module chatclient;

import tango.net.Socket;
import tango.core.Thread;
import tango.io.Stdout;
import tango.io.Console;
import tango.util.log.Log;

import dreactor.core.Vat; 
import dreactor.core.Dispatcher;

import dreactor.protocol.RawTcp;
import dreactor.transport.AsyncSocketConduit;

int main()
{ 
    Vat c_vat = new Vat();
    RawTCPClient client = new RawTCPClient(c_vat);
    Log.root.level(log.Level.Warn, true); 

    client.setDataHandler( (char[] inbuf, Dispatcher d) {
        Stdout(inbuf)();
    });
 
    c_vat.run();
    client.connect(new IPv4Address("localhost", 5555));
    
    while(true)
    {
        char buf[] = Cin.copyln(true);
        if (buf == "quit\n")
            break;
        client.send(buf);             
    }
    c_vat.exit();
    delete client;
    return 0;
}