Vertx
object, actions can be blocking, they are not executed
on Vertx event loop.Vertx
object, actions can be blocking, they are not executed
on Vertx event loop.WorkerExecutor
object, actions are executed on the threads of this executor.Observable
that was subscribed to terminates successfully.Flowable
that was subscribed to terminates successfully.Observable
that was subscribed to terminates with an error.Flowable
that was subscribed to terminates with an error.WriteStream
fails.WriteStream
fails.Vertx
object, actions are executed on the event loop.Context
, actions are executed on the event loop of this context.Completable
that, when subscribed, uses the provided handler
to adapt a callback-based asynchronous method.FlowableHelper.toFlowable(ReadStream)
but with a mapping
functionReadStream
to an RxJava Flowable
.ReadStream
to an RxJava Flowable
.Maybe
that, when subscribed, uses the provided handler
to adapt a callback-based asynchronous method.
to an RxJava
.ObservableHelper.toObservable(ReadStream)
but with a mapping
functionHandler<AsyncResult<T>>
to an RxJava2 SingleObserver
.Handler<AsyncResult<T>>
to an RxJava2 MaybeObserver
.WriteStream
to an RxJava Observer
.RxHelper.toObserver(WriteStream)
, except the provided mapping
function is applied to each Observable
item.Handler<AsyncResult<T>>
to an RxJava2 SingleObserver
.Flowable
to a Vert.x io.vertx.core.streams.ReadStream
.Observable
to a Vert.x io.vertx.core.streams.ReadStream
.Single
that, when subscribed, uses the provided handler
to adapt a callback-based asynchronous method.WriteStream
to an RxJava Subscriber
.RxHelper.toSubscriber(WriteStream)
, except the provided mapping
function is applied to each Flowable
item.WriteStream
to Observer
adapter.WriteStream
to Subscriber
adapter.Copyright © 2020 Eclipse. All rights reserved.