WatchPublisher

public struct WatchPublisher : Publisher

リモート MongoDB コレクションが変更されるたびに 変更イベント を発行する発行者。

  • 宣言

    Swift

    public typealias Output = AnyBSON
  • 宣言

    Swift

    public typealias Failure = Error
  • 監視変更ストリームが開かれたときにイベントをトリガーします。

    作業を実行する前に変更ストリームを開く必要がある場合は、この関数を使用します。 これは、発行者を呼び出した後、直接呼び出す必要があります。

    宣言

    Swift

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

    パラメーター

    event

    変更ストリームが開かれると呼び出されるコールバック。

    戻り値

    リモート MongoDB コレクションが変更されるたびに 変更イベント を発行する発行者。

  • サブスクライブ、キャンセル、リクエスト操作を実行するスケジューラーを指定します。

    宣言

    Swift

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

    パラメーター

    scheduler

    サブスクリプションを実行するスケジューラー。

    戻り値

    指定されたスケジューラーをサブスクライブする出版社。