DataObserver

Public facing interface for users to grab data

Constructors

DataObserver

Thread

Represents a thread in which the result of a subscribe should be handled on.

dispose

This will dispose any api calls being made from this observer

isDisposed

fun subscribe(onSuccess: (T) -> Unit, onError: (Throwable) -> Unit = {}, thread: DataObserver.Thread = Thread.Main): DataObserver<T>

This will allow users to subscribe for data

onDisposed

var onDisposed: () -> Unit? = null

An optional callback that will be triggered after the DataObserver has been disposed.

convertToRxJava

Converts a DataObserver back into an RxJava pipeline, as a Single.

getNow

Provides blockingGet() functionality to DataObservers.