public class ValueWithToken<Subscribable, T> : Publisher where Subscribable : RealmSubscribable, Subscribable : ThreadConfined
A publisher which emits an object or collection each time that object is mutated.
This publisher cannot actually fail and will change to Never in the future.
public typealias Failure = Error
This publisher emits the object or collection which it is publishing.
public typealias Output = Subscribable
Specifies the scheduler on which to perform subscribe, cancel, and request operations.
For Realm Publishers, this determines which queue the underlying change notifications are sent to. If
receive(on:)is not used subsequently, it also will determine which queue elements received from the publisher are evaluated on. Currently only serial dispatch queues are supported, and the
options:parameter is not supported.
public func subscribe<S>(on scheduler: S) -> ValueWithToken<Subscribable, T> where S : Scheduler
The serial dispatch queue to perform the subscription on.
A publisher which subscribes on the given scheduler.
Specifies the scheduler on which to perform downstream operations.
This differs from
subscribe(on:)in how it is integrated with the autorefresh cycle. When using
subscribe(on:), the subscription is performed on the target scheduler and the publisher will emit the collection during the refresh. When using
receive(on:), the collection is then converted to a
ThreadSafeReferenceand delivered to the target scheduler with no integration into the autorefresh cycle, meaning it may arrive some time after the refresh occurs.
When in doubt, you probably want
public func receive<S>(on scheduler: S) -> Handover<ValueWithToken, S> where S : Scheduler
The serial dispatch queue to receive values on.
A publisher which delivers values to the given scheduler.