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.ObservableFuture<T>
object: an Observable
implementation
implementing Handler<AsyncResult<T>>
.ObservableHandler<T>
object: an Observable
implementation
implementing Handler<T>
.ObservableHandler<T>
object: an 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.ReadStream
to be an Observable.OnSubscribe
that can be used to
build Observable
.Observable
that was subscribed to terminates successfully.Observable
that was subscribed to terminates with an error.WriteStream
fails.Subscriber
that turns an Observable
into a ReadStream
.Vertx
object, actions are executed on the event loop.Context
, actions are executed on the event loop of this context.Context
object, the RxJavaSchedulersHook.getIOScheduler()
uses a blocking scheduler.Vertx
object, the RxJavaSchedulersHook.getIOScheduler()
uses a blocking scheduler.Subscriber
as a Handler<AsyncResult<T>>;
.Handler<AsyncResult<T>>
.Handler<AsyncResult<T>>
.Handler<AsyncResult<T>>
.Subscriber
as a Handler<T>;
.
When the event handler completes, the observer
will complete immediatly after the event is received, as a single event is expected.Subscriber
as a Handler<T>;
.
When parameter is false and the event handler completes, the observer
will complete immediatly after the event is received, as a single event is expected.Handler<T>
.io.vertx.core.streams.ReadStream
to an RxJava Observable
.io.vertx.core.streams.ReadStream
to an RxJava Observable
.RxHelper.toObservable(ReadStream)
but with a function that adapts the items.RxHelper.toObservable(ReadStream, int)
but with a function that adapts the items.Observable
to a Vert.x io.vertx.core.streams.ReadStream
.Handler<AsyncResult<T>>
to an RxJava Subscriber
.WriteStream
to an RxJava Subscriber
.RxHelper.toSubscriber(WriteStream)
, except the provided mapping
function is applied to each Observable
item.Observable.Operator
instance given the
the provided ObjectMapper
The marshaller can be used with the Observable.lift(rx.Observable.Operator)
method to transform
a Observable<Buffer> into a Observable<T>.
The unmarshaller buffers the content until onComplete is called, then unmarshalling happens.
Note that the returned observable will emit at most a single object.Observable.Operator
instance.
The marshaller can be used with the Observable.lift(rx.Observable.Operator)
method to transform
a Observable<Buffer> into a Observable<T>.
The unmarshaller buffers the content until onComplete is called, then unmarshalling happens.
Note that the returned observable will emit at most a single object.Observable.Operator
instance.
The marshaller can be used with the Observable.lift(rx.Observable.Operator)
method to transform
a Observable<Buffer> into a Observable<T>.
The unmarshaller buffers the content until onComplete is called, then unmarshalling happens.
Note that the returned observable will emit at most a single object.Observable.Operator
instance given the
the provided ObjectMapper
The marshaller can be used with the Observable.lift(rx.Observable.Operator)
method to transform
a Observable<Buffer> into a Observable<T>.
The unmarshaller buffers the content until onComplete is called, then unmarshalling happens.
Note that the returned observable will emit at most a single object.WriteStream
to Subscriber
adapter.Copyright © 2020 Eclipse. All rights reserved.