code: @Override
  	public ChannelInput<ByteBuf> getInput() {
  		return input -> {
  			this.input = sanitize(input);
  			//noinspection ConstantConditions
  			if (this.input != null && this.output != null) startProcess();
  			return getProcessCompletion();
  		};
  	}
docs: check input for clarity