A helper publisher created by calling
.threadSafeReference() on a
publisher which emits
Specifies the scheduler on which to receive elements from the publisher.
This publisher converts each value emitted by the upstream publisher to a
ThreadSafeReference, passes it to the target scheduler, and then converts back to the original type.
public func receive<S>(on scheduler: S) -> DeferredHandoverCollectionChangeset<Upstream, T, S> where S : Scheduler
The serial dispatch queue to receive values on.
A publisher which delivers values to the given scheduler.