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