i would turn B's onComplete into an event and then...
# rx
j
i would turn B's onComplete into an event and then use skipUntil