onSubscribe

open override fun onSubscribe(subscription: Subscription)