observe

open fun observe(consumer: Consumer<T>): Disposable