UseThreadセーフ

@frozen
public struct MakeThreadSafe<Upstream> : Publisher where Upstream : Publisher, Upstream.Output : ThreadConfined

スレッド定義オブジェクトのストリームに対してreceive(on:)を動作させる出版社

.threadセーフリファレンス() を使用して作成

Githubでの表示

  • パブリッシャーから要素を受け取るスケジューラーを指定します。

    このパブリックは、アップストリーム パブリックの各値をThreadSafeReferenceに変換し、それをターゲット スケジューラーに渡し、その後元の型に変換します。

    宣言

    Swift

    public func receive<S>(on scheduler: S) -> DeferredHandover<Upstream, S> where S : Scheduler

    パラメーター

    scheduler

    値を受信するシリアル ディスパッチ キュー。

    戻り値

    指定されたスケジューラーに値を提供する出版社。

    Githubでの表示