public struct WatchPublisher : Publisher
A publisher that emits a change event each time the remote MongoDB collection changes.
public typealias Failure = Error
Specifies the scheduler on which to perform subscribe, cancel, and request operations.
public func subscribe<S>(on scheduler: S) -> WatchPublisher where S : Scheduler
The dispatch queue to perform the subscription on.
A publisher which subscribes on the given scheduler.