@Test public void testInputDecodesOnePacket() { String encodedBytes = "<-A->"; putBytesIntoTransport(encodedBytes); assertEquals("a_", _underlyingInput.getAcceptedInput()); assertEquals(CapitalisingDummySslEngine.MAX_ENCODED_CHUNK_SIZE, _sslWrapper.capacity()); assertEquals(2, _dummySslEngine.getUnwrapCount()); assertEquals(1, _underlyingInput.getProcessCount()); }
@Override public int capacity() { if (_tail_closed) return Transport.END_OF_STREAM; return _inputBuffer.remaining(); }
SimpleSslTransportWrapper implements SslTransportWrapper { @Override public int capacity() { if (_tail_closed) return Transport.END_OF_STREAM; return _inputBuffer.remaining(); } }
SimpleSslTransportWrapper implements SslTransportWrapper { @Override public int capacity() { if (_tail_closed) return Transport.END_OF_STREAM; return _inputBuffer.remaining(); } SimpleSslTransportWrapper(ProtonSslEngine sslEngine, TransportInput underlyingInput, TransportOutput underlyingOutput); }
SimpleSslTransportWrapper implements SslTransportWrapper { @Override public int capacity() { if (_tail_closed) return Transport.END_OF_STREAM; return _inputBuffer.remaining(); } SimpleSslTransportWrapper(ProtonSslEngine sslEngine, TransportInput underlyingInput, TransportOutput underlyingOutput); @Override String getCipherName(); @Override String getProtocolName(); @Override int capacity(); @Override int position(); @Override ByteBuffer tail(); @Override void process(); @Override void close_tail(); @Override int pending(); @Override ByteBuffer head(); @Override void pop(int bytes); @Override void close_head(); @Override String toString(); }
SimpleSslTransportWrapper implements SslTransportWrapper { @Override public int capacity() { if (_tail_closed) return Transport.END_OF_STREAM; return _inputBuffer.remaining(); } SimpleSslTransportWrapper(ProtonSslEngine sslEngine, TransportInput underlyingInput, TransportOutput underlyingOutput); @Override String getCipherName(); @Override String getProtocolName(); @Override int capacity(); @Override int position(); @Override ByteBuffer tail(); @Override void process(); @Override void close_tail(); @Override int pending(); @Override ByteBuffer head(); @Override void pop(int bytes); @Override void close_head(); @Override String toString();  }