Package | Description |
---|---|
io.vertx.ext.reactivestreams |
Modifier and Type | Method and Description |
---|---|
ReactiveReadStream<T> |
ReactiveReadStream.endHandler(Handler<Void> endHandler) |
ReactiveReadStream<T> |
ReactiveReadStream.exceptionHandler(Handler<Throwable> handler) |
ReactiveReadStream<T> |
ReactiveReadStream.handler(Handler<T> handler) |
ReactiveReadStream<T> |
ReactiveReadStream.pause() |
static <T> ReactiveReadStream<T> |
ReactiveReadStream.readStream()
Create a reactive read stream
|
static <T> ReactiveReadStream<T> |
ReactiveReadStream.readStream(long batchSize)
Create a reactive read stream specifying batch size
|
ReactiveReadStream<T> |
ReactiveReadStream.resume() |
Copyright © 2021 Eclipse. All rights reserved.