public interface RowStream<T> extends ReadStream<T>
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close the stream and release the resources.
|
void |
close(Handler<AsyncResult<Void>> completionHandler)
Close the stream and release the resources.
|
RowStream<T> |
endHandler(Handler<Void> endHandler)
Set an end handler.
|
RowStream<T> |
exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
RowStream<T> |
handler(Handler<T> handler)
Set a data handler.
|
RowStream<T> |
pause()
Pause the
ReadStream, it sets the buffer in fetch mode and clears the actual demand. |
RowStream<T> |
resume()
Resume reading, and sets the buffer in
flowing mode. |
fetch, pipe, pipeTo, pipeToRowStream<T> exceptionHandler(Handler<Throwable> handler)
ReadStreamexceptionHandler in interface ReadStream<T>exceptionHandler in interface StreamBasehandler - the exception handlerRowStream<T> handler(Handler<T> handler)
ReadStreamhandler in interface ReadStream<T>RowStream<T> pause()
ReadStreamReadStream, it sets the buffer in fetch mode and clears the actual demand.
While it's paused, no data will be sent to the data handler.
pause in interface ReadStream<T>RowStream<T> resume()
ReadStreamflowing mode.
If the ReadStream has been paused, reading will recommence on it.resume in interface ReadStream<T>RowStream<T> endHandler(Handler<Void> endHandler)
ReadStreamendHandler in interface ReadStream<T>void close()
void close(Handler<AsyncResult<Void>> completionHandler)
completionHandler - the completion handler for this operationCopyright © 2023 Eclipse. All rights reserved.