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, pipeTo
static 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)
ReadStream
exceptionHandler
in interface ReadStream<T>
exceptionHandler
in interface StreamBase
handler
- the exception handlerReactiveReadStream<T> handler(Handler<T> handler)
ReadStream
handler
in interface ReadStream<T>
ReactiveReadStream<T> pause()
ReadStream
ReadStream
, 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()
ReadStream
flowing
mode.
If the ReadStream
has been paused, reading will recommence on it.resume
in interface ReadStream<T>
ReactiveReadStream<T> endHandler(Handler<Void> endHandler)
ReadStream
endHandler
in interface ReadStream<T>
Copyright © 2022 Eclipse. All rights reserved.