_handleConnection: (self, c) ->
        client = new Socket()
        client._socket = c

        data = null;
        length = null;

        c.on 'data', (d) ->
            if data == null
                data = d
            else
                data = Buffer.concat([data, d])

            loopp = true
            while loopp
                loopp = false

                if length == null and data.length >= 4
                    length = data.readUInt32BE(0)

                if length != null and data.length >= length + 4
                    messageData = data.slice(4, 4 + length)
                    message = JSON.parse(messageData.toString())

                    data = data.slice(4 + length)
                    loopp = true if data.length > 0
                    length = null

                    self.onMessage(client, message.data)