onSubscribe

open override fun onSubscribe(subscription: Flow.Subscription)