public interface ReactiveReadStream<T> extends ReadStream<T>, org.reactivestreams.Subscriber<T>
| Modifier and Type | Field and Description |
|---|---|
static long |
DEFAULT_BATCH_SIZE
Default batch size
|
| Modifier and Type | Method and Description |
|---|---|
ReactiveReadStream<T> |
endHandler(Handler<Void> endHandler)
Set an end handler.
|
ReactiveReadStream<T> |
exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
ReactiveReadStream<T> |
handler(Handler<T> handler)
Set a data handler.
|
ReactiveReadStream<T> |
pause()
Pause the
ReadStream, it sets the buffer in fetch mode and clears the actual demand. |
static <T> ReactiveReadStream<T> |
readStream()
Create a reactive read stream
|
static <T> ReactiveReadStream<T> |
readStream(long batchSize)
Create a reactive read stream specifying batch size
|
ReactiveReadStream<T> |
resume()
Resume reading, and sets the buffer in
flowing mode. |
fetch, pipe, pipeTo, pipeTostatic final long DEFAULT_BATCH_SIZE
static <T> ReactiveReadStream<T> readStream()
static <T> ReactiveReadStream<T> readStream(long batchSize)
batchSize - the batch sizeReactiveReadStream<T> exceptionHandler(Handler<Throwable> handler)
ReadStreamexceptionHandler in interface ReadStream<T>exceptionHandler in interface StreamBasehandler - the exception handlerReactiveReadStream<T> handler(Handler<T> handler)
ReadStreamhandler in interface ReadStream<T>ReactiveReadStream<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>ReactiveReadStream<T> resume()
ReadStreamflowing mode.
If the ReadStream has been paused, reading will recommence on it.resume in interface ReadStream<T>ReactiveReadStream<T> endHandler(Handler<Void> endHandler)
ReadStreamendHandler in interface ReadStream<T>Copyright © 2023 Eclipse. All rights reserved.