Searched defs:toChannel (Results 1 – 5 of 5) sorted by relevance
33 internal fun <T> MaybeSource<T>.toChannel(): ReceiveChannel<T> { in collect() method40 internal fun <T> ObservableSource<T>.toChannel(): ReceiveChannel<T> { in toChannel() method
22 internal fun <T> Publisher<T>.toChannel(request: Int = 1): ReceiveChannel<T> { in <lambda>() method
342 static Channel toChannel(InternalInstrumented<ChannelStats> channel) { in toChannel() method in ChannelzProtoUtil
572 public void toChannel() throws Exception { in toChannel() method in ChannelzProtoUtilTest
276 internal suspend fun <E, C : SendChannel<E>> ReceiveChannel<E>.toChannel(destination: C): C { in toChannel() method