MakeThreadSafeSectionedResultsChangeset

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

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

在 GitHub 上显示


                    
                    
                    receive(on:)

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

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

声明

Swift

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

参数


                                scheduler

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

返回值

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

在 GitHub 上显示