public final class AsyncStreamHelper extends Object
AsyncInputStream or AsyncOutputStream instances.
Provides support for:
byte[] - Converts byte arrays into Async StreamsByteBuffer - Converts ByteBuffers into Async StreamsInputStream - Converts InputStreams into Async Streams (Note: InputStream implementations are blocking)OutputStream - Converts OutputStreams into Async Streams (Note: OutputStream implementations are blocking)public static AsyncInputStream toAsyncInputStream(byte[] srcBytes)
byte[] into a AsyncInputStreamsrcBytes - the data sourcepublic static AsyncInputStream toAsyncInputStream(byte[] srcBytes, ObservableAdapter observableAdapter)
byte[] into a AsyncInputStreamsrcBytes - the data sourceobservableAdapter - the ObservableAdapterpublic static AsyncOutputStream toAsyncOutputStream(byte[] dstBytes)
byte[] into a AsyncOutputStreamdstBytes - the data destinationpublic static AsyncOutputStream toAsyncOutputStream(byte[] dstBytes, ObservableAdapter observableAdapter)
byte[] into a AsyncOutputStreamdstBytes - the data destinationobservableAdapter - the ObservableAdapterpublic static AsyncInputStream toAsyncInputStream(ByteBuffer srcByteBuffer)
ByteBuffer into a AsyncInputStreamsrcByteBuffer - the data sourcepublic static AsyncInputStream toAsyncInputStream(ByteBuffer srcByteBuffer, ObservableAdapter observableAdapter)
ByteBuffer into a AsyncInputStreamsrcByteBuffer - the data sourceobservableAdapter - the ObservableAdapterpublic static AsyncOutputStream toAsyncOutputStream(ByteBuffer dstByteBuffer)
ByteBuffer into a AsyncOutputStreamdstByteBuffer - the data destinationpublic static AsyncOutputStream toAsyncOutputStream(ByteBuffer dstByteBuffer, ObservableAdapter observableAdapter)
ByteBuffer into a AsyncOutputStreamdstByteBuffer - the data destinationobservableAdapter - the ObservableAdapterpublic static AsyncInputStream toAsyncInputStream(InputStream inputStream)
InputStream into a AsyncInputStreaminputStream - the InputStreampublic static AsyncInputStream toAsyncInputStream(InputStream inputStream, ObservableAdapter observableAdapter)
InputStream into a AsyncInputStreaminputStream - the InputStreamobservableAdapter - the ObservableAdapterpublic static AsyncOutputStream toAsyncOutputStream(OutputStream outputStream)
OutputStream into a AsyncOutputStreamoutputStream - the OutputStreampublic static AsyncOutputStream toAsyncOutputStream(OutputStream outputStream, ObservableAdapter observableAdapter)
OutputStream into a AsyncOutputStreamoutputStream - the OutputStreamobservableAdapter - the ObservableAdapter