vertx / io.vertx.reactivex / ObservableHelper

ObservableHelper

open class ObservableHelper

Author
Julien Viet

Constructors

<init>

ObservableHelper()

Functions

toObservable

open static fun <T : Any> toObservable(stream: ReadStream<T>): Observable<T>

Adapts a Vert.x ReadStream to an RxJava Observable. After the stream is adapted to an observable, the original stream handlers should not be used anymore as they will be used by the observable adapter.

open static fun <T : Any, U : Any> toObservable(stream: ReadStream<T>, mapping: Function<T, U>): Observable<U>

Like #toObservable(ReadStream) but with a mapping function

toReadStream

open static fun <T : Any> toReadStream(observable: Observable<T>): ReadStream<T>

Adapts an RxJava < to a Vert.x <. The returned readstream will be subscribed to the <.

unmarshaller

open static fun <T : Any> unmarshaller(mappedType: Class<T>): ObservableTransformer<Buffer, T>
open static fun <T : Any> unmarshaller(mappedTypeRef: TypeReference<T>): ObservableTransformer<Buffer, T>