WatchPublisher

public struct WatchPublisher : Publisher

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

在 GitHub 上显示

  • 声明

    迅速

    public typealias Output = AnyBSON
    在 GitHub 上显示

  • 声明

    迅速

    public typealias Failure = Error
    在 GitHub 上显示

  • Atlas Triggers一个事件当change stream被打开。

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

    声明

    迅速

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

    参数

    event

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

    返回值

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

    在 GitHub 上显示

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

    声明

    迅速

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

    参数

    scheduler

    执行订阅的调度器。

    返回值

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

    在 GitHub 上显示