#include "moustique.hh"

int main()
{
    moustique_listen(1234, // Port number
                     SOCK_STREAM, // TCP socket
                     2, // number of threads
         [] (int fd, auto read, auto write) {

           printf("new connection: %i\n", fd);

           char buf[1024];
           int received;
           
           while (received = read(buf, sizeof(buf))) // Suspend until new bytes
                                                     // are available for reading.

             if (!write(buf, received)) // Suspend until the socket is ready for a write.
               break;

           printf("end of connection: %i\n", fd);
         }
    );
}