MakeThreadSafeCollectionChangeset

@frozen
public struct MakeThreadSafeCollectionChangeset<Upstream, T> : Publisher where Upstream : Publisher, T : RealmCollection, Upstream.Output == RealmCollectionChange<T>

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

在 GitHub 上显示

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

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

    声明

    迅速

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

    参数

    scheduler

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

    返回值

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

    在 GitHub 上显示