marcoferrer
01/08/2019, 8:47 PMfun <T> CoroutineScope.parallelActor(
paralellism: Int,
block: suspend ActorScope<T>.()->Unit
): SendChannel<T> {
require(paralellism > 0)
val sendChannel = Channel<T>()
repeat(paralellism){
launch {
sendChannel.toChannel(actor (block = block))
}
}
return sendChannel
}