docs: @Override
  	public void userEventTriggered(ChannelHandlerContext ctx, Object msg) throws Exception {
  		if (msg instanceof RemoteInputChannel) {
  			boolean triggerWrite = inputChannelsWithCredit.isEmpty();
  
  			inputChannelsWithCredit.add((RemoteInputChannel) msg);
  
  			if (triggerWrite) {
  				writeAndFlushNextMessageIfPossible(ctx.channel());
  			}
  		} else {
  			ctx.fireUserEventTriggered(msg);
  		}
  	}