MakeThreadSafeProjectionChangeset

@frozen
public struct MakeThreadSafeProjectionChangeset<Upstream, T> : Publisher where Upstream : Publisher, T : ProjectionObservable, Upstream.Output == ObjectChange<T>

通过在发出线程限制值的发布者上调用.threadSafeReference()来创建的辅助发布者。

在 GitHub 上显示

  • 指定要向其交付投影变更集的调度程序。

    这与subscribe(on:)的不同之处在于它与自动刷新周期集成的方式。 使用subscribe(on:)时，在目标调度器上执行订阅，并且发布者将在刷新期间发出集合。 使用receive(on:)时，该集合会转换为ThreadSafeReference并传递到目标计划程序，而不会集成到自动刷新周期中，这意味着它可能会在刷新发生后的某个时间到达。

    如有疑问，您可能需要subscribe(on:) 。

    声明

    迅速

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

    参数

    scheduler

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

    返回值

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

    在 GitHub 上显示