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.11.3
- com.fasterxml.jackson.core/jackson-core/2.11.3
- com.fasterxml.jackson.core/jackson-databind/2.11.3
- 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.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-haproxy/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-tcnative/2.0.30.Final
- io.netty/netty-transport/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.projectreactor.tools/blockhound/1.0.3.RELEASE
- io.reactivex.rxjava2/rxjava/2.2.12
- io.vertx/vertx-codegen/4.0.0
- io.vertx/vertx-core/4.0.0
- io.vertx/vertx-docgen/0.9.2
- io.vertx/vertx-rx-gen/4.0.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.65
- org.bouncycastle/bcprov-jdk15on/1.65
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.reactivestreams/reactive-streams/1.0.3
- org.slf4j/slf4j-api/1.7.21
Declarations
-
io
-
vertx
-
lang
-
reactivex
- Helper
-
RxJava2Generator
- RxJava2Generator(): void
- genImports(ClassModel, PrintWriter): void
- genToObservable(TypeInfo, PrintWriter): void
- genToXXXAble(TypeInfo, String, String, PrintWriter): void
- genToSubscriber(TypeInfo, PrintWriter): void
- genToXXXEr(TypeInfo, String, String, PrintWriter): void
- genMethods(ClassModel, MethodInfo, List<String>, boolean, PrintWriter): void
- genRxMethod(ClassModel, MethodInfo, List<String>, boolean, PrintWriter): void
- genReadStream(List<TypeParamInfo>, PrintWriter): void
- genTypeName(TypeInfo, boolean): String
- genConvParam(TypeInfo, MethodInfo, String): String
- genFutureMethod(MethodInfo): MethodInfo
- genOverloadedMethod(MethodInfo): MethodInfo
- genOverloadedType(TypeInfo): TypeInfo
- RxJava2GeneratorLoader
-
reactivex
-
reactivex
- CompletableHelper
-
ContextScheduler
- vertx: Vertx
- blocking: boolean
- ordered: boolean
- context: Context
- workerExecutor: WorkerExecutor
- ContextScheduler(Context, boolean): void
- ContextScheduler(Context, boolean, boolean): void
- ContextScheduler(Vertx, boolean): void
- ContextScheduler(Vertx, boolean, boolean): void
- ContextScheduler(WorkerExecutor): void
- ContextScheduler(WorkerExecutor, boolean): void
- createWorker(): ContextWorker
- DUMB: Object
-
ContextWorker
- actions: ConcurrentHashMap<TimedAction, Object>
- cancelled: AtomicBoolean
- countActions(): int
- schedule(Runnable): Disposable
- schedule(Runnable, long, TimeUnit): Disposable
- schedulePeriodically(Runnable, long, long, TimeUnit): Disposable
- dispose(): void
- isDisposed(): boolean
- TimedAction
-
FlowableHelper
- toReadStream(Flowable<Object>): ReadStream<Object>
- toFlowable(ReadStream<Object>, Function<Object, Object>): Flowable<Object>
- toFlowable(ReadStream<Object>): Flowable<Object>
- toFlowable(ReadStream<Object>, long): Flowable<Object>
- unmarshaller(Class<Object>): FlowableTransformer<Buffer, Object>
- unmarshaller(TypeReference<Object>): FlowableTransformer<Buffer, Object>
- unmarshaller(Class<Object>, ObjectCodec): FlowableTransformer<Buffer, Object>
- unmarshaller(TypeReference<Object>, ObjectCodec): FlowableTransformer<Buffer, Object>
-
MaybeHelper
- toMaybe(Consumer<Handler<AsyncResult<Object>>>): Maybe<Object>
- toObserver(Handler<AsyncResult<Object>>): MaybeObserver<Object>
- toFuture(Maybe<Object>): Future<Object>
- toFuture(Maybe<Object>, Function<Object, Object>): Future<Object>
- unmarshaller(Class<Object>): MaybeTransformer<Buffer, Object>
- unmarshaller(TypeReference<Object>): MaybeTransformer<Buffer, Object>
- unmarshaller(Class<Object>, ObjectCodec): MaybeTransformer<Buffer, Object>
- unmarshaller(TypeReference<Object>, ObjectCodec): MaybeTransformer<Buffer, Object>
-
ObservableHelper
- toReadStream(Observable<Object>): ReadStream<Object>
- toObservable(ReadStream<Object>): Observable<Object>
- toObservable(ReadStream<Object>, Function<Object, Object>): Observable<Object>
- unmarshaller(Class<Object>): ObservableTransformer<Buffer, Object>
- unmarshaller(TypeReference<Object>): ObservableTransformer<Buffer, Object>
- unmarshaller(Class<Object>, ObjectCodec): ObservableTransformer<Buffer, Object>
- unmarshaller(TypeReference<Object>, ObjectCodec): ObservableTransformer<Buffer, Object>
-
RxHelper
- scheduler(Vertx): Scheduler
- scheduler(Context): Scheduler
- blockingScheduler(Vertx): Scheduler
- blockingScheduler(Vertx, boolean): Scheduler
- blockingScheduler(WorkerExecutor): Scheduler
- toSubscriber(WriteStream<Object>): WriteStreamSubscriber<Object>
- toSubscriber(WriteStream<Object>, Function<Object, Object>): WriteStreamSubscriber<Object>
- toObserver(WriteStream<Object>): WriteStreamObserver<Object>
- toObserver(WriteStream<Object>, Function<Object, Object>): WriteStreamObserver<Object>
-
SingleHelper
- toSingle(Consumer<Handler<AsyncResult<Object>>>): Single<Object>
- toObserver(Handler<AsyncResult<Object>>): SingleObserver<Object>
- toFuture(Single<Object>): Future<Object>
- toFuture(Single<Object>, Function<Object, Object>): Future<Object>
- unmarshaller(Class<Object>): SingleTransformer<Buffer, Object>
- unmarshaller(TypeReference<Object>): SingleTransformer<Buffer, Object>
- unmarshaller(Class<Object>, ObjectCodec): SingleTransformer<Buffer, Object>
- unmarshaller(TypeReference<Object>, ObjectCodec): SingleTransformer<Buffer, Object>
- WriteStreamObserver
- WriteStreamSubscriber
-
impl
- AsyncResultCompletable
- AsyncResultMaybe
- AsyncResultSingle
- FlowableReadStream
-
FlowableUnmarshaller
- unwrap: Function<Object, Buffer>
- mappedType: Class<Object>
- mappedTypeRef: TypeReference<Object>
- mapper: ObjectCodec
- FlowableUnmarshaller(Function<Object, Buffer>, Class<Object>): void
- FlowableUnmarshaller(Function<Object, Buffer>, TypeReference<Object>): void
- FlowableUnmarshaller(Function<Object, Buffer>, Class<Object>, ObjectCodec): void
- FlowableUnmarshaller(Function<Object, Buffer>, TypeReference<Object>, ObjectCodec): void
- FlowableUnmarshaller(Function<Object, Buffer>, Class<Object>, TypeReference<Object>, ObjectCodec): void
- apply(Flowable<Object>): Publisher<Object>
-
MaybeUnmarshaller
- unwrap: Function<Object, Buffer>
- mappedType: Class<Object>
- mappedTypeRef: TypeReference<Object>
- mapper: ObjectCodec
- MaybeUnmarshaller(Function<Object, Buffer>, Class<Object>): void
- MaybeUnmarshaller(Function<Object, Buffer>, TypeReference<Object>): void
- MaybeUnmarshaller(Function<Object, Buffer>, Class<Object>, ObjectCodec): void
- MaybeUnmarshaller(Function<Object, Buffer>, TypeReference<Object>, ObjectCodec): void
- MaybeUnmarshaller(Function<Object, Buffer>, Class<Object>, TypeReference<Object>, ObjectCodec): void
- apply(Maybe<Object>): MaybeSource<Object>
-
ObservableReadStream
- stream: ReadStream<Object>
- f: Function<Object, Object>
- observer: AtomicReference<Observer<Object>>
- ObservableReadStream(ReadStream<Object>, Function<Object, Object>): void
- Subscription
- subscribeActual(Observer<Object>): void
-
ObservableUnmarshaller
- unwrap: Function<Object, Buffer>
- mappedType: Class<Object>
- mappedTypeRef: TypeReference<Object>
- mapper: ObjectCodec
- ObservableUnmarshaller(Function<Object, Buffer>, Class<Object>): void
- ObservableUnmarshaller(Function<Object, Buffer>, TypeReference<Object>): void
- ObservableUnmarshaller(Function<Object, Buffer>, Class<Object>, ObjectCodec): void
- ObservableUnmarshaller(Function<Object, Buffer>, TypeReference<Object>, ObjectCodec): void
- ObservableUnmarshaller(Function<Object, Buffer>, Class<Object>, TypeReference<Object>, ObjectCodec): void
- apply(Observable<Object>): ObservableSource<Object>
- getT(Buffer, Class<Object>, TypeReference<Object>): Object
-
ReadStreamSubscriber
- NOOP_ACTION: Runnable
- DONE_SENTINEL: Throwable
- BUFFER_SIZE: int
- asReadStream(Flowable<Object>, Function<Object, Object>): ReadStream<Object>
- 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
- subscription: Subscription
- ReadStreamSubscriber(Function<Object, Object>): void
- handler(Handler<Object>): ReadStream<Object>
- pause(): ReadStream<Object>
- fetch(long): ReadStream<Object>
- resume(): ReadStream<Object>
- onSubscribe(Subscription): void
- checkStatus(): void
- endHandler(Handler<Void>): ReadStream<Object>
- exceptionHandler(Handler<Throwable>): ReadStream<Object>
- onComplete(): void
- onError(Throwable): void
- onNext(Object): void
-
SingleUnmarshaller
- unwrap: Function<Object, Buffer>
- mappedType: Class<Object>
- mappedTypeRef: TypeReference<Object>
- mapper: ObjectCodec
- SingleUnmarshaller(Function<Object, Buffer>, Class<Object>): void
- SingleUnmarshaller(Function<Object, Buffer>, TypeReference<Object>): void
- SingleUnmarshaller(Function<Object, Buffer>, Class<Object>, ObjectCodec): void
- SingleUnmarshaller(Function<Object, Buffer>, TypeReference<Object>, ObjectCodec): void
- SingleUnmarshaller(Function<Object, Buffer>, Class<Object>, TypeReference<Object>, ObjectCodec): void
- apply(Single<Object>): SingleSource<Object>
-
WriteStreamObserverImpl
- setDone(): boolean
- isDone(): boolean
- writeStream: WriteStream<Object>
- mapping: Function<Object, Object>
- disposable: Disposable
- done: boolean
- observableErrorHandler: Consumer<Object>
- writeStreamExceptionHandler: Consumer<Object>
- writeStreamEndHandler: Action
- writeStreamEndErrorHandler: Consumer<Object>
- WriteStreamObserverImpl(WriteStream<Object>, Function<Object, Object>): void
- onSubscribe(Disposable): void
- onNext(Object): void
- onError(Throwable): void
- onComplete(): void
- writeStreamEnd(AsyncResult<Void>): void
- getDisposable(): Disposable
- setDisposable(Disposable): boolean
- onError(Consumer<Object>): WriteStreamObserver<Object>
- onWriteStreamError(Consumer<Object>): WriteStreamObserver<Object>
- onWriteStreamEnd(Action): WriteStreamObserver<Object>
- onWriteStreamEndError(Consumer<Object>): WriteStreamObserver<Object>
-
WriteStreamSubscriberImpl
- BATCH_SIZE: int
- writeStream: WriteStream<Object>
- mapping: Function<Object, Object>
- subscription: Subscription
- outstanding: int
- done: boolean
- flowableErrorHandler: Consumer<Object>
- writeStreamExceptionHandler: Consumer<Object>
- writeStreamEndHandler: Action
- writeStreamEndErrorHandler: Consumer<Object>
- WriteStreamSubscriberImpl(WriteStream<Object>, Function<Object, Object>): void
- onSubscribe(Subscription): void
- onNext(Object): void
- onError(Throwable): void
- onComplete(): void
- writeStreamEnd(AsyncResult<Void>): void
- getSubscription(): Subscription
- setSubscription(Subscription): boolean
- isDone(): boolean
- setDone(): boolean
- requestMore(): void
- onError(Consumer<Object>): WriteStreamSubscriber<Object>
- onWriteStreamError(Consumer<Object>): WriteStreamSubscriber<Object>
- onWriteStreamEnd(Action): WriteStreamSubscriber<Object>
- onWriteStreamEndError(Consumer<Object>): WriteStreamSubscriber<Object>
-
lang
-
vertx