@Override
    public void flush() throws TTransportException {
        ChannelBuffer flush = ChannelBuffers.dynamicBuffer();
        flush.writeBytes(output);
        channel.write(flush).awaitUninterruptibly();
    }
@Override
    public void flush() throws TTransportException {
        ChannelBuffer flush = ChannelBuffers.dynamicBuffer();
        flush.writeBytes(output);
        channel.write(flush).awaitUninterruptibly();
    }
@ Override public void flush ( ) throws TTransportException { ChannelBuffer flush = ChannelBuffers . dynamicBuffer ( ) ; flush . writeBytes ( output ) ; channel . write ( flush ) . awaitUninterruptibly ( ) ; }
We need data to be written and flushed at once.
We need data to be written and flushed at once .