Searched defs:openSubscription (Results 1 – 3 of 3) sorted by relevance
23 public fun openSubscription(): ReceiveChannel<E> in openSubscription() method115 override fun openSubscription(): ReceiveChannel<E> = lock.withLock { // protected by lock in <lambda>() method in kotlinx.coroutines.channels.BroadcastChannelImpl
112 override fun openSubscription(): ReceiveChannel<E> { in openSubscription() method
102 public fun <T> Publisher<T>.openSubscription(request: Int = 1): ReceiveChannel<T> { in openSubscription() method