subscribe

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