SubscribableState

A SubscribableState object allows you to subscribe an Observer to receive updates from a specific source - as with Subscribable. Each updated value will be provided through the given Observer.onNext method.

The SubscribableState also maintains the current value of the property for synchronous access

Updates can be immediate, or asynchronous depending on the underlying source.

To stop observing updates, use the Disposable.dispose method of the returned Disposable.

Properties

abstract val value: T

The current value of the property.

Subscribes the given onNext to receive updates, where no Observer.onComplete is required.

abstract fun subscribe(observer: Observer<T>): Disposable

Subscribes the given observer to receive updates, including an Observer.onComplete notification when the upstream source terminates.

open fun subscribe(onNext: Consumer<T>, onComplete: Runnable): Disposable

Subscribes the given onNext to receive updates, and the given onComplete to receive the Observer.onComplete signal