1 min readMar 20, 2019
The first subscriber would receive enqueued events, and otherwise all subscribers receive all events (when they are subscribed), no?
I’m sure you can hack it together to “wait for all expected subscriber count” with connectable observables but then you need to remember to modify the number of expected subscribers.
The benefit of DispatchWorkSubject over UnicastWorkSubject is that it doesn’t explode if you have multiple subscribers, it ought to work the same way as the “enqueued EventBus” example above.