值

@frozen
public struct Value<Subscribable> : Publisher where Subscribable : RealmSubscribable, Subscribable : ThreadConfined

每次对象发生变更时都会发出该对象或collection的发布者。

在 GitHub 上显示

  • 此发布者实际上不会失败，并且将来会更改为“从不”。

    声明

    Swift

    public typealias Failure = Error
    在 GitHub 上显示

  • 此发布者发出它正在发布的对象或集合。

    声明

    Swift

    public typealias Output = Subscribable
    在 GitHub 上显示

  • 捕获通过观察 Realm 集合而生成的NotificationToken 。

    这允许您在执行Realm.write(withoutNotifying:)时跳过通知。 如果您需要写入 Realm 数据库并忽略此特定观察链，则应使用此调用。 NotificationToken将保存在receive(subscriber:)中设置的观察块中的指定KeyPath上。

    声明

    Swift

    public func saveToken<T>(on object: T, at keyPath: WritableKeyPath<T, NotificationToken?>) -> ValueWithToken<Subscribable, T>

    参数

    object

    写入NotificationToken的对象。
    keyPath

    写入NotificationToken的 KeyPath。

    返回值

    一个ValueWithToken发布者。

    在 GitHub 上显示

  • 指定执行订阅、取消和请求操作的调度程序。

    对于 Realm 发布者，这决定了将底层变更通知发送到哪个队列。 如果随后未使用receive(on:) ，它还将确定对从发布者收到的哪些队列元素进行评估。 目前仅支持串行调度队列，不支持options:参数。

    声明

    Swift

    public func subscribe<S>(on scheduler: S) -> Value<Subscribable> where S : Scheduler

    参数

    scheduler

    要对其执行订阅的串行调度队列。

    返回值

    在给定调度器上进行订阅的发布者。

    在 GitHub 上显示

  • 指定执行下游操作的调度器。

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

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

    声明

    Swift

    public func receive<S>(on scheduler: S) -> RealmPublishers.Handover<`Self`, S> where S : Scheduler

    参数

    scheduler

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

    返回值

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

    在 GitHub 上显示