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.StreamBase
public 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.