com.mongodb.reactivestreams.client.gridfs

Interface AsyncInputStream

All Known Subinterfaces:

GridFSDownloadStream

public interface AsyncInputStream

The Async Input Stream interface represents some asynchronous input stream of bytes.

See the client.gridfs.helpers package for adapters that create an AsyncInputStream

Since:

1.3

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<Success>	close() Closes the input stream
org.reactivestreams.Publisher<java.lang.Integer>	read(java.nio.ByteBuffer dst) Reads a sequence of bytes from this stream into the given buffer.

Method Detail

read

org.reactivestreams.Publisher<java.lang.Integer> read(java.nio.ByteBuffer dst)

Reads a sequence of bytes from this stream into the given buffer.

Parameters:

dst - the destination buffer

Returns:

a publisher with a single element, the total number of bytes read into the buffer, or -1 if there is no more data because the end of the stream has been reached.

close

org.reactivestreams.Publisher<Success> close()

Closes the input stream

Returns:

a publisher with a single element indicating when the stream has been closed