open class ObservableHelper
Author
Julien Viet
ObservableHelper() |
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 |
|
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 <. |
|
open static fun <T : Any> unmarshaller(mappedType: Class<T>): ObservableTransformer<Buffer, T>open static fun <T : Any> unmarshaller(mappedTypeRef: TypeReference<T>): ObservableTransformer<Buffer, T>open static fun <T : Any> unmarshaller(mappedType: Class<T>, mapper: ObjectMapper): ObservableTransformer<Buffer, T>open static fun <T : Any> unmarshaller(mappedTypeRef: TypeReference<T>, mapper: ObjectMapper): ObservableTransformer<Buffer, T> |