openSubscription
fun <T> ObservableSource<T>.openSubscription(): SubscriptionReceiveChannel<T>Subscribes to this ObservableSource and returns a channel to receive elements emitted by it. The resulting channel shall be closed to unsubscribe from this source.