### Question:
SimpleNettyChannel implements Channel { @Override public Future<Void> writeAndFlush( Object msg ) { checkDisposed(); return channel.writeAndFlush( msg ); } SimpleNettyChannel( io.netty.channel.Channel channel, Log log ); @Override boolean isDisposed(); @Override synchronized void dispose(); @Override boolean isOpen(); @Override Future<Void> write( Object msg ); @Override Future<Void> writeAndFlush( Object msg );  }### Answer:
@Test public void shouldWriteAndFlushOnNettyChannel() { SimpleNettyChannel channel = new SimpleNettyChannel( nettyChannel, NullLog.getInstance() ); Object msg = new Object(); Future<Void> writeComplete = channel.writeAndFlush( msg ); assertTrue( writeComplete.isDone() ); assertEquals( msg, nettyChannel.readOutbound() ); }