server.d

import std.socket,
       std.socketstream,
       std.stream,
       core.thread;

void main()
{
    TcpSocket listener;
    Thread loopThread;

    void loop()
    {
        auto client = listener.accept();
        auto stream = new SocketStream( client, FileMode.In | FileMode.Out );

        //ubyte opcode;
        //stream.read( opcode );

        //Do whatever.

        stream.flush();
        stream.close();
        client.shutdown( SocketShutdown.BOTH );
        client.close();
    }

    const ushort port = 9991;
    const int backlog = 10;
    auto listenHost = new InternetAddress( "0.0.0.0", port );

    listener = new TcpSocket();
    listener.blocking = true;
    listener.bind( listenHost );
    listener.listen( backlog );

    loopThread = new Thread( &loop );
    loopThread.isDaemon = false;
    loopThread.start();
}