Okay so back with another question. I want all cor...

# coroutines

[jkbbwr]

Okay so back with another question.
I want all coroutines spawned in network, both the inbound and any actors handling outbound to be children of soemthing so I can cancel the lot in one go

class Network(val bind: String)  {
    val zmqContext = ZMQ.context(2)
    val pull = zmqContext.socket(ZMQ.PULL)
    val recvThread = newSingleThreadContext("zmqRecvThread")
    val sendPool = newFixedThreadPoolContext(4, "zmqSendPool")
    val peers = mutableListOf<SendChannel<String>>()
    val parent = Job()

    suspend fun connect(endpoint: String): SendChannel<String> {
        val peer = actor<String>(CoroutineName(endpoint), parent=parent) {
            log("peer")
            val push = zmqContext.socket(ZMQ.PUSH)
            push.connect(endpoint)

            for (message in channel) {
                withContext(sendPool) {
                    push.send(message)
                }
            }
        }
        peers.add(peer)
        return peer
    }

    fun run() = async(parent) {
        log("inbox")
        pull.bind(bind)

        while (true) {
            val message = withContext(recvThread) {
                pull.recvStr()
            }
            log(message)
        }
    }
}