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/rxjava/1.3.8 (available as io.reactivex.rxjava2/rxjava/2.2.11)
- 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.slf4j/slf4j-api/1.7.21
Declarations
-
io
-
vertx
-
lang
-
rxjava
-
Helper
-
RxJavaGenerator
-
RxJavaGenerator(): void
-
isImported(TypeInfo): boolean
-
genImports(ClassModel, PrintWriter): void
-
genToObservable(TypeInfo, PrintWriter): void
-
genToSubscriber(TypeInfo, PrintWriter): void
-
genMethods(ClassModel, MethodInfo, List<String>, boolean, PrintWriter): void
-
unwrap(TypeInfo): TypeInfo
-
foo(MethodInfo, MethodInfo): boolean
-
genRxMethod(ClassModel, MethodInfo, List<String>, boolean, PrintWriter): void
-
genFutureMethod(MethodInfo): MethodInfo
-
genOverloadedMethod(MethodInfo): MethodInfo
-
genReadStream(List<TypeParamInfo>, PrintWriter): void
-
genConvParam(TypeInfo, MethodInfo, String): String
-
-
RxJavaGeneratorLoader
-
-
rxjava
-
rx
-
java
-
ContextScheduler
-
schedulersHook: RxJavaSchedulersHook
-
vertx: Vertx
-
context: Context
-
workerExecutor: WorkerExecutor
-
blocking: boolean
-
ordered: boolean
-
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
-
-
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>, ObjectCodec): Operator<Object, Buffer>
-
unmarshaller(Class<Object>): Operator<Object, Buffer>
-
unmarshaller(TypeReference<Object>): Operator<Object, Buffer>
-
unmarshaller(TypeReference<Object>, ObjectCodec): 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: ObjectCodec
-
UnmarshallerOperator(Class<Object>): void
-
UnmarshallerOperator(Class<Object>, ObjectCodec): void
-
UnmarshallerOperator(TypeReference<Object>): void
-
UnmarshallerOperator(TypeReference<Object>, ObjectCodec): 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>
-
writeStreamExceptionHandler: Action1<Throwable>
-
writeStreamEndHandler: Action0
-
writeStreamEndErrorHandler: Action1<Throwable>
-
WriteStreamSubscriberImpl(WriteStream<Object>, Function<Object, Object>): void
-
onStart(): void
-
onNext(Object): void
-
onError(Throwable): void
-
onCompleted(): void
-
writeStreamEnd(AsyncResult<Void>): void
-
requestMore(): void
-
onError(Action1<Throwable>): WriteStreamSubscriber<Object>
-
onWriteStreamError(Action1<Throwable>): WriteStreamSubscriber<Object>
-
onWriteStreamEnd(Action0): WriteStreamSubscriber<Object>
-
onWriteStreamEndError(Action1<Throwable>): WriteStreamSubscriber<Object>
-
-
-
-
java
-
lang
-
vertx