code: @Override
      public void reset() {
  
          if (debugEnabled) {
              logger.debug("{} reset()", logPrefix());
          }
  
          if (channel != null) {
              channel.pipeline().fireUserEventTriggered(new ConnectionEvents.Reset());
          }
          cancelBufferedCommands("Reset");
      }
docs: Reset the writer state. Queued commands will be canceled and the internal state will be reset. This is useful when the
  internal state machine gets out of sync with the connection.