Searched defs:openSubscription (Results 1 – 6 of 6) sorted by relevance
23 public fun <T> MaybeSource<T>.openSubscription(): ReceiveChannel<T> { in openSubscription() method38 public fun <T> ObservableSource<T>.openSubscription(): ReceiveChannel<T> { in openSubscription() method
32 public fun openSubscription(): ReceiveChannel<E> in openSubscription() method
129 override fun openSubscription(): ReceiveChannel<E> { in openSubscription() method
101 public override fun openSubscription(): ReceiveChannel<E> { in <lambda>() method in kotlinx.coroutines.channels.ConflatedBroadcastChannel
59 public override fun openSubscription(): ReceiveChannel<E> = in <lambda>() method in kotlinx.coroutines.channels.ArrayBroadcastChannel
24 public fun <T> Publisher<T>.openSubscription(request: Int = 1): ReceiveChannel<T> { in <lambda>() method