open class HandlerAdapter<T : Any> : ObservableOnSubscribeAdapter<T>, Handler<AsyncResult<T>> |
|
open class ReadStreamSubscriber<R : Any, J : Any> : Subscriber<R>, ReadStream<J>
An RxJava The stream implements the When the subscriber is created it requests The |
|
open class RxHelper
A set of helpers for RxJava and Vert.x. |
|
open class SingleOnSubscribeAdapter<T : Any> : OnSubscribe<T> |
|
abstract class UnmarshallerOperator<T : Any, B : Any> : Operator<T, B>
An operator |