Searched refs:channelB (Results 1 – 3 of 3) sorted by relevance
22 val channelB = source.openSubscription() in <lambda>() constant29 channelB.onReceiveOrNull { in <lambda>()37 val r = channelB.receiveOrNull() in <lambda>()47 channelB.cancel() in <lambda>()
31 val channelB = source.openSubscription(request) in <lambda>() constant38 channelB.onReceiveOrNull { in <lambda>()46 val r = channelB.receiveOrNull() in <lambda>()57 channelB.cancel() in <lambda>()