Searched refs:resultChannel (Results 1 – 3 of 3) sorted by relevance
69 val resultChannel: Channel<Unit> = Channel(1) in <lambda>() constant71 val requestor = requestorActorUnfair(computations, resultChannel) in <lambda>()73 resultChannel.receive() in <lambda>()78 val resultChannel: Channel<Unit> = Channel(1) in <lambda>() constant80 val requestor = requestorActorFair(computations, resultChannel) in <lambda>()82 resultChannel.receive() in <lambda>()
68 val resultChannel: Channel<Unit> = Channel(requestorActorsCount) in run() constant70 …val requestors = (0 until requestorActorsCount).map { requestorActor(computations, resultChannel) } in run()77 resultChannel.receive() in run()
27 val resultChannel = Channel<Update>(size) in <lambda>() constant35 resultChannel.send(Update(i, value)) in <lambda>()41 resultChannel.close() in <lambda>()57 … var element = resultChannel.receiveOrNull() ?: break // Channel is closed, nothing to do here in <lambda>()68 element = resultChannel.poll() ?: break in <lambda>()