Searched refs:channelA (Results 1 – 3 of 3) sorted by relevance
21 val channelA = source.openSubscription() in <lambda>() constant25 channelA.onReceiveOrNull { in <lambda>()41 val r = channelA.receiveOrNull() in <lambda>()46 channelA.cancel() in <lambda>()
30 val channelA = source.openSubscription(request) in <lambda>() constant34 channelA.onReceiveOrNull { in <lambda>()50 val r = channelA.receiveOrNull() in <lambda>()56 channelA.cancel() in <lambda>()