public interface ReadStream<T> extends StreamBase
Any class that implements this interface can be used by a Pump
to pump data from it
to a WriteStream
.
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Method and Description |
---|---|
ReadStream<T> |
endHandler(Handler<Void> endHandler)
Set an end handler.
|
ReadStream<T> |
exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
Object |
getDelegate() |
ReadStream<T> |
handler(Handler<T> handler)
Set a data handler.
|
static <T> ReadStream<T> |
newInstance(ReadStream arg) |
ReadStream<T> |
pause()
Pause the
ReadSupport . |
ReadStream<T> |
resume()
Resume reading.
|
rx.Observable<T> |
toObservable() |
newInstance
Object getDelegate()
getDelegate
in interface StreamBase
ReadStream<T> exceptionHandler(Handler<Throwable> handler)
exceptionHandler
in interface StreamBase
handler
- the exception handlerReadStream<T> handler(Handler<T> handler)
handler
- ReadStream<T> pause()
ReadSupport
. While it's paused, no data will be sent to the dataHandler
ReadStream<T> resume()
ReadSupport
has been paused, reading will recommence on it.ReadStream<T> endHandler(Handler<Void> endHandler)
endHandler
- rx.Observable<T> toObservable()
static <T> ReadStream<T> newInstance(ReadStream arg)
Copyright © 2015. All Rights Reserved.