core/com.tealium.prism.core.api.pubsub/Subscribable

Subscribable

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

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

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

Inheritors

Observable

Single

SubscribableState

Functions

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

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