com.mongodb.rx.client.gridfs

Interface AsyncOutputStream

All Known Subinterfaces:

GridFSUploadStream

public interface AsyncOutputStream

The Async Output Stream interface represents some asynchronous output stream of bytes.

See the com.mongodb.async.client.gridfs.helpers package for adapters that create an AsyncOutputStream

Since:

1.3

Method Summary

Modifier and Type	Method and Description
rx.Observable<Success>	close() Closes the output stream
rx.Observable<Integer>	write(ByteBuffer src) Writes a sequence of bytes from the given buffer into this stream.

Method Detail

write

rx.Observable<Integer> write(ByteBuffer src)

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

Parameters:

src - the source buffer containing the data to be written.

Returns:

an observable with a single element, the number of bytes written.

close

rx.Observable<Success> close()

Closes the output stream

Returns:

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