gistfile1.ooc

use zeromq
import zeromq, threading/Thread, os/Time

me: Socket

Actor: class extends Thread {

    ctx: Context
    me: Socket
    init: func(=ctx) {
        me = Socket new(ctx, SocketType pair)
        me bind("inproc://me")
    }

    start: func {
        while (true) {
            "Yay" println()
            request := me recv()
            printf("%s \n", request data())
            Time sleepSec(1)
        }
    }

    wait: func {  }
}
main: func {
    ctx := Context new(2)
    me := Socket new(ctx, SocketType sub)
    me bind("inproc://me")
    actor := Actor new(ctx)
    actor start()
    while (true) {
        "yao" println()
        me send(Message new("hallo", "hallo" length(), null, null), SendRecvOption noBlock)
        Time sleepSec(2)
    }
}