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
.handler
may be called while there are outstanding writes in the underlying WriteStream
.
Use onWriteStreamEnd(Action0)
instead.Observable
that was subscribed to terminates with an error.WriteStream
ends successfully.WriteStream
ends 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 © 2021 Eclipse. All rights reserved.