com.mongodb.rx.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 com.mongodb.async.client.gridfs.helpers package for adapters that create an AsyncInputStream

Since:

1.3

Method Summary

Modifier and Type	Method and Description
rx.Observable<Success>	close() Closes the input stream
rx.Observable<Integer>	read(ByteBuffer dst) Reads a sequence of bytes from this stream into the given buffer.

Method Detail

read

rx.Observable<Integer> read(ByteBuffer dst)

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

Parameters:

dst - the destination buffer

Returns:

an observable 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

rx.Observable<Success> close()

Closes the input stream

Returns:

an observable with a single element indicating when the stream has been closed