PubSub

A class that allows to subscribe for events until the returned subscription is disposed.

A protocol to provide all publisher-like classes access to a corresponding observable.

An observable that holds the current value as the current state.

You can use updates to receive only future updates in a new observable.

Contains factory methods for creating common Observable instances for use with the Tealium SDK.

A concrete implementation of the Publisher that will forward all events published to the contained observable and therefore to the observers subscribed to it.

A protocol to provide all publisher-like classes some utilities like publish() for Void events.

A Subject that, in addition to normal publish and subscribe behavior, holds a cache of items and sends it, in order, to each new observer that is subscribed.

You can use it as a property wrapper to make the publishing private in the class where it’s contained, but still expose an Observable to the other classes.

A Subject that must always have a value.

You can use it as a property wrapper to make the publishing private in the class where it’s contained, but still expose an ObservableState to the other classes.

A Publisher that can be also subscribed to.

You can use it as a property wrapper to make the publishing private in the class where it’s contained, but still expose an Observable to the other classes.

A Subscribable implementation whereby only a single result is expected to be emitted to the subscriber.

A Single that completes with a Result<T, Error>.

With a SingleResult you can subscribe as any other type of Single, but you can also subscribe only for onSuccess or onFailure to receive the event only in case the event is respectively either a success or a failure.

So in case you want to handle both success and failure:

 single.subscribe { result in
      switch result {
       case let .success(output):
          // Handle success
          break
       case let .failure(error):
          // Handle failure
          break
 }

In case you want to handle only successes:

 single.onSuccess { output in
   // Handle success
 }

In case you want to handle only failures:

 single.onFailure { error in
   // Handle failure
 }

A group that contains many disposable objects and disposes them simultaneously.

An protocol representing some long-lived operation that can be disposed.

Contains factory methods for creating common Disposable instances for use with the Tealium SDK.

A protocol to provide all observable-like classes some utilities like subscribeOnce or the operators.

An object from which you can extract an optional value.