This blocks the `onNext` until `subscribe` happens and the latch is released. This attempts to make inter-thread behavior act like `onNext` on the same thread. It exhibits back pressure until the work is complete and resolves the "time gap" issue. 

However, I'm not 100% confident the latch is foolproof and that my testing has accounted for all use cases.