Dependencies
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- com.fasterxml.jackson.core/jackson-annotations/2.9.0
- com.fasterxml.jackson.core/jackson-core/2.9.9
- com.fasterxml.jackson.core/jackson-databind/2.9.9.1
- com.github.jponge/lzma-java/1.3
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.jcraft/jzlib/1.1.3
- commons-logging/commons-logging/1.2
- com.ning/compress-lzf/1.0.3
- com.sun/tools/1.8
- io.netty/netty-buffer/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.reactivex/rxjava/1.3.8 (available as io.reactivex.rxjava2/rxjava/2.2.11)
- io.vertx/vertx-codegen/3.8.0
- io.vertx/vertx-core/3.8.0
- io.vertx/vertx-docgen/0.9.2
- io.vertx/vertx-rx-gen/3.8.0
- java/11
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- net.jpountz.lz4/lz4/1.3.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.bouncycastle/bcpkix-jdk15on/1.54
- org.bouncycastle/bcprov-jdk15on/1.54
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.mvel/mvel2/2.3.1.Final
- org.slf4j/slf4j-api/1.7.21
Declarations
-
io
-
vertx
-
lang
-
rxjava
- Helper
-
RxJavaGenerator
- RxJavaGenerator(): void
- genRxImports(ClassModel, PrintWriter): void
- genToObservable(TypeInfo, PrintWriter): void
- genToSubscriber(TypeInfo, PrintWriter): void
- genMethods(ClassModel, MethodInfo, List<String>, PrintWriter): void
- genRxMethod(ClassModel, MethodInfo, PrintWriter): void
- genFutureMethod(MethodInfo): MethodInfo
- genOverloadedMethod(MethodInfo): MethodInfo
- genReadStream(List<TypeParamInfo>, PrintWriter): void
- RxJavaGeneratorLoader
-
rxjava
-
rx
-
java
-
ContextScheduler
- schedulersHook: RxJavaSchedulersHook
- vertx: Vertx
- context: Context
- workerExecutor: WorkerExecutor
- blocking: boolean
- ordered: boolean
- ContextScheduler(Vertx, boolean, boolean): void
- ContextScheduler(Context, boolean): void
- ContextScheduler(Context, boolean, boolean): void
- ContextScheduler(Vertx, boolean): void
- ContextScheduler(WorkerExecutor): void
- ContextScheduler(WorkerExecutor, boolean): void
- createWorker(): ContextWorker
- DUMB: Object
- ContextWorker
- HandlerAdapter
- ObservableFuture
- ObservableHandler
- ObservableOnSubscribeAdapter
-
ObservableReadStream
- COMPLETED_SENTINEL: Throwable
- DEFAULT_MAX_BUFFER_SIZE: long
- stream: ReadStream<Object>
- adapter: Function<Object, Object>
- subscription: AtomicReference<Sub>
- subscribed: boolean
- ObservableReadStream(ReadStream<Object>, Function<Object, Object>): void
- ObservableReadStream(ReadStream<Object>, Function<Object, Object>, long): void
- getRequested(): long
- Sub
- call(Subscriber<Object>): void
- Adapter
- QueueAdapter
-
ReadStreamSubscriber
- NOOP_ACTION: Runnable
- DONE_SENTINEL: Throwable
- BUFFER_SIZE: int
- asReadStream(Observable<Object>, Function<Object, Object>): ReadStream<Object>
- adapter: Function<Object, Object>
- endHandler: Handler<Void>
- exceptionHandler: Handler<Throwable>
- elementHandler: Handler<Object>
- paused: boolean
- completed: Throwable
- pending: ArrayDeque<Object>
- requested: int
- ReadStreamSubscriber(Function<Object, Object>): void
- handler(Handler<Object>): ReadStream<Object>
- fetch(long): ReadStream<Object>
- pause(): ReadStream<Object>
- resume(): ReadStream<Object>
- checkStatus(): void
- endHandler(Handler<Void>): ReadStream<Object>
- exceptionHandler(Handler<Throwable>): ReadStream<Object>
- onCompleted(): void
- onError(Throwable): void
- onNext(Object): void
-
RxHelper
- toSubscriber(Handler<AsyncResult<Object>>): Subscriber<Object>
- toReadStream(Observable<Object>): ReadStream<Object>
- toObservable(ReadStream<Object>): Observable<Object>
- toObservable(ReadStream<Object>, int): Observable<Object>
- toObservable(ReadStream<Object>, Function<Object, Object>): Observable<Object>
- toObservable(ReadStream<Object>, Function<Object, Object>, int): Observable<Object>
- observableFuture(): ObservableFuture<Object>
- observableHandler(): ObservableHandler<Object>
- observableHandler(boolean): ObservableHandler<Object>
- toFuture(Observer<Object>): Handler<AsyncResult<Object>>
- toHandler(Observer<Object>): Handler<Object>
- toHandler(Observer<Object>, boolean): Handler<Object>
- toFuture(Action1<Object>): Handler<AsyncResult<Object>>
- toHandler(Action1<Object>): Handler<Object>
- toFuture(Action1<Object>, Action1<Throwable>): Handler<AsyncResult<Object>>
- toFuture(Action1<Object>, Action1<Throwable>, Action0): Handler<AsyncResult<Object>>
- scheduler(Vertx): Scheduler
- scheduler(Context): Scheduler
- blockingScheduler(Vertx): Scheduler
- blockingScheduler(Vertx, boolean): Scheduler
- schedulerHook(Context): RxJavaSchedulersHook
- schedulerHook(Vertx): RxJavaSchedulersHook
- unmarshaller(Class<Object>, ObjectMapper): Operator<Object, Buffer>
- unmarshaller(Class<Object>): Operator<Object, Buffer>
- unmarshaller(TypeReference<Object>): Operator<Object, Buffer>
- unmarshaller(TypeReference<Object>, ObjectMapper): Operator<Object, Buffer>
- setNullHandlers(ReadStream<Object>): void
- toSubscriber(WriteStream<Object>): WriteStreamSubscriber<Object>
- toSubscriber(WriteStream<Object>, Function<Object, Object>): WriteStreamSubscriber<Object>
- SingleOnSubscribeAdapter
-
UnmarshallerOperator
- mappedType: Class<Object>
- mappedTypeRef: TypeReference<Object>
- mapper: ObjectMapper
- UnmarshallerOperator(Class<Object>): void
- UnmarshallerOperator(Class<Object>, ObjectMapper): void
- UnmarshallerOperator(TypeReference<Object>): void
- UnmarshallerOperator(TypeReference<Object>, ObjectMapper): void
- unwrap(Object): Buffer
- call(Subscriber<Object>): Subscriber<Object>
- WriteStreamSubscriber
-
impl
-
WriteStreamSubscriberImpl
- BATCH_SIZE: int
- writeStream: WriteStream<Object>
- mapping: Function<Object, Object>
- outstanding: int
- observableErrorHandler: Action1<Throwable>
- observableCompleteHandler: Action0
- writeStreamExceptionHandler: Action1<Throwable>
- WriteStreamSubscriberImpl(WriteStream<Object>, Function<Object, Object>): void
- onStart(): void
- onNext(Object): void
- onError(Throwable): void
- onCompleted(): void
- requestMore(): void
- onError(Action1<Throwable>): WriteStreamSubscriber<Object>
- onComplete(Action0): WriteStreamSubscriber<Object>
- onWriteStreamError(Action1<Throwable>): WriteStreamSubscriber<Object>
-
WriteStreamSubscriberImpl
-
ContextScheduler
-
java
-
lang
-
vertx