vertx / io.vertx.rxjava.core / TimeoutStream

TimeoutStream

open class TimeoutStream : ReadStream<Long>

A timeout stream is triggered by a timer, the 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 the io.vertx.core.TimeoutStream non RX-ified interface using Vert.x codegen.

Constructors

<init>

TimeoutStream(delegate: TimeoutStream)

Properties

__TYPE_ARG

static val __TYPE_ARG: TypeArg<TimeoutStream>

Functions

cancel

open fun cancel(): Unit

Cancels the timeout. Note this has the same effect as calling io.vertx.rxjava.core.TimeoutStream#handler with a null argument.

endHandler

open fun endHandler(endHandler: Handler<Void>): TimeoutStream

equals

open fun equals(other: Any?): Boolean

exceptionHandler

open fun exceptionHandler(handler: Handler<Throwable>): TimeoutStream

getDelegate

open fun getDelegate(): TimeoutStream

handler

open fun handler(handler: Handler<Long>): TimeoutStream

hashCode

open fun hashCode(): Int

newInstance

open static fun newInstance(arg: TimeoutStream): TimeoutStream

pause

open fun pause(): TimeoutStream

resume

open fun resume(): TimeoutStream

toObservable

open fun toObservable(): Observable<Long>

toString

open fun toString(): String