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