openSubscription

fun <T> MaybeSource<T>.openSubscription(): SubscriptionReceiveChannel<T>

Subscribes to this MaybeSource and returns a channel to receive elements emitted by it. The resulting channel shall be closed to unsubscribe from this source.