com.mongodb.reactivestreams.client.gridfs

Interface AsyncInputStream

All Known Subinterfaces:

GridFSDownloadStream

Deprecated.

replaced by the more idiomatic Publisher<ByteBuffer> instead

@Deprecated
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
org.reactivestreams.Publisher<Success>	close() Deprecated. Closes the input stream
org.reactivestreams.Publisher<Integer>	read(ByteBuffer dst) Deprecated. Reads a sequence of bytes from this stream into the given buffer.
org.reactivestreams.Publisher<Long>	skip(long bytesToSkip) Deprecated. Skips over and discards n bytes of data from this input stream.

Method Detail

read

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

Deprecated.

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.

skip

org.reactivestreams.Publisher<Long> skip(long bytesToSkip)

Deprecated.

Skips over and discards n bytes of data from this input stream.

Parameters:

bytesToSkip - the number of bytes to skip

Returns:

a publisher with a single element, the actual number of bytes skipped

Since:

1.11

close

org.reactivestreams.Publisher<Success> close()

Deprecated.

Closes the input stream

Returns:

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