Hierarchy For All Packages

Package Hierarchies:

• hu.akarnokd.rxjava3.async,
• hu.akarnokd.rxjava3.basetypes,
• hu.akarnokd.rxjava3.consumers,
• hu.akarnokd.rxjava3.debug,
• hu.akarnokd.rxjava3.debug.multihook,
• hu.akarnokd.rxjava3.debug.validator,
• hu.akarnokd.rxjava3.expr,
• hu.akarnokd.rxjava3.functions,
• hu.akarnokd.rxjava3.joins,
• hu.akarnokd.rxjava3.math,
• hu.akarnokd.rxjava3.operators,
• hu.akarnokd.rxjava3.parallel,
• hu.akarnokd.rxjava3.processors,
• hu.akarnokd.rxjava3.schedulers,
• hu.akarnokd.rxjava3.string,
• hu.akarnokd.rxjava3.subjects,
• hu.akarnokd.rxjava3.util

Class Hierarchy

• java.lang.Object
  • hu.akarnokd.rxjava3.async.AsyncFlowable
  • hu.akarnokd.rxjava3.async.AsyncObservable
  • java.util.concurrent.atomic.AtomicReference<V> (implements java.io.Serializable)
    • hu.akarnokd.rxjava3.util.SpscOneQueue<T> (implements io.reactivex.rxjava3.operators.SimplePlainQueue<T>)
  • hu.akarnokd.rxjava3.consumers.CompletableConsumers
  • hu.akarnokd.rxjava3.operators.Completables
  • hu.akarnokd.rxjava3.operators.CompletableTransformers
  • hu.akarnokd.rxjava3.util.CompositeSubscription (implements org.reactivestreams.Subscription)
  • io.reactivex.rxjava3.core.Flowable<T> (implements org.reactivestreams.Publisher<T>)
    • hu.akarnokd.rxjava3.async.DisposableFlowable<T> (implements io.reactivex.rxjava3.disposables.Disposable)
    • io.reactivex.rxjava3.processors.FlowableProcessor<T> (implements io.reactivex.rxjava3.core.FlowableSubscriber<T>, org.reactivestreams.Processor<T,R>)
      • hu.akarnokd.rxjava3.processors.DispatchWorkProcessor<T> (implements io.reactivex.rxjava3.disposables.Disposable)
  • hu.akarnokd.rxjava3.consumers.FlowableConsumers
  • hu.akarnokd.rxjava3.processors.FlowableProcessors
  • hu.akarnokd.rxjava3.operators.Flowables
  • hu.akarnokd.rxjava3.operators.FlowableTransformers
  • hu.akarnokd.rxjava3.functions.FunctionsEx
  • hu.akarnokd.rxjava3.functions.FunctionTagging
  • hu.akarnokd.rxjava3.joins.JoinObservable<T>
  • hu.akarnokd.rxjava3.math.MathFlowable
  • hu.akarnokd.rxjava3.math.MathObservable
  • hu.akarnokd.rxjava3.consumers.MaybeConsumers
  • hu.akarnokd.rxjava3.operators.Maybes
  • hu.akarnokd.rxjava3.operators.MaybeTransformers
  • hu.akarnokd.rxjava3.debug.multihook.MultiHandlerManager<H>
    • hu.akarnokd.rxjava3.debug.multihook.OnScheduleMultiHandlerManager (implements io.reactivex.rxjava3.functions.BiConsumer<T1,T2>, io.reactivex.rxjava3.functions.Function<T,R>)
  • hu.akarnokd.rxjava3.basetypes.Nono (implements org.reactivestreams.Publisher<T>)
    • hu.akarnokd.rxjava3.basetypes.NonoProcessor (implements org.reactivestreams.Processor<T,R>)
  • java.lang.Number (implements java.io.Serializable)
    • java.util.concurrent.atomic.AtomicInteger (implements java.io.Serializable)
      • hu.akarnokd.rxjava3.operators.BasicMergeSubscription<T> (implements io.reactivex.rxjava3.internal.subscribers.InnerQueuedSubscriberSupport<T>, org.reactivestreams.Subscription)
  • io.reactivex.rxjava3.core.Observable<T> (implements io.reactivex.rxjava3.core.ObservableSource<T>)
    • hu.akarnokd.rxjava3.async.DisposableObservable<T> (implements io.reactivex.rxjava3.disposables.Disposable)
    • hu.akarnokd.rxjava3.math.ObservableAverageDouble
    • hu.akarnokd.rxjava3.math.ObservableAverageFloat
    • hu.akarnokd.rxjava3.math.ObservableSumDouble
    • hu.akarnokd.rxjava3.math.ObservableSumFloat
    • hu.akarnokd.rxjava3.math.ObservableSumLong
    • io.reactivex.rxjava3.subjects.Subject<T> (implements io.reactivex.rxjava3.core.Observer<T>)
      • hu.akarnokd.rxjava3.subjects.DispatchWorkSubject<T> (implements io.reactivex.rxjava3.disposables.Disposable)
      • hu.akarnokd.rxjava3.subjects.UnicastWorkSubject<T> (implements io.reactivex.rxjava3.disposables.Disposable)
  • hu.akarnokd.rxjava3.consumers.ObservableConsumers
  • hu.akarnokd.rxjava3.operators.Observables
  • hu.akarnokd.rxjava3.operators.ObservableTransformers
  • hu.akarnokd.rxjava3.parallel.ParallelTransformers
  • hu.akarnokd.rxjava3.joins.Pattern1<T1>
  • hu.akarnokd.rxjava3.joins.Pattern2<T1,T2>
  • hu.akarnokd.rxjava3.joins.Pattern3<T1,T2,T3>
  • hu.akarnokd.rxjava3.joins.Pattern4<T1,T2,T3,T4>
  • hu.akarnokd.rxjava3.joins.Pattern5<T1,T2,T3,T4,T5>
  • hu.akarnokd.rxjava3.joins.Pattern6<T1,T2,T3,T4,T5,T6>
  • hu.akarnokd.rxjava3.joins.Pattern7<T1,T2,T3,T4,T5,T6,T7>
  • hu.akarnokd.rxjava3.joins.Pattern8<T1,T2,T3,T4,T5,T6,T7,T8>
  • hu.akarnokd.rxjava3.joins.Pattern9<T1,T2,T3,T4,T5,T6,T7,T8,T9>
  • hu.akarnokd.rxjava3.joins.PatternN
  • hu.akarnokd.rxjava3.basetypes.Perhaps<T> (implements org.reactivestreams.Publisher<T>)
    • hu.akarnokd.rxjava3.basetypes.PerhapsProcessor<T> (implements org.reactivestreams.Processor<T,R>)
  • hu.akarnokd.rxjava3.joins.Plan<R>
  • hu.akarnokd.rxjava3.debug.RxJavaAssemblyTracking
  • hu.akarnokd.rxjava3.debug.validator.RxJavaProtocolValidator
  • io.reactivex.rxjava3.core.Scheduler
    • hu.akarnokd.rxjava3.schedulers.BlockingScheduler
    • hu.akarnokd.rxjava3.schedulers.ParallelScheduler
    • hu.akarnokd.rxjava3.schedulers.SharedScheduler
  • hu.akarnokd.rxjava3.consumers.SingleConsumers
  • hu.akarnokd.rxjava3.operators.Singles
  • hu.akarnokd.rxjava3.operators.SingleTransformers
  • hu.akarnokd.rxjava3.util.SneakyThrows
  • hu.akarnokd.rxjava3.basetypes.Solo<T> (implements org.reactivestreams.Publisher<T>)
    • hu.akarnokd.rxjava3.basetypes.SoloProcessor<T> (implements org.reactivestreams.Processor<T,R>)
  • hu.akarnokd.rxjava3.util.SpmcLinkedArrayQueue<T> (implements io.reactivex.rxjava3.operators.SimplePlainQueue<T>)
  • hu.akarnokd.rxjava3.expr.StatementCompletable
  • hu.akarnokd.rxjava3.expr.StatementFlowable
  • hu.akarnokd.rxjava3.expr.StatementMaybe
  • hu.akarnokd.rxjava3.expr.StatementObservable
  • hu.akarnokd.rxjava3.expr.StatementSingle
  • hu.akarnokd.rxjava3.string.StringFlowable
  • hu.akarnokd.rxjava3.string.StringObservable
  • hu.akarnokd.rxjava3.subjects.Subjects
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • hu.akarnokd.rxjava3.functions.FunctionTagging.FunctionTaggingException
        • java.lang.IllegalStateException
          • hu.akarnokd.rxjava3.debug.validator.ProtocolNonConformanceException
            • hu.akarnokd.rxjava3.debug.validator.MultipleOnSubscribeCallsException
            • hu.akarnokd.rxjava3.debug.validator.MultipleTerminationsException
            • hu.akarnokd.rxjava3.debug.validator.NullOnErrorParameterException
            • hu.akarnokd.rxjava3.debug.validator.NullOnNextParameterException
            • hu.akarnokd.rxjava3.debug.validator.NullOnSubscribeParameterException
            • hu.akarnokd.rxjava3.debug.validator.NullOnSuccessParameterException
            • hu.akarnokd.rxjava3.debug.validator.OnNextAfterTerminationException
            • hu.akarnokd.rxjava3.debug.validator.OnSubscribeNotCalledException
            • hu.akarnokd.rxjava3.debug.validator.OnSuccessAfterTerminationException
        • hu.akarnokd.rxjava3.debug.RxJavaAssemblyException

Interface Hierarchy

• hu.akarnokd.rxjava3.operators.BasicEmitter<T>
• io.reactivex.rxjava3.functions.BiConsumer<T1,T2>
  • hu.akarnokd.rxjava3.functions.PlainBiConsumer<T1,T2>
• io.reactivex.rxjava3.functions.BiFunction<T1,T2,R>
  • hu.akarnokd.rxjava3.functions.PlainBiFunction<T1,T2,R>
• java.util.concurrent.Callable<V>
  • hu.akarnokd.rxjava3.functions.SimpleCallable<T>
• io.reactivex.rxjava3.functions.Consumer<T>
  • hu.akarnokd.rxjava3.functions.PlainConsumer<T>
• hu.akarnokd.rxjava3.functions.Consumer3<T1,T2,T3>
• hu.akarnokd.rxjava3.functions.Consumer4<T1,T2,T3,T4>
• hu.akarnokd.rxjava3.functions.Consumer5<T1,T2,T3,T4,T5>
• hu.akarnokd.rxjava3.functions.Consumer6<T1,T2,T3,T4,T5,T6>
• hu.akarnokd.rxjava3.functions.Consumer7<T1,T2,T3,T4,T5,T6,T7>
• hu.akarnokd.rxjava3.functions.Consumer8<T1,T2,T3,T4,T5,T6,T7,T8>
• hu.akarnokd.rxjava3.functions.Consumer9<T1,T2,T3,T4,T5,T6,T7,T8,T9>
• io.reactivex.rxjava3.core.Emitter<T>
  • hu.akarnokd.rxjava3.operators.FlowableAsyncEmitter<T>
• io.reactivex.rxjava3.functions.Function<T,R>
  • hu.akarnokd.rxjava3.functions.PlainFunction<T,R>
• io.reactivex.rxjava3.functions.Function3<T1,T2,T3,R>
  • hu.akarnokd.rxjava3.functions.PlainFunction3<T1,T2,T3,R>
• io.reactivex.rxjava3.functions.Function4<T1,T2,T3,T4,R>
  • hu.akarnokd.rxjava3.functions.PlainFunction4<T1,T2,T3,T4,R>
• io.reactivex.rxjava3.functions.Function5<T1,T2,T3,T4,T5,R>
  • hu.akarnokd.rxjava3.functions.PlainFunction5<T1,T2,T3,T4,T5,R>
• io.reactivex.rxjava3.functions.Function6<T1,T2,T3,T4,T5,T6,R>
  • hu.akarnokd.rxjava3.functions.PlainFunction6<T1,T2,T3,T4,T5,T6,R>
• io.reactivex.rxjava3.functions.Function7<T1,T2,T3,T4,T5,T6,T7,R>
  • hu.akarnokd.rxjava3.functions.PlainFunction7<T1,T2,T3,T4,T5,T6,T7,R>
• io.reactivex.rxjava3.functions.Function8<T1,T2,T3,T4,T5,T6,T7,T8,R>
  • hu.akarnokd.rxjava3.functions.PlainFunction8<T1,T2,T3,T4,T5,T6,T7,T8,R>
• io.reactivex.rxjava3.functions.Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,R>
  • hu.akarnokd.rxjava3.functions.PlainFunction9<T1,T2,T3,T4,T5,T6,T7,T8,T9,R>
• hu.akarnokd.rxjava3.operators.PartialCollectEmitter<T,I,A,R>
• hu.akarnokd.rxjava3.debug.SavedHooks

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • hu.akarnokd.rxjava3.async.AnyValue
    • hu.akarnokd.rxjava3.operators.ExpandStrategy
    • hu.akarnokd.rxjava3.util.SelfComparator (implements java.util.Comparator<T>)
    • hu.akarnokd.rxjava3.util.AlwaysTrueBooleanSupplier (implements io.reactivex.rxjava3.functions.BooleanSupplier)
    • hu.akarnokd.rxjava3.util.AlwaysFalseBooleanSupplier (implements io.reactivex.rxjava3.functions.BooleanSupplier)
    • hu.akarnokd.rxjava3.util.BiFunctionSecondIdentity (implements io.reactivex.rxjava3.functions.BiFunction<T1,T2,R>)