WatchPublisher

public struct WatchPublisher : Publisher

A publisher that emits a change event each time the remote MongoDB collection changes.

  • Declaration

    Swift

    public typealias Output = AnyBSON
  • Declaration

    Swift

    public typealias Failure = Error
  • Specifies the scheduler on which to perform subscribe, cancel, and request operations.

    Declaration

    Swift

    public func subscribe<S>(on scheduler: S) -> WatchPublisher where S : Scheduler

    Parameters

    scheduler

    The dispatch queue to perform the subscription on.

    Return Value

    A publisher which subscribes on the given scheduler.