subscribe

open fun subscribe(listener: Consumer<T>): Subscription