468469470471472473474475476477478
} public TransportWrapper wrap(final TransportInput input, final TransportOutput output) { return new TransportWrapper() { private boolean _outputComplete; @Override public int input(byte[] bytes, int offset, int size)
225226227228229230231232233234235
public Sasl sasl() { if(_sasl == null) { _sasl = new SaslImpl(); TransportWrapper transportWrapper = _sasl.wrap(_inputProcessor, _outputProcessor); _inputProcessor = transportWrapper; _outputProcessor = transportWrapper; } return _sasl;