onSubscribe

abstract fun onSubscribe(subscription: Subscription)