WatchPublisher

public struct WatchPublisher : Publisher

每次远程 MongoDB collection发生更改时发出事件的发布者。

在 GitHub 上显示

  • 声明

    Swift

    public typealias Output = AnyBSON
    在 GitHub 上显示

  • 声明

    Swift

    public typealias Failure = Error
    在 GitHub 上显示

  • 打开监视变更流时触发事件。

    当您需要在执行任何工作之前打开变更流时，请使用此功能。 这应该在调用发布者后直接调用。

    声明

    Swift

    public func onOpen(_ event: @escaping (() -> Void)) -> Publishers.WatchPublisher

    参数

    event

    变更流打开后将调用的回调。

    返回值

    每次远程 MongoDB collection发生更改时发出事件的发布者。

    在 GitHub 上显示

  • 指定执行订阅、取消和请求操作的调度程序。

    声明

    Swift

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

    参数

    scheduler

    要对其执行订阅的调度队列。

    返回值

    在给定调度器上进行订阅的发布者。

    在 GitHub 上显示