vertx / io.vertx.rx.java / RxHelper / observableHandler

observableHandler

open static fun <T : Any> observableHandler(): ObservableHandler<T>

Create a new ObservableHandler<T> object: an rx.Observable implementation implementing Handler<T>. When the event handler completes, the observable will produce the event and complete immediatly after.

Return
the observable future.

open static fun <T : Any> observableHandler(multi: Boolean): ObservableHandler<T>

Create a new ObservableHandler<T> object: an rx.Observable implementation implementing Handler<T>. When parameter is false and the event handler completes, the observable will produce the event and complete immediatly after, as a single event is expected.

Parameters

multi - true if the handler can emit multiple events

Return
the observable future.