and if you only want to complete upstream use take...
# rx
u
and if you only want to complete upstream use take, or variations. but check it first via doOnComplete etc