MakeThreadSafe

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

使receive(on:)适用于线程限制对象流的发布者

使用 .threadSafeReference() 创建

在 GitHub 上显示

  • 指定从发布者接收元素的调度器。

    该发布者将上游发布者发出的每个值转换为ThreadSafeReference ，将其传递给目标调度程序，然后再转换回原始类型。

    声明

    迅速

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

    参数

    scheduler

    用于接收值的串行调度队列。

    返回值

    向给定调度程序传递值的发布者。

    在 GitHub 上显示