subscribe

open override val subscribe: SubscriptionReceiver.() -> Flow<T>