Package | Description |
---|---|
io.vertx.reactivex |
= Vert.x RxJava
:toc: left
== Vert.x API for RxJava2
https://github.com/ReactiveX/RxJava[RxJava] is a popular library for composing asynchronous and event based programs using
observable sequences for the Java VM.
|
Modifier and Type | Method and Description |
---|---|
WriteStreamObserver<R> |
WriteStreamObserver.onComplete(io.reactivex.functions.Action handler)
Sets the handler to invoke if the
Observable that was subscribed to terminates successfully. |
WriteStreamObserver<R> |
WriteStreamObserver.onError(io.reactivex.functions.Consumer<? super Throwable> handler)
Sets the handler to invoke if the
Observable that was subscribed to terminates with an error. |
WriteStreamObserver<R> |
WriteStreamObserver.onWriteStreamError(io.reactivex.functions.Consumer<? super Throwable> handler)
Sets the handler to invoke if the adapted
WriteStream fails. |
static <T> WriteStreamObserver<T> |
RxHelper.toObserver(io.vertx.core.streams.WriteStream<T> stream)
Adapts a Vert.x
WriteStream to an RxJava Observer . |
static <R,T> WriteStreamObserver<R> |
RxHelper.toObserver(io.vertx.core.streams.WriteStream<T> stream,
Function<R,T> mapping)
Like
RxHelper.toObserver(WriteStream) , except the provided mapping function is applied to each Observable item. |
Copyright © 2019 Eclipse. All rights reserved.