code: private void writeEvent(final ChannelHandlerContext ctx, final Object message) {
          if (isFinishedSent)
              return;
          
          if (message instanceof FinishedMessage)
              isFinishedSent = true;
  
          Channels.write(ctx, Channels.future(null), message);
      }
docs: will send no message after the FINISHED