subscriber work

TCPSession.cpp

@@ -58,17 +58,13 @@ namespace core
 
    void TCPSession::onConnected() {}
 
-   void TCPSession::onDataReceived(coreutils::ZString &data)
-   {
-      if (data.getLength() > 0)
-      {
+   void TCPSession::onDataReceived(coreutils::ZString &data) {
+      if (data.getLength() > 0) {
          lineBuffer = (char *)realloc(lineBuffer, lineBufferSize + data.getLength());
          memcpy(lineBuffer + lineBufferSize, data.getData(), data.getLength());
          lineBufferSize += data.getLength();
-         while (lineBufferSize > 0)
-         {
-            if (blockSize == 0)
-            {
+         while (lineBufferSize > 0) {
+            if (blockSize == 0) {
                lineLength = strcspn(lineBuffer, "\r\n");
                if (lineLength == lineBufferSize)
                   break;
@@ -118,7 +114,7 @@ namespace core
 
    void TCPSession::send() {
       if(out.tellp() > 0)
-	      write(out.str(), this);
+	      write(out.str());
       out.str("");
    }