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 (() -> Void)) -> Publishers.WatchPublisher

    매개변수

    event

    변경 스트림이 열리면 호출될 콜백입니다.

    반환 값

    원격 MongoDB collection이 변경될 때마다 변경 이벤트를 발생시키는 출판사입니다.

    GitHub에 표시

  • 구독, 취소 및 요청 작업을 수행할 스케줄러를 지정합니다.

    선언

    스위프트

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

    매개변수

    scheduler

    구독을 수행할 디스패치 대기열입니다.

    반환 값

    지정된 스케줄러에서 구독하는 출판사입니다.

    GitHub에 표시