public interface GridFSInputStream extends com.mongodb.async.client.gridfs.AsyncInputStream, WriteStream<Buffer>
GridFSInputStream which bridges the gap between vertx's WriteStream
and mongodb's AsyncInputStream.
Adapted from com.github.sth.vertx.mongo.streams.GridFSInputStream
| Modifier and Type | Method and Description |
|---|---|
static GridFSInputStream |
create()
Create a
GridFSInputStream. |
static GridFSInputStream |
create(int queueSize)
Create a
GridFSInputStream. |
void |
end(Handler<AsyncResult<Void>> handler)
Signals that all data has been consumed.
|
GridFSInputStream |
setWriteQueueMaxSize(int size)
Sets the maximum internal buffer size.
|
drainHandler, end, end, end, exceptionHandler, write, write, writeQueueFullvoid end(Handler<AsyncResult<Void>> handler)
end in interface WriteStream<Buffer>GridFSInputStream setWriteQueueMaxSize(int size)
setWriteQueueMaxSize in interface WriteStream<Buffer>size - the size in bytes.GridFSInputStreamstatic GridFSInputStream create()
GridFSInputStream.static GridFSInputStream create(int queueSize)
GridFSInputStream.queueSize - the initial queue sizeCopyright © 2019 Eclipse. All rights reserved.