code: public synchronized void flush(boolean bSendFakeTrx)
      {
          try {
              if (bSendFakeTrx)
                  this.getWriter().writeObject(FAKE_TRX);
              this.getWriter().flush();
          } catch (IOException e) {
              e.printStackTrace();
          }
      }
docs: Flush the buffer.
  @param bSendFakeTrx Send a fake trx before flushing (This guarantees activity on the stream before the flush [In case it just autoflushed the entire buffer])