com.mongodb.reactivestreams.client.gridfs.helpers

Class AsyncStreamHelper

java.lang.Object

com.mongodb.reactivestreams.client.gridfs.helpers.AsyncStreamHelper

public final class AsyncStreamHelper
extends java.lang.Object

A general helper class that creates AsyncInputStream or AsyncOutputStream instances. Provides support for:

• byte[] - Converts byte arrays into Async Streams
• ByteBuffer - Converts ByteBuffers into Async Streams
• InputStream - Converts InputStreams into Async Streams (Note: InputStream implementations are blocking)
• OutputStream - Converts OutputStreams into Async Streams (Note: OutputStream implementations are blocking)

Since:

1.3

Method Summary

Modifier and Type	Method and Description
static AsyncInputStream	toAsyncInputStream(byte[] srcBytes) Converts a byte[] into a AsyncInputStream
static AsyncInputStream	toAsyncInputStream(java.nio.ByteBuffer srcByteBuffer) Converts a ByteBuffer into a AsyncInputStream
static AsyncInputStream	toAsyncInputStream(java.io.InputStream inputStream) Converts a InputStream into a AsyncInputStream
static AsyncOutputStream	toAsyncOutputStream(byte[] dstBytes) Converts a byte[] into a AsyncOutputStream
static AsyncOutputStream	toAsyncOutputStream(java.nio.ByteBuffer dstByteBuffer) Converts a ByteBuffer into a AsyncOutputStream
static AsyncOutputStream	toAsyncOutputStream(java.io.OutputStream outputStream) Converts a OutputStream into a AsyncOutputStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

toAsyncInputStream

public static AsyncInputStream toAsyncInputStream(byte[] srcBytes)

Converts a byte[] into a AsyncInputStream

Parameters:

srcBytes - the data source

Returns:

the AsyncInputStream

toAsyncOutputStream

public static AsyncOutputStream toAsyncOutputStream(byte[] dstBytes)

Converts a byte[] into a AsyncOutputStream

Parameters:

dstBytes - the data destination

Returns:

the AsyncOutputStream

toAsyncInputStream

public static AsyncInputStream toAsyncInputStream(java.nio.ByteBuffer srcByteBuffer)

Converts a ByteBuffer into a AsyncInputStream

Parameters:

srcByteBuffer - the data source

Returns:

the AsyncInputStream

toAsyncOutputStream

public static AsyncOutputStream toAsyncOutputStream(java.nio.ByteBuffer dstByteBuffer)

Converts a ByteBuffer into a AsyncOutputStream

Parameters:

dstByteBuffer - the data destination

Returns:

the AsyncOutputStream

toAsyncInputStream

public static AsyncInputStream toAsyncInputStream(java.io.InputStream inputStream)

Converts a InputStream into a AsyncInputStream

Parameters:

inputStream - the InputStream

Returns:

the AsyncInputStream

toAsyncOutputStream

public static AsyncOutputStream toAsyncOutputStream(java.io.OutputStream outputStream)

Converts a OutputStream into a AsyncOutputStream

Parameters:

outputStream - the OutputStream

Returns:

the AsyncOutputStream