public class SearchReadStream
extends java.lang.Object
implements io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>| Constructor and Description |
|---|
SearchReadStream(io.vertx.core.http.HttpClientResponse delegate)Create a new read stream |
| Modifier and Type | Method and Description |
|---|---|
SearchReadStream | endHandler(io.vertx.core.Handler<java.lang.Void> endHandler) |
SearchReadStream | endHandlerWithResult(io.vertx.core.Handler<SearchReadStreamResult> endHandler)Set an end handler. |
SearchReadStream | exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler) |
io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> | fetch(long amount) |
SearchReadStreamResult | getResult()Get a result object that contains information only available after the stream has ended. |
SearchReadStream | handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler) |
SearchReadStream | pause() |
SearchReadStream | resume() |
public SearchReadStream(io.vertx.core.http.HttpClientResponse delegate)
delegate - the actual read stream to delegate topublic SearchReadStream exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
exceptionHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>exceptionHandler in interface io.vertx.core.streams.StreamBasepublic SearchReadStream handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)
handler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>public SearchReadStream pause()
pause in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>public SearchReadStream resume()
resume in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>public io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> fetch(long amount)
fetch in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>public SearchReadStream endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)
endHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>public SearchReadStream endHandlerWithResult(io.vertx.core.Handler<SearchReadStreamResult> endHandler)
endHandler - the handler to callpublic SearchReadStreamResult getResult()
null until the end of the stream has been reached.