MakeThreadSafeSectionedResultsChangeset

@frozen
public struct MakeThreadSafeSectionedResultsChangeset<Upstream, T> : Publisher where Upstream : Publisher, T : RealmSectionedResult, Upstream.Output == SectionedResultsChange<T>

通过在发出SectionedResultsChange的发布者上调用.threadSafeReference()创建的辅助发布者。

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

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

    声明

    Swift

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

    参数

    scheduler

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

    返回值

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