public class TimeoutStream extends Object implements ReadStream<Long>
io.vertx.rxjava.core.Handler will be call when the timer is fired,
it can be once or several times depending on the nature of the timer related to this stream. The
will be called after the timer handler has been called.
Pausing the timer inhibits the timer shots until the stream is resumed. Setting a null handler callback cancels the timer.
NOTE: This class has been automatically generated from theoriginal non RX-ified interface using Vert.x codegen.| Constructor and Description |
|---|
TimeoutStream(TimeoutStream delegate) |
| Modifier and Type | Method and Description |
|---|---|
void |
cancel()
Cancels the timeout.
|
TimeoutStream |
endHandler(Handler<Void> endHandler)
Set an end handler.
|
TimeoutStream |
exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
Object |
getDelegate() |
TimeoutStream |
handler(Handler<Long> handler)
Set a data handler.
|
static TimeoutStream |
newInstance(TimeoutStream arg) |
TimeoutStream |
pause()
Pause the
ReadSupport. |
TimeoutStream |
resume()
Resume reading.
|
rx.Observable<Long> |
toObservable() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitnewInstancenewInstancepublic TimeoutStream(TimeoutStream delegate)
public Object getDelegate()
getDelegate in interface ReadStream<Long>getDelegate in interface StreamBasepublic rx.Observable<Long> toObservable()
toObservable in interface ReadStream<Long>public TimeoutStream exceptionHandler(Handler<Throwable> handler)
ReadStreamexceptionHandler in interface ReadStream<Long>exceptionHandler in interface StreamBasehandler - the exception handlerpublic TimeoutStream handler(Handler<Long> handler)
ReadStreamhandler in interface ReadStream<Long>public TimeoutStream pause()
ReadStreamReadSupport. While it's paused, no data will be sent to the dataHandlerpause in interface ReadStream<Long>public TimeoutStream resume()
ReadStreamReadSupport has been paused, reading will recommence on it.resume in interface ReadStream<Long>public TimeoutStream endHandler(Handler<Void> endHandler)
ReadStreamendHandler in interface ReadStream<Long>public void cancel()
handler(io.vertx.core.Handler<java.lang.Long>) with a null
argument.public static TimeoutStream newInstance(TimeoutStream arg)
Copyright © 2015. All rights reserved.