A B C D E F G H I J L M N O P R S T U V W Z

## A

accept(T1, T2, T3) - Method in interface hu.akarnokd.rxjava2.functions.Consumer3
accept(T1, T2, T3, T4) - Method in interface hu.akarnokd.rxjava2.functions.Consumer4
accept(T1, T2, T3, T4, T5) - Method in interface hu.akarnokd.rxjava2.functions.Consumer5
accept(T1, T2, T3, T4, T5, T6) - Method in interface hu.akarnokd.rxjava2.functions.Consumer6
accept(T1, T2, T3, T4, T5, T6, T7) - Method in interface hu.akarnokd.rxjava2.functions.Consumer7
accept(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface hu.akarnokd.rxjava2.functions.Consumer8
accept(T1, T2, T3, T4, T5, T6, T7, T8, T9) - Method in interface hu.akarnokd.rxjava2.functions.Consumer9
add(Subscription) - Method in class hu.akarnokd.rxjava2.util.CompositeSubscription
AlwaysFalseBooleanSupplier - Enum in hu.akarnokd.rxjava2.util
  A `BooleanSupplier` implementation that is always false.
AlwaysTrueBooleanSupplier - Enum in hu.akarnokd.rxjava2.util
  A `BooleanSupplier` implementation that is always true.
amb(Iterable<? extends Nono>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Returns a Nono that terminates when the first Nono from the sources sequence terminates.
amb(Iterable<? extends Perhaps<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Emit the events of the Perhaps that reacts first.
amb(Iterable<? extends Solo<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Emit the events of the Solo that reacts first.
ambArray(Nono...) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Returns a Nono that terminates when the first Nono from the array terminates.
ambArray(Perhaps<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Emit the events of the Perhaps that reacts first.
ambArray(Solo<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Emit the events of the Solo that reacts first.
ambWith(Perhaps<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Signals the events of this or the other Perhaps whichever signals first.
ambWith(Solo<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Signal the events of this or the other Solo whichever signals first.
and(Observable<T2>) - Method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Returns a Pattern that matches when both Observables emit an item.
and(Observable<T3>) - Method in class hu.akarnokd.rxjava2.joins.Pattern2
  Creates a pattern that matches when all three observable sequences have an available element.
and(Observable<T4>) - Method in class hu.akarnokd.rxjava2.joins.Pattern3
  Creates a pattern that matches when all three observable sequences have an available element.
and(Observable<T5>) - Method in class hu.akarnokd.rxjava2.joins.Pattern4
  Creates a pattern that matches when all four observable sequences have an available element.
and(Observable<T6>) - Method in class hu.akarnokd.rxjava2.joins.Pattern5
  Creates a pattern that matches when all five observable sequences have an available element.
and(Observable<T7>) - Method in class hu.akarnokd.rxjava2.joins.Pattern6
  Creates a pattern that matches when all six observable sequences have an available element.
and(Observable<T8>) - Method in class hu.akarnokd.rxjava2.joins.Pattern7
  Creates a pattern that matches when all seven observable sequences have an available element.
and(Observable<T9>) - Method in class hu.akarnokd.rxjava2.joins.Pattern8
  Creates a pattern that matches when all eight observable sequences have an available element.
and(Observable<? extends Object>) - Method in class hu.akarnokd.rxjava2.joins.Pattern9
  Creates a pattern that matches when all nine observable sequences have an available element.
and(Observable<? extends Object>) - Method in class hu.akarnokd.rxjava2.joins.PatternN
  Creates a pattern that matches when all previous observable sequences have an available element.
andThen(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  When this Nono completes, it is continued by the events of the other Publisher.
andThen(Nono) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Run the other Nono when this Nono completes.
andThen(Nono) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Runs this Perhaps and then runs the other Nono source, only emitting this Perhaps' success value if the other Nono source completes normally.
andThen(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Runs this Perhaps and emits its value followed by running the other Publisher and emitting its values.
andThen(Nono) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Run the given Nono after this Solo completes successfully and emit that original success value only if the Nono completes normally.
andThen(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Emits the success value of this Solo and then continues with the events of the other Publisher.
AnyValue - Enum in hu.akarnokd.rxjava2.async
  Placeholder instance when one has to return something (and used to return `null` in 1.x).
appendLast(Throwable) - Method in exception hu.akarnokd.rxjava2.debug.RxJavaAssemblyException
  Try appending this RxJavaAssemblyException as the very last cause of the given throwable.
apply(T1, T2) - Method in interface hu.akarnokd.rxjava2.functions.PlainBiFunction
apply(T) - Method in interface hu.akarnokd.rxjava2.functions.PlainFunction
apply(T1, T2, T3) - Method in interface hu.akarnokd.rxjava2.functions.PlainFunction3
apply(T1, T2, T3, T4) - Method in interface hu.akarnokd.rxjava2.functions.PlainFunction4
apply(T1, T2, T3, T4, T5) - Method in interface hu.akarnokd.rxjava2.functions.PlainFunction5
apply(T1, T2, T3, T4, T5, T6) - Method in interface hu.akarnokd.rxjava2.functions.PlainFunction6
apply(T1, T2, T3, T4, T5, T6, T7) - Method in interface hu.akarnokd.rxjava2.functions.PlainFunction7
apply(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface hu.akarnokd.rxjava2.functions.PlainFunction8
apply(T1, T2, T3, T4, T5, T6, T7, T8, T9) - Method in interface hu.akarnokd.rxjava2.functions.PlainFunction9
AsyncFlowable - Class in hu.akarnokd.rxjava2.async
  Utility methods to convert functions and actions into asynchronous operations through the Publisher/Subscriber pattern.
AsyncObservable - Class in hu.akarnokd.rxjava2.async
  Utility methods to convert functions and actions into asynchronous operations through the Observable/Observer pattern.
averageDouble(Publisher<? extends Number>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable
averageDouble(ObservableSource<? extends Number>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable
averageFloat(Publisher<? extends Number>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable
averageFloat(ObservableSource<? extends Number>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable

## B

BasicEmitter<T> - Interface in hu.akarnokd.rxjava2.operators
  Abstraction over a Subscriber.
blockingAwait() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Blockingly await indefinitely the termination of this Nono and return the Throwable if this Nono terminated with an error, null otherwise.
blockingAwait(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Blockingly await for the given timeout the termination of this Nono and return the Throwable if this Nono terminated with an error, null otherwise.
blockingGet() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Blockingly awaits indefinitely the success value of this Perhaps or rethrows its error (wrapped into a RuntimeException if necessary).
blockingGet(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Blockingly awaits at most the given timeout for the success value of this Perhaps or rethrows its error (wrapped into a RuntimeException if necessary).
blockingGet() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Blockingly awaits indefinitely the success value of this Solo or rethrows its error (wrapped into a RuntimeException if necessary).
blockingGet(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Blockingly awaits at most the given timeout for the success value of this Solo or rethrows its error (wrapped into a RuntimeException if necessary).
blockingSubscribe() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Block until this Nono terminates and ignore the actual events.
blockingSubscribe(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Block until this Nono completes and call the Action on the thread where the blocking happens.
blockingSubscribe(Action, Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Block until this Nono terminates and call the Action or Consumer depending on the terminal event on the thread where the blocking happens.
blockingSubscribe() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Blocks until this Perhaps terminates and ignores the signals it produced.
blockingSubscribe(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Blocks until this Perhaps terminates and calls the onNext with the success value.
blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Blocks until this Perhaps terminates and calls the onNext with the success value or calls the onError with the error Throwable.
blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>, Action) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Blocks until this Perhaps produces its terminal signal and calls the appropriate callback(s) based on the signal type.
blockingSubscribe() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Blocks until this Solo terminates and ignores the signals it produced.
blockingSubscribe(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Blocks until this Solo terminates and calls the onNext with the success value.
blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Blocks until this solo terminates and calls the onNext with the success value or calls the onError with the error Throwable.
blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>, Action) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Blocks until this Solo produces its terminal signal and calls the appropriate callback(s) based on the signal type.
bufferSize() - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Returns the default buffer or prefetch size.
bufferUntil(Predicate<? super T>) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Buffers elements into a List until the given predicate returns true at which point a new empty buffer is started.
bufferUntil(Predicate<? super T>, Callable<C>) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Buffers elements into a custom collection until the given predicate returns true at which point a new empty custom collection is started.
bufferWhile(Predicate<? super T>) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Buffers elements into a List while the given predicate returns true; if the predicate returns false for an item, a new buffer is created with the specified item.
bufferWhile(Predicate<? super T>, Callable<C>) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Buffers elements into a custom collection while the given predicate returns true; if the predicate returns false for an item, a new collection is created with the specified item.
buildStackTrace() - Static method in exception hu.akarnokd.rxjava2.debug.RxJavaAssemblyException

## C

cache() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Caches the terminal event of the upstream Nono and relays/replays it to Subscribers.
cache() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Caches the value or error event of the upstream Perhaps and relays/replays it to Subscribers.
cache() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Caches the value or error event of the upstream Solo and relays/replays it to Subscribers.
call() - Method in interface hu.akarnokd.rxjava2.functions.Supplier
cancel() - Method in class hu.akarnokd.rxjava2.util.CompositeSubscription
characters(CharSequence) - Static method in class hu.akarnokd.rxjava2.string.StringFlowable
  Signals each character of the given string CharSequence as Integers.
characters(CharSequence) - Static method in class hu.akarnokd.rxjava2.string.StringObservable
  Signals each character of the given string CharSequence as Integers.
clear() - Method in class hu.akarnokd.rxjava2.util.SpscOneQueue
collect(Callable<C>, BiConsumer<C, T>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Collect the elements in each rail into a collection supplied via a collectionSupplier and collected into with a collector action, emitting the collection at the end.
compare(Comparable, Comparable) - Method in enum hu.akarnokd.rxjava2.util.SelfComparator
CompletableSubject - Class in hu.akarnokd.rxjava2.subjects
  Represents a hot Completable-like source and consumer of events similar to Subjects.
complete() - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Returns a Nono that completes normally.
compose(Function<? super Nono, ? extends Nono>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Compose operators fluently via a function callback that returns a Nono for this Nono.
compose(Function<? super Perhaps<T>, ? extends Perhaps<R>>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Applies a function to this Perhaps and returns the Perhaps it returned.
compose(Function<? super Solo<T>, ? extends Solo<R>>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Applies a function to this Solo and returns the Solo it returned.
compose(Function<? super ParallelFlowable<T>, ParallelFlowable<U>>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Allows composing operators, in assembly time, on top of this ParallelFlowable and returns another ParallelFlowable with composed features.
CompositeSubscription - Class in hu.akarnokd.rxjava2.util
  Container for Subscriptions and atomic operations on them.
CompositeSubscription() - Constructor for class hu.akarnokd.rxjava2.util.CompositeSubscription
concat(Iterable<? extends Nono>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the Nono sources one after the other.
concat(Publisher<? extends Nono>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the Nono sources emitted by the Publisher one after the other.
concat(Publisher<? extends Nono>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the Nono sources emitted by the Publisher one after the other, prefetching the given number of Nono sources.
concat(Iterable<? extends Perhaps<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Concatenate the values in order from a sequence of Perhaps sources.
concat(Publisher<? extends Perhaps<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Concatenate the values in order from a sequence of Perhaps sources.
concat(Publisher<? extends Perhaps<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Concatenate the values in order from a sequence of Perhaps sources.
concat(Iterable<? extends Solo<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Concatenate the values in order from a sequence of Solo sources.
concat(Publisher<? extends Solo<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Concatenate the values in order from a sequence of Solo sources.
concat(Publisher<? extends Solo<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Concatenate the values in order from a sequence of Solo sources.
concatArray(Nono...) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the Nono sources one after the other.
concatArray(Perhaps<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Concatenate the values in order from a sequence of Perhaps sources.
concatArray(Solo<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Concatenate the values in order from a sequence of Solo sources.
concatArrayDelayError(Nono...) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the Nono sources one after the other, delaying errors from them till all sources have terminated.
concatArrayDelayError(Perhaps<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Concatenate the values in order from a sequence of Perhaps sources, delaying errors till all sources terminate.
concatArrayDelayError(Solo<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Concatenate the values in order from a sequence of Solo sources, delaying errors till all sources terminate.
concatDelayError(Iterable<? extends Nono>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the Nono sources one after the other, delaying errors from them till all sources have terminated.
concatDelayError(Publisher<? extends Nono>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the Nono sources emitted by the Publisher, one after the other, delaying errors from them till all sources have terminated.
concatDelayError(Publisher<? extends Nono>, int, boolean) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the Nono sources emitted by the Publisher, one after the other, delaying errors from them till all sources have terminated and prefetching Nonos from the upstream.
concatDelayError(Iterable<? extends Perhaps<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Concatenate the values in order from a sequence of Perhaps sources, delaying errors till all sources terminate.
concatDelayError(Publisher<? extends Perhaps<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Concatenate the values in order from a sequence of Perhaps sources, delaying errors till all sources terminate.
concatDelayError(Publisher<? extends Perhaps<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Concatenate the values in order from a sequence of Perhaps sources, delaying errors till all sources terminate.
concatDelayError(Publisher<? extends Perhaps<? extends T>>, int, boolean) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Concatenate the values in order from a sequence of Perhaps sources, delaying errors till a source terminates or the whole sequence terminates.
concatDelayError(Iterable<? extends Solo<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Concatenate the values in order from a sequence of Solo sources, delaying errors till all sources terminate.
concatDelayError(Publisher<? extends Solo<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Concatenate the values in order from a sequence of Solo sources, delaying errors till all sources terminate.
concatDelayError(Publisher<? extends Solo<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Concatenate the values in order from a sequence of Solo sources, delaying errors till all sources terminate.
concatDelayError(Publisher<? extends Solo<? extends T>>, int, boolean) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Concatenate the values in order from a sequence of Solo sources, delaying errors till a source terminates or the whole sequence terminates.
concatMap(Function<? super T, ? extends Publisher<? extends R>>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Generates and concatenates Publishers on each 'rail', signalling errors immediately and generating 2 publishers upfront.
concatMap(Function<? super T, ? extends Publisher<? extends R>>, int) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Generates and concatenates Publishers on each 'rail', signalling errors immediately and using the given prefetch amount for generating Publishers upfront.
concatMap(Function<? super T, ? extends Publisher<? extends R>>, ErrorMode) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Generates and concatenates Publishers on each 'rail', optionally delaying errors and generating 2 publishers upfront.
concatMap(Function<? super T, ? extends Publisher<? extends R>>, int, ErrorMode) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Generates and concatenates Publishers on each 'rail', optionally delaying errors and using the given prefetch amount for generating Publishers upfront.
concatWith(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Runs this Perhaps and emits its value followed by running the other Publisher and emitting its values.
concatWith(Solo<T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Emits the success value of this Solo followed by the event of the other Solo.
Consumer3<T1,T2,T3> - Interface in hu.akarnokd.rxjava2.functions
  Functional interface for a callback that consumes multipe values at the same and may throw a checked exception.
Consumer4<T1,T2,T3,T4> - Interface in hu.akarnokd.rxjava2.functions
  Functional interface for a callback that consumes multipe values at the same and may throw a checked exception.
Consumer5<T1,T2,T3,T4,T5> - Interface in hu.akarnokd.rxjava2.functions
  Functional interface for a callback that consumes multipe values at the same and may throw a checked exception.
Consumer6<T1,T2,T3,T4,T5,T6> - Interface in hu.akarnokd.rxjava2.functions
  Functional interface for a callback that consumes multipe values at the same and may throw a checked exception.
Consumer7<T1,T2,T3,T4,T5,T6,T7> - Interface in hu.akarnokd.rxjava2.functions
  Functional interface for a callback that consumes multipe values at the same and may throw a checked exception.
Consumer8<T1,T2,T3,T4,T5,T6,T7,T8> - Interface in hu.akarnokd.rxjava2.functions
  Functional interface for a callback that consumes multipe values at the same and may throw a checked exception.
Consumer9<T1,T2,T3,T4,T5,T6,T7,T8,T9> - Interface in hu.akarnokd.rxjava2.functions
  Functional interface for a callback that consumes multipe values at the same and may throw a checked exception.
create(CompletableOnSubscribe) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Creates a Nono instance that when subscribed to, the given onCreate is called for each individual subscriber to generate a terminal event synchronously and synchronously in a cancellation-safe manner.
create() - Static method in class hu.akarnokd.rxjava2.basetypes.NonoProcessor
  Creates a NonoProcessor instance ready to receive events and Subscribers.
create(MaybeOnSubscribe<T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Create a Perhaps that for each incoming Subscriber calls a callback to emit a sync or async events in a thread-safe, backpressure-aware and cancellation-safe manner.
create() - Static method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
  Creates a fresh PerhapsProcessor instance.
create(SingleOnSubscribe<T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Create a Solo that for each incoming Subscriber calls a callback to emit a sync or async events in a thread-safe, backpressure-aware and cancellation-safe manner.
create() - Static method in class hu.akarnokd.rxjava2.basetypes.SoloProcessor
  Creates a fresh SoloProcessor instance.
create() - Static method in class hu.akarnokd.rxjava2.subjects.CompletableSubject
  Creates a fresh CompletableSubject.
create() - Static method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
  Creates a fresh MaybeSubject.
create() - Static method in class hu.akarnokd.rxjava2.subjects.SingleSubject
  Creates a fresh SingleSubject.
createWorker() - Method in class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
createWorker() - Method in class hu.akarnokd.rxjava2.schedulers.SharedScheduler

## D

defaultIfEmpty(T) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Signal the given item if this Perhaps is empty.
defer(Callable<? extends Nono>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Defers the creation of the actual Nono instance until a subscriber subscribes.
defer(Callable<? extends Perhaps<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Defers the creation of the actual Perhaps instance until subscription time and for each downstream Subscriber the given callable is called.
defer(Callable<? extends Solo<T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Defers the creation of the actual Solo to the time when a Subscriber subscribes to the returned Solo.
deferFuture(Callable<? extends Future<? extends Publisher<? extends T>>>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Returns an Observable that starts the specified asynchronous factory function whenever a new subscriber subscribes.
deferFuture(Callable<? extends Future<? extends Publisher<? extends T>>>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Returns an Observable that starts the specified asynchronous factory function whenever a new subscriber subscribes.
deferFuture(Callable<? extends Future<? extends ObservableSource<? extends T>>>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Returns an Observable that starts the specified asynchronous factory function whenever a new subscriber subscribes.
deferFuture(Callable<? extends Future<? extends ObservableSource<? extends T>>>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Returns an Observable that starts the specified asynchronous factory function whenever a new subscriber subscribes.
delay(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Delay the emission of the terminal events of this Nono by the given time amount.
delay(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Delay the emission of the terminal events of this Nono by the given time amount.
delay(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Delay the emission of the signals of this Perhaps by the given amount of time.
delay(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Delay the emission of the signals of this Perhaps by the given amount of time.
delay(Publisher<?>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Delay the emission of the signals of this Perhaps till the other Publisher signals an item or completes.
delay(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Delay the emission of the signal of this Solo with the specified time amount.
delay(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Delay the emission of the signal of this Solo with the specified time amount on the specified scheduler.
delay(Publisher<?>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Delay the emission of the signal until the other Publisher signals an item or completes.
delaySubscription(Publisher<?>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Delays the actual subscription to this Nono until the other Publisher signals an item or completes.
delaySubscription(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Delays the actual subscription to this Nono until the given time passes.
delaySubscription(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Delays the actual subscription to this Nono until the given time passes.
delaySubscription(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Delay the subscription to this Perhaps by the given time amount.
delaySubscription(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Delay the subscription to this Perhaps by the given time amount, running on the specified Scheduler.
delaySubscription(Publisher<?>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Delay the subscription to this Perhaps until the other Publisher signals an item or completes.
delaySubscription(Publisher<?>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Delay the subscription to this Solo until the other Publisher signals a value or completes.
delaySubscription(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Delay the subscription to this Solo until the specified delay elapses.
delaySubscription(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Delay the subscription to this Solo until the specified delay elapses.
delete(Subscription) - Method in class hu.akarnokd.rxjava2.util.CompositeSubscription
disable() - Static method in class hu.akarnokd.rxjava2.debug.RxJavaAssemblyTracking
  Disable the assembly tracking.
DisposableFlowable<T> - Class in hu.akarnokd.rxjava2.async
  A `Flowable` that also offers a means to dispose it, cancelling/disposing some shared underlying computation or resource via `Disposable.dispose()`.
DisposableFlowable() - Constructor for class hu.akarnokd.rxjava2.async.DisposableFlowable
DisposableObservable<T> - Class in hu.akarnokd.rxjava2.async
  A `Observable` that also offers a means to dispose it, cancelling/disposing some shared underlying computation or resource via `Disposable.dispose()`.
DisposableObservable() - Constructor for class hu.akarnokd.rxjava2.async.DisposableObservable
doAfterNext(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Executes a callback after the value is emitted to downstream.
doAfterNext(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Executes a callback after the value is emitted to downstream.
doAfterNext(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Call the specified consumer with the current element passing through any 'rail' after it has been delivered to downstream within the rail.
doAfterTerminate(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Executes the callback after this Nono terminates and the downstream is notified.
doAfterTerminate(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Executes the callback after this Perhaps terminates and the downstream is notified.
doAfterTerminate(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Executes the callback after this Solo terminates and the downstream is notified.
doAfterTerminated(Action) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Run the specified Action when a 'rail' completes or signals an error.
doComplete() - Method in interface hu.akarnokd.rxjava2.operators.BasicEmitter
doError(Throwable) - Method in interface hu.akarnokd.rxjava2.operators.BasicEmitter
doFinally(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Executes the callback exactly if the upstream terminates or the downstream cancels the sequence.
doFinally(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Executes the callback exactly if the upstream terminates or the downstream cancels the sequence.
doFinally(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Executes the callback exactly if the upstream terminates or the downstream cancels the sequence.
doNext(T) - Method in interface hu.akarnokd.rxjava2.operators.BasicEmitter
doOnCancel(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Executes the callback if the downstream cancels the sequence.
doOnCancel(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Executes the callback if the downstream cancels the sequence.
doOnCancel(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Executes the callback if the downstream cancels the sequence.
doOnCancel(Action) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Run the specified Action when a 'rail' receives a cancellation.
doOnComplete(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Executes a callback when the upstream completes normally.
doOnComplete(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Executes a callback when the upstream completes normally.
doOnComplete(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Executes a callback when the upstream completes normally.
doOnComplete(Action) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Run the specified Action when a 'rail' completes.
doOnError(Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Executes a callback when the upstream signals an error.
doOnError(Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Executes a callback when the upstream signals an error.
doOnError(Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Executes a callback when the upstream signals an error.
doOnError(Consumer<Throwable>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Call the specified consumer with the exception passing through any 'rail'.
doOnNext(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Executes a callback before the value is emitted to downstream.
doOnNext(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Executes a callback before the value is emitted to downstream.
doOnNext(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Call the specified consumer with the current element passing through any 'rail'.
doOnRequest(LongConsumer) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Executes the callback when the downstream requests from this Nolo.
doOnRequest(LongConsumer) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Executes the callback when the downstream requests from this Perhaps.
doOnRequest(LongConsumer) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Executes the callback when the downstream requests from this Solo.
doOnRequest(LongConsumer) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Call the specified consumer with the request amount if any rail receives a request.
doOnSubscribe(Consumer<? super Subscription>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Executes a callback when the upstream calls onSubscribe.
doOnSubscribe(Consumer<? super Subscription>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Executes a callback when the upstream calls onSubscribe.
doOnSubscribe(Consumer<? super Subscription>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Executes a callback when the upstream calls onSubscribe.
doOnSubscribe(Consumer<? super Subscription>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Call the specified callback when a 'rail' receives a Subscription from its upstream.
doWhile(Publisher<? extends T>, BooleanSupplier) - Static method in class hu.akarnokd.rxjava2.expr.StatementFlowable
  Return an Flowable that re-emits the emissions from the source Flowable, and then re-subscribes to the source long as a condition is true.
doWhile(ObservableSource<? extends T>, BooleanSupplier) - Static method in class hu.akarnokd.rxjava2.expr.StatementObservable
  Return an Observable that re-emits the emissions from the source Observable, and then re-subscribes to the source long as a condition is true.

## E

empty() - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Returns an empty Perhaps.
emptyConsumer() - Static method in class hu.akarnokd.rxjava2.functions.FunctionsEx
  Returns a Consumer1-9 shared instance that ignores the argument(s) of its `accept()` methods.
enable() - Static method in class hu.akarnokd.rxjava2.debug.RxJavaAssemblyTracking
  Enable the assembly tracking.
error(Throwable) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Returns a Nono that signals the given Throwable to all subscribers.
error(Callable<? extends Throwable>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Returns a Nono that signals a Throwable generated by the callable for each individual subscriber.
error(Throwable) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Returns a Perhaps that signals the given error to Subscribers.
error(Callable<? extends Throwable>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Returns a Perhaps that signals the error returned from the errorSupplier to each individual Subscriber.
error(Throwable) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Returns a Solo that signals the given error to Subscribers.
error(Callable<? extends Throwable>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Returns a Solo that signals the error returned from the errorSupplier to each individual Subscriber.

## F

fillInStackTrace() - Method in exception hu.akarnokd.rxjava2.debug.RxJavaAssemblyException
filter(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Filters the value from upstream with a predicate and completes if the filter didn't match it.
filter(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Applies a predicate to the value and emits it if the predicate returns true, completes otherwise.
filter(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Filters the source values on each 'rail'.
find(Throwable) - Static method in exception hu.akarnokd.rxjava2.debug.RxJavaAssemblyException
  Tries to locate the RxJavaAssemblyException in the chain of causes of the given Throwable.
flatMap(Function<? super Throwable, ? extends Publisher<? extends T>>, Callable<? extends Publisher<? extends T>>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Maps the upstream completion or error into a Publisher and emit its events as a Flowable.
flatMap(Function<? super T, ? extends Perhaps<? extends R>>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Maps the upstream's value into another Perhaps and emits its resulting events.
flatMap(Function<? super T, ? extends Perhaps<? extends R>>, Function<? super Throwable, ? extends Perhaps<? extends R>>, Callable<? extends Perhaps<? extends R>>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Maps the upstream events into other Perhaps instances and emits its resulting events.
flatMap(Function<? super T, ? extends Solo<? extends R>>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Maps the success value of this Solo into another Solo and emits its signals.
flatMap(Function<? super T, ? extends Solo<? extends R>>, Function<? super Throwable, ? extends Solo<? extends R>>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Maps the success value or the failure of this Solo into another Solo and emits its signal.
flatMap(Function<? super T, ? extends Publisher<? extends R>>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Generates and flattens Publishers on each 'rail'.
flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Generates and flattens Publishers on each 'rail', optionally delaying errors.
flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean, int) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Generates and flattens Publishers on each 'rail', optionally delaying errors and having a total number of simultaneous subscriptions to the inner Publishers.
flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean, int, int) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Generates and flattens Publishers on each 'rail', optionally delaying errors, having a total number of simultaneous subscriptions to the inner Publishers and using the given prefetch amount for the inner Publishers.
flatMapPublisher(Function<? super T, ? extends Publisher<? extends R>>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Maps the upstream value into a Publisher and emits all of its events.
flatMapPublisher(Function<? super T, ? extends Publisher<? extends R>>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Maps the success value of this Solo into a Publisher and emits its signals.
FlowableProcessors - Class in hu.akarnokd.rxjava2.processors
  Utility methods to work with Reactive-Streams Processors and RxJava 2 FlowableProcessors.
Flowables - Class in hu.akarnokd.rxjava2.operators
  Utility class to create Flowable sources.
FlowableTransformers - Class in hu.akarnokd.rxjava2.operators
  Additional operators in the form of `FlowableTransformer`, use `Flowable.compose(FlowableTransformer)` to apply the operators to an existing sequence.
forEachFuture(Publisher<? extends T>, Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.
forEachFuture(Publisher<? extends T>, Consumer<? super T>, Consumer<? super Throwable>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.
forEachFuture(Publisher<? extends T>, Consumer<? super T>, Consumer<? super Throwable>, Action) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.
forEachFuture(Publisher<? extends T>, Consumer<? super T>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given scheduler.
forEachFuture(Publisher<? extends T>, Consumer<? super T>, Consumer<? super Throwable>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given Scheduler.
forEachFuture(Publisher<? extends T>, Consumer<? super T>, Consumer<? super Throwable>, Action, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given Scheduler.
forEachFuture(ObservableSource<? extends T>, Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.
forEachFuture(ObservableSource<? extends T>, Consumer<? super T>, Consumer<? super Throwable>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.
forEachFuture(ObservableSource<? extends T>, Consumer<? super T>, Consumer<? super Throwable>, Action) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.
forEachFuture(ObservableSource<? extends T>, Consumer<? super T>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given scheduler.
forEachFuture(ObservableSource<? extends T>, Consumer<? super T>, Consumer<? super Throwable>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given Scheduler.
forEachFuture(ObservableSource<? extends T>, Consumer<? super T>, Consumer<? super Throwable>, Action, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given Scheduler.
from(Observable<T>) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Creates a JoinObservable from a regular Observable.
from(Publisher<? extends T>) - Static method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Take a Publisher and prepare to consume it on multiple 'rails' (number of CPUs) in a round-robin fashion.
from(Publisher<? extends T>, int) - Static method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Take a Publisher and prepare to consume it on parallallism number of 'rails' in a round-robin fashion.
from(Publisher<? extends T>, int, int) - Static method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Take a Publisher and prepare to consume it on parallallism number of 'rails' , possibly ordered and round-robin fashion and use custom prefetch amount and queue for dealing with the source Publisher's values.
fromAction(Action) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Executes an action when a subscriber subscribes to the returned Nono.
fromAction(Action) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Run an action for each individual Subscriber and terminate.
fromArray(Publisher<T>...) - Static method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Wraps multiple Publishers into a ParallelFlowable which runs them in parallel and unordered.
fromCallable(Callable<T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Runs a Callable and emits its resulting value or its exception; null is considered to be an indication for an empty Perhaps.
fromCallable(Callable<T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Returns a Solo that calls the callable and emits its value or error.
fromCompletable(CompletableSource) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Wrap a Completable into a Nono and terminate when the source Completable terminates.
fromCompletable(CompletableSource) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Wraps a Completable and signals its terminal events.
fromFuture(Future<?>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Blockingly waits indefinitely for the given Future to terminate, relaying any error the Future signals.
fromFuture(Future<?>, long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Blockingly waits the given Future for the given timeout to terminate, relaying any error the Future signals.
fromFuture(Future<? extends T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  When subscribed, the future is awaited blockingly and indefinitely for its result value; null result will yield a NoSuchElementException.
fromFuture(Future<? extends T>, long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  When subscribed, the future is awaited blockingly for a given amount of time for its result value; null result will yield a NoSuchElementException and a timeout will yield a TimeoutException.
fromFuture(Future<? extends T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  When subscribed, the future is awaited blockingly and indefinitely for its result value; null result will yield a NoSuchElementException.
fromFuture(Future<? extends T>, long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  When subscribed, the future is awaited blockingly for a given amount of time for its result value; null result will yield a NoSuchElementException and a timeout will yield a TimeoutException.
fromMaybe(MaybeSource<?>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Wrap a Maybe, ignore its success value and terminate if the source Maybe terminates.
fromMaybe(MaybeSource<T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Wraps a Maybe and signals its events.
fromObservable(ObservableSource<?>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Wrap a general Observable, ignore all of its values and terminate if the source Observable terminates.
fromPublisher(Publisher<?>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Wrap a general Publisher, ignore all of its values and terminate if the source Publisher terminates.
fromPublisher(Publisher<T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Wraps a Publisher and signals its single value or completion signal or signals IndexOutOfBoundsException if the Publisher has more than one element.
fromPublisher(Publisher<T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Wraps a Publisher into a Solo and signals its only value, NoSuchElementException if empty or IndexOutOfBoundsException if it has more than one element.
fromSingle(SingleSource<?>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Wrap a Single, ignore its success value and terminate if the source Single terminates.
fromSingle(SingleSource<T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Wraps a Single and signals its events.
fromSingle(SingleSource<T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Wraps a Single into a Solo and signals its events.
FunctionsEx - Class in hu.akarnokd.rxjava2.functions
  Utility methods to work with functional interfaces of this package.

## G

getAsBoolean() - Method in enum hu.akarnokd.rxjava2.util.AlwaysFalseBooleanSupplier
getAsBoolean() - Method in enum hu.akarnokd.rxjava2.util.AlwaysTrueBooleanSupplier
getOnAssemblyHandler() - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Returns the current onAssembly handler function or null if not set.
getOnAssemblyHandler() - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Returns the current onAssembly handler.
getOnAssemblyHandler() - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Returns the current onAssembly handler.
getThrowable() - Method in class hu.akarnokd.rxjava2.basetypes.NonoProcessor
  Returns the error that terminated this NonoProcessor if `NonoProcessor.hasThrowable()` returns true.
getThrowable() - Method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
  Returns the received onError Throwable if hasThrowable() is true, null otherwise.
getThrowable() - Method in class hu.akarnokd.rxjava2.basetypes.SoloProcessor
  Returns the received onError Throwable if hasThrowable() is true, null otherwise.
getThrowable() - Method in class hu.akarnokd.rxjava2.subjects.CompletableSubject
  Returns the terminal error if this CompletableSubject has been terminated with an error, null otherwise.
getThrowable() - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
  Returns the terminal error if this MaybeSubject has been terminated with an error, null otherwise.
getThrowable() - Method in class hu.akarnokd.rxjava2.subjects.SingleSubject
  Returns the terminal error if this SingleSubject has been terminated with an error, null otherwise.
getValue() - Method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
  Returns the received onNext value if hasValue() is true, null otherwise.
getValue() - Method in class hu.akarnokd.rxjava2.basetypes.SoloProcessor
  Returns the received onNext value if hasValue() is true, null otherwise.
getValue() - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
  Returns the success value if this MaybeSubject was terminated with a success value.
getValue() - Method in class hu.akarnokd.rxjava2.subjects.SingleSubject
  Returns the success value if this SingleSubject was terminated with a success value.

## H

hasComplete() - Method in class hu.akarnokd.rxjava2.basetypes.NonoProcessor
  Returns true if this NonoProcessor has completed normally.
hasComplete() - Method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
  Returns true if this PerhapsProcessor completed without any value.
hasComplete() - Method in class hu.akarnokd.rxjava2.subjects.CompletableSubject
  Returns true if this CompletableSubject has been completed.
hasComplete() - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
  Returns true if this MaybeSubject has been completed.
hasObservers() - Method in class hu.akarnokd.rxjava2.subjects.CompletableSubject
  Returns true if this CompletableSubject has observers.
hasObservers() - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
  Returns true if this MaybeSubject has observers.
hasObservers() - Method in class hu.akarnokd.rxjava2.subjects.SingleSubject
  Returns true if this SingleSubject has observers.
hasSubscribers() - Method in class hu.akarnokd.rxjava2.basetypes.NonoProcessor
  Returns true if this NonoProcessor currently has Subscribers.
hasSubscribers() - Method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
  Returns true if this Processor has Subscribers.
hasSubscribers() - Method in class hu.akarnokd.rxjava2.basetypes.SoloProcessor
  Returns true if this Processor has Subscribers.
hasThrowable() - Method in class hu.akarnokd.rxjava2.basetypes.NonoProcessor
  Returns true if this NonoProcessor has terminated with an error.
hasThrowable() - Method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
  Returns true if this PerhapsProcessor received an onError Throwable.
hasThrowable() - Method in class hu.akarnokd.rxjava2.basetypes.SoloProcessor
  Returns true if this SoloProcessor received an onError Throwable.
hasThrowable() - Method in class hu.akarnokd.rxjava2.subjects.CompletableSubject
  Returns true if this CompletableSubject has been terminated with an error.
hasThrowable() - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
  Returns true if this MaybeSubject has been terminated with an error.
hasThrowable() - Method in class hu.akarnokd.rxjava2.subjects.SingleSubject
  Returns true if this SingleSubject has been terminated with an error.
hasValue() - Method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
  Returns true if this PerhapsProcessor received an onNext value.
hasValue() - Method in class hu.akarnokd.rxjava2.basetypes.SoloProcessor
  Returns true if this SoloProcessor received an onNext value.
hasValue() - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
  Returns true if this MaybeSubject was terminated with a success value.
hasValue() - Method in class hu.akarnokd.rxjava2.subjects.SingleSubject
  Returns true if this SingleSubject was terminated with a success value.
hide() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Hides the identity of this Nono.
hide() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Hides the identity of this Perhaps instance, including its subscriber.
hide() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Hides the identity of this Solo, including its Subscription and allows preventing fusion and other optimizations for diagnostic purposes.
hu.akarnokd.rxjava2.async - package hu.akarnokd.rxjava2.async
hu.akarnokd.rxjava2.basetypes - package hu.akarnokd.rxjava2.basetypes
hu.akarnokd.rxjava2.debug - package hu.akarnokd.rxjava2.debug
hu.akarnokd.rxjava2.expr - package hu.akarnokd.rxjava2.expr
hu.akarnokd.rxjava2.functions - package hu.akarnokd.rxjava2.functions
hu.akarnokd.rxjava2.joins - package hu.akarnokd.rxjava2.joins
hu.akarnokd.rxjava2.math - package hu.akarnokd.rxjava2.math
hu.akarnokd.rxjava2.operators - package hu.akarnokd.rxjava2.operators
hu.akarnokd.rxjava2.parallel - package hu.akarnokd.rxjava2.parallel
hu.akarnokd.rxjava2.processors - package hu.akarnokd.rxjava2.processors
hu.akarnokd.rxjava2.schedulers - package hu.akarnokd.rxjava2.schedulers
hu.akarnokd.rxjava2.string - package hu.akarnokd.rxjava2.string
hu.akarnokd.rxjava2.subjects - package hu.akarnokd.rxjava2.subjects
hu.akarnokd.rxjava2.util - package hu.akarnokd.rxjava2.util

## I

ifThen(BooleanSupplier, Publisher<? extends R>) - Static method in class hu.akarnokd.rxjava2.expr.StatementFlowable
  Return an Flowable that emits the emissions from a specified Flowable if a condition evaluates to true, otherwise return an empty Flowable.
ifThen(BooleanSupplier, Publisher<? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.expr.StatementFlowable
  Return an Flowable that emits the emissions from a specified Flowable if a condition evaluates to true, otherwise return an empty Flowable that runs on a specified Scheduler.
ifThen(BooleanSupplier, Publisher<? extends R>, Flowable<? extends R>) - Static method in class hu.akarnokd.rxjava2.expr.StatementFlowable
  Return an Flowable that emits the emissions from one specified Flowable if a condition evaluates to true, or from another specified Flowable otherwise.
ifThen(BooleanSupplier, ObservableSource<? extends R>) - Static method in class hu.akarnokd.rxjava2.expr.StatementObservable
  Return an Observable that emits the emissions from a specified Observable if a condition evaluates to true, otherwise return an empty Observable.
ifThen(BooleanSupplier, ObservableSource<? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.expr.StatementObservable
  Return an Observable that emits the emissions from a specified Observable if a condition evaluates to true, otherwise return an empty Observable that runs on a specified Scheduler.
ifThen(BooleanSupplier, ObservableSource<? extends R>, Observable<? extends R>) - Static method in class hu.akarnokd.rxjava2.expr.StatementObservable
  Return an Observable that emits the emissions from one specified Observable if a condition evaluates to true, or from another specified Observable otherwise.
ignoreElement() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Ignore the element of this Perhaps.
ignoreElement() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Ignore the solo value of this Solo and only signal the terminal events.
instance() - Static method in enum hu.akarnokd.rxjava2.util.SelfComparator
isEmpty() - Method in class hu.akarnokd.rxjava2.util.SpscOneQueue

## J

JoinObservable<T> - Class in hu.akarnokd.rxjava2.joins
  Represents an observable that supports join operations.
just(T) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Returns a Perhaps that signals the given item.
just(T) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Returns a Solo that signals the given item and completes.
justThrow(Throwable) - Static method in class hu.akarnokd.rxjava2.util.SneakyThrows

## L

lift(Function<Subscriber<? super Void>, Subscriber<? super Void>>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Transform the downstream's Subscriber into a Subscriber for the upstream via a function.
lift(Function<Subscriber<? super R>, Subscriber<? super T>>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Map the downstream Subscriber into an upstream Subscriber.
lift(Function<Subscriber<? super R>, Subscriber<? super T>>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Map the downstream Subscriber into an upstream Subscriber.

## M

map(Function<? super T, ? extends R>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Maps the value of this Perhaps into another value (of possibly different type).
map(Function<? super T, ? extends R>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Maps the value of this Solo into another value via function.
map(Function<? super T, ? extends R>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Maps the source values on each 'rail' to another value.
mapError(Function<? super Throwable, ? extends Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Maps the upstream error into another Throwable via a function.
mapError(Function<? super Throwable, ? extends Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Maps the error from upstream into another Throwable error.
mapError(Function<? super Throwable, ? extends Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Maps the Throwable error of this Solo into another Throwable error type.
mapFilter(BiConsumer<? super T, ? super BasicEmitter<R>>) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Allows mapping or filtering an upstream value through an emitter.
MathFlowable - Class in hu.akarnokd.rxjava2.math
  Utility methods to work with numerical Flowable sources: sum, min, max and average.
MathObservable - Class in hu.akarnokd.rxjava2.math
  Utility methods to work with numerical Observable sources: sum, min, max and average.
max(Publisher<T>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable
max(Publisher<T>, Comparator<? super T>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable
max(ObservableSource<T>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable
max(ObservableSource<T>, Comparator<? super T>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable
MaybeSubject<T> - Class in hu.akarnokd.rxjava2.subjects
  Represents a hot Maybe-like source and consumer of events similar to Subjects.
merge(Iterable<? extends Nono>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs all Nono sources at once and completes once all of them complete.
merge(Iterable<? extends Nono>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the maximum number of Nono sources at once and completes when all source Nono complete.
merge(Publisher<? extends Nono>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs all Nono sources emitted by the Publisher at once and completes once all of them complete.
merge(Publisher<? extends Nono>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the maximum number of Nono sources emitted by the Publisher at once and completes when all source Nono complete.
merge(Iterable<? extends Perhaps<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources.
merge(Iterable<? extends Perhaps<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources.
merge(Publisher<? extends Perhaps<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources.
merge(Publisher<? extends Perhaps<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources.
merge(Iterable<? extends Solo<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources.
merge(Iterable<? extends Solo<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources.
merge(Publisher<? extends Solo<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources.
merge(Publisher<? extends Solo<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources.
mergeArray(Nono...) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs all Nono sources at once and completes once all of them complete.
mergeArray(int, Nono...) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the maximum number of Nono sources at once and completes when all source Nono complete.
mergeArray(Perhaps<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources.
mergeArray(int, Perhaps<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources.
mergeArray(Solo<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources.
mergeArray(int, Solo<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources.
mergeArrayDelayError(Nono...) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs all Nono sources at once and terminates once all of them terminate, delaying errors in the process.
mergeArrayDelayError(int, Nono...) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the maximum number of Nono sources at once and terminates when all source Nono terminate, delaying errors in the process.
mergeArrayDelayError(Perhaps<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources, delaying errors till all sources terminate.
mergeArrayDelayError(int, Perhaps<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources, delaying errors till all sources terminate.
mergeArrayDelayError(Solo<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources, delaying errors till all sources terminate.
mergeArrayDelayError(int, Solo<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources, delaying errors till all sources terminate.
mergeDelayError(Iterable<? extends Nono>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs all Nono sources at once and terminates once all of them terminate, delaying errors in the process.
mergeDelayError(Iterable<? extends Nono>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the maximum number of Nono sources at once and terminates when all source Nono terminate, delaying errors in the process.
mergeDelayError(Publisher<? extends Nono>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs all Nono sources emitted by the Publisher at once and terminates once all of them terminate, delaying errors in the process.
mergeDelayError(Publisher<? extends Nono>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Runs the maximum number of Nono sources emitted by the Publisher at once and terminates when all source Nono terminate, delaying errors in the process.
mergeDelayError(Iterable<? extends Perhaps<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources, delaying errors till all sources terminate.
mergeDelayError(Iterable<? extends Perhaps<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources, delaying errors till all sources terminate.
mergeDelayError(Publisher<? extends Perhaps<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources, delaying errors till all sources terminate.
mergeDelayError(Publisher<? extends Perhaps<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merge the values in arbitrary order from a sequence of Perhaps sources, delaying errors till all sources terminate.
mergeDelayError(Iterable<? extends Solo<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources, delaying errors till all sources terminate.
mergeDelayError(Iterable<? extends Solo<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources, delaying errors till all sources terminate.
mergeDelayError(Publisher<? extends Solo<? extends T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources, delaying errors till all sources terminate.
mergeDelayError(Publisher<? extends Solo<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merge the values in arbitrary order from a sequence of Solo sources, delaying errors till all sources terminate.
mergeWith(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Merges this Perhaps with another Publisher and emits all their values.
mergeWith(Solo<T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Merges the values of this Solo and the other Solo into a Flowable sequence.
min(Publisher<T>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable
min(Publisher<T>, Comparator<? super T>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable
min(ObservableSource<T>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable
min(ObservableSource<T>, Comparator<? super T>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable

## N

never() - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Returns a Nono that never terminates.
never() - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Returns a Perhaps that never signals any item or terminal event.
never() - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Returns a Solo that never signals an item or terminal event.
Nono - Class in hu.akarnokd.rxjava2.basetypes
  Represents the base reactive class with fluent API for Publisher-based, no-item just onError or onComplete source.
Nono() - Constructor for class hu.akarnokd.rxjava2.basetypes.Nono
NonoProcessor - Class in hu.akarnokd.rxjava2.basetypes
  A hot Nono that signals the terminal event to Subscribers.
now(TimeUnit) - Method in class hu.akarnokd.rxjava2.schedulers.SharedScheduler

## O

ObservableAverageDouble - Class in hu.akarnokd.rxjava2.math
ObservableAverageDouble(ObservableSource<Number>) - Constructor for class hu.akarnokd.rxjava2.math.ObservableAverageDouble
ObservableAverageFloat - Class in hu.akarnokd.rxjava2.math
ObservableAverageFloat(ObservableSource<Number>) - Constructor for class hu.akarnokd.rxjava2.math.ObservableAverageFloat
ObservableSumDouble - Class in hu.akarnokd.rxjava2.math
ObservableSumDouble(ObservableSource<Double>) - Constructor for class hu.akarnokd.rxjava2.math.ObservableSumDouble
ObservableSumFloat - Class in hu.akarnokd.rxjava2.math
ObservableSumFloat(ObservableSource<Float>) - Constructor for class hu.akarnokd.rxjava2.math.ObservableSumFloat
ObservableSumLong - Class in hu.akarnokd.rxjava2.math
ObservableSumLong(ObservableSource<Long>) - Constructor for class hu.akarnokd.rxjava2.math.ObservableSumLong
observeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Observes the onError and onComplete events on the specified Scheduler.
observeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Observe the events of this Perhaps on the specified scheduler.
observeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Returns a Solo that delivers the onNext, onError and onComplete signals from this Solo on the specified scheduler.
offer(T) - Method in class hu.akarnokd.rxjava2.util.SpscOneQueue
offer(T, T) - Method in class hu.akarnokd.rxjava2.util.SpscOneQueue
onAssembly(Nono) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Optionally apply a function to the raw source and return a potentially modified Nono instance.
onAssembly(Perhaps<T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
onAssembly(Solo<T>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
onBackpressureTimeout(long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Buffers the incoming values from upstream up to a maximum timeout if the downstream can't keep up.
onBackpressureTimeout(long, TimeUnit, Scheduler, Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Buffers the incoming values from upstream up to a maximum size or timeout if the downstream can't keep up.
onBackpressureTimeout(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Buffers the incoming values from upstream up to a maximum timeout if the downstream can't keep up, running on a custom scheduler.
onBackpressureTimeout(int, long, TimeUnit, Scheduler, Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Buffers the incoming values from upstream up to a maximum size or timeout if the downstream can't keep up.
onComplete() - Method in class hu.akarnokd.rxjava2.basetypes.NonoProcessor
onComplete() - Method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
onComplete() - Method in class hu.akarnokd.rxjava2.basetypes.SoloProcessor
onComplete() - Method in class hu.akarnokd.rxjava2.subjects.CompletableSubject
onComplete() - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
onError(Throwable) - Method in class hu.akarnokd.rxjava2.basetypes.NonoProcessor
onError(Throwable) - Method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
onError(Throwable) - Method in class hu.akarnokd.rxjava2.basetypes.SoloProcessor
onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.CompletableSubject
onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.SingleSubject
onErrorComplete() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  If this Nono signals an error, signal an onComplete instead.
onErrorComplete() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Completes in case the upstream signals an error.
onErrorFrom(Observer<T>) - Static method in class hu.akarnokd.rxjava2.joins.Plan
  Extracts a method reference to the Observer's `onError` method in the form of an `Consumer`.
onErrorResumeNext(Function<? super Throwable, ? extends Nono>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  If this Nono signals an error, subscribe to the fallback Nono returned by the error handler function.
onErrorResumeNext(Function<? super Throwable, ? extends Perhaps<? extends T>>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  If the upstream signals an error, apply the given function to that Throwable error and resume with the returned Perhaps.
onErrorResumeNext(Function<? super Throwable, ? extends Solo<T>>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  If the upstream signals an error, call a function and subscribe to the Solo it returns.
onErrorResumeWith(Perhaps<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  If the upstream signals an error, switch to the given fallback Perhaps.
onErrorResumeWith(Solo<T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  If the upstream signals an error, switch over to the next Solo and emits its signal instead.
onErrorReturnItem(T) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  If the upstream signals an error, it is replaced by a signal of the given item and normal completion.
onErrorReturnItem(T) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  If the upstream signals an error, signal an item instead.
onNext(Void) - Method in class hu.akarnokd.rxjava2.basetypes.NonoProcessor
onNext(T) - Method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
onNext(T) - Method in class hu.akarnokd.rxjava2.basetypes.SoloProcessor
onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.basetypes.NonoProcessor
onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.basetypes.SoloProcessor
onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subjects.CompletableSubject
onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subjects.SingleSubject
onSuccess(T) - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
onSuccess(T) - Method in class hu.akarnokd.rxjava2.subjects.SingleSubject
orderedMerge(Publisher<T>...) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by their natural order).
orderedMerge(boolean, Publisher<T>...) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by their natural order) and allows delaying any error they may signal.
orderedMerge(boolean, int, Publisher<T>...) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by their natural order), allows delaying any error they may signal and sets the prefetch amount when requesting from these Publishers.
orderedMerge(Comparator<? super T>, Publisher<T>...) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by the Comparator).
orderedMerge(Comparator<? super T>, boolean, Publisher<T>...) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by the Comparator) and allows delaying any error they may signal.
orderedMerge(Comparator<? super T>, boolean, int, Publisher<T>...) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by the Comparator), allows delaying any error they may signal and sets the prefetch amount when requesting from these Publishers.
orderedMerge(Iterable<? extends Publisher<T>>, Comparator<? super T>) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by the Comparator).
orderedMerge(Iterable<? extends Publisher<T>>, Comparator<? super T>, boolean) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by the Comparator) and allows delaying any error they may signal.
orderedMerge(Iterable<? extends Publisher<T>>, Comparator<? super T>, boolean, int) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by the Comparator), allows delaying any error they may signal and sets the prefetch amount when requesting from these Publishers.
orderedMerge(Iterable<? extends Publisher<T>>) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by their natural order).
orderedMerge(Iterable<? extends Publisher<T>>, boolean) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by their natural order) and allows delaying any error they may signal.
orderedMerge(Iterable<? extends Publisher<T>>, boolean, int) - Static method in class hu.akarnokd.rxjava2.operators.Flowables
  Merges the source Publishers in an ordered fashion picking the smallest of the available value from them (determined by their natural order), allows delaying any error they may signal and sets the prefetch amount when requesting from these Publishers.

## P

ParallelFlowable<T> - Class in hu.akarnokd.rxjava2.parallel
  Abstract base class for Parallel publishers that take an array of Subscribers.
ParallelFlowable() - Constructor for class hu.akarnokd.rxjava2.parallel.ParallelFlowable
parallelism() - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Returns the number of expected parallel Subscribers.
ParallelScheduler - Class in hu.akarnokd.rxjava2.schedulers
  Scheduler with a configurable fixed amount of thread-pools.
ParallelScheduler() - Constructor for class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
ParallelScheduler(String) - Constructor for class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
ParallelScheduler(int) - Constructor for class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
ParallelScheduler(int, boolean) - Constructor for class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
ParallelScheduler(int, boolean, int) - Constructor for class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
ParallelScheduler(int, boolean, int, String) - Constructor for class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
ParallelScheduler(int, ThreadFactory) - Constructor for class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
ParallelScheduler(int, ThreadFactory, boolean) - Constructor for class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
Pattern1<T1> - Class in hu.akarnokd.rxjava2.joins
  Represents a join pattern over Observable sequences.
Pattern1(Observable<T1>) - Constructor for class hu.akarnokd.rxjava2.joins.Pattern1
Pattern2<T1,T2> - Class in hu.akarnokd.rxjava2.joins
  Represents a join pattern over observable sequences.
Pattern2(Observable<T1>, Observable<T2>) - Constructor for class hu.akarnokd.rxjava2.joins.Pattern2
Pattern3<T1,T2,T3> - Class in hu.akarnokd.rxjava2.joins
  Represents a join pattern over observable sequences.
Pattern3(Observable<T1>, Observable<T2>, Observable<T3>) - Constructor for class hu.akarnokd.rxjava2.joins.Pattern3
Pattern4<T1,T2,T3,T4> - Class in hu.akarnokd.rxjava2.joins
  Represents a join pattern over observable sequences.
Pattern4(Observable<T1>, Observable<T2>, Observable<T3>, Observable<T4>) - Constructor for class hu.akarnokd.rxjava2.joins.Pattern4
Pattern5<T1,T2,T3,T4,T5> - Class in hu.akarnokd.rxjava2.joins
  Represents a join pattern over observable sequences.
Pattern5(Observable<T1>, Observable<T2>, Observable<T3>, Observable<T4>, Observable<T5>) - Constructor for class hu.akarnokd.rxjava2.joins.Pattern5
Pattern6<T1,T2,T3,T4,T5,T6> - Class in hu.akarnokd.rxjava2.joins
  Represents a join pattern over observable sequences.
Pattern6(Observable<T1>, Observable<T2>, Observable<T3>, Observable<T4>, Observable<T5>, Observable<T6>) - Constructor for class hu.akarnokd.rxjava2.joins.Pattern6
Pattern7<T1,T2,T3,T4,T5,T6,T7> - Class in hu.akarnokd.rxjava2.joins
  Represents a join pattern over observable sequences.
Pattern7(Observable<T1>, Observable<T2>, Observable<T3>, Observable<T4>, Observable<T5>, Observable<T6>, Observable<T7>) - Constructor for class hu.akarnokd.rxjava2.joins.Pattern7
Pattern8<T1,T2,T3,T4,T5,T6,T7,T8> - Class in hu.akarnokd.rxjava2.joins
  Represents a join pattern over observable sequences.
Pattern8(Observable<T1>, Observable<T2>, Observable<T3>, Observable<T4>, Observable<T5>, Observable<T6>, Observable<T7>, Observable<T8>) - Constructor for class hu.akarnokd.rxjava2.joins.Pattern8
Pattern9<T1,T2,T3,T4,T5,T6,T7,T8,T9> - Class in hu.akarnokd.rxjava2.joins
  Represents a join pattern over observable sequences.
Pattern9(Observable<T1>, Observable<T2>, Observable<T3>, Observable<T4>, Observable<T5>, Observable<T6>, Observable<T7>, Observable<T8>, Observable<T9>) - Constructor for class hu.akarnokd.rxjava2.joins.Pattern9
PatternN - Class in hu.akarnokd.rxjava2.joins
  Represents a join pattern over observable sequences.
PatternN(List<Observable<? extends Object>>) - Constructor for class hu.akarnokd.rxjava2.joins.PatternN
PatternN(List<Observable<? extends Object>>, Observable<? extends Object>) - Constructor for class hu.akarnokd.rxjava2.joins.PatternN
Perhaps<T> - Class in hu.akarnokd.rxjava2.basetypes
  A 0-1-error base reactive type, similar to Maybe, implementing the Reactive-Streams Publisher interface.
Perhaps() - Constructor for class hu.akarnokd.rxjava2.basetypes.Perhaps
PerhapsProcessor<T> - Class in hu.akarnokd.rxjava2.basetypes
  A Processor based on the Perhaps type that emits an onNext+onComplete, only onComplete or an onError.
PlainBiFunction<T1,T2,R> - Interface in hu.akarnokd.rxjava2.functions
  A `BiFunction` with suppressed exception on its `PlainBiFunction.apply(Object, Object)` method.
PlainFunction<T,R> - Interface in hu.akarnokd.rxjava2.functions
  A `Function` with suppressed exception on its `PlainFunction.apply(Object)` method.
PlainFunction3<T1,T2,T3,R> - Interface in hu.akarnokd.rxjava2.functions
  A `Function3` with suppressed exception on its `PlainFunction3.apply(Object, Object, Object)` method.
PlainFunction4<T1,T2,T3,T4,R> - Interface in hu.akarnokd.rxjava2.functions
  A `Function4` with suppressed exception on its `PlainFunction4.apply(Object, Object, Object, Object)` method.
PlainFunction5<T1,T2,T3,T4,T5,R> - Interface in hu.akarnokd.rxjava2.functions
  A `Function5` with suppressed exception on its `PlainFunction5.apply(Object, Object, Object, Object, Object)` method.
PlainFunction6<T1,T2,T3,T4,T5,T6,R> - Interface in hu.akarnokd.rxjava2.functions
  A `Function6` with suppressed exception on its `PlainFunction6.apply(Object, Object, Object, Object, Object, Object)` method.
PlainFunction7<T1,T2,T3,T4,T5,T6,T7,R> - Interface in hu.akarnokd.rxjava2.functions
  A `Function7` with suppressed exception on its `PlainFunction7.apply(Object, Object, Object, Object, Object, Object, Object)` method.
PlainFunction8<T1,T2,T3,T4,T5,T6,T7,T8,R> - Interface in hu.akarnokd.rxjava2.functions
  A `Function8` with suppressed exception on its `PlainFunction8.apply(Object, Object, Object, Object, Object, Object, Object, Object)` method.
PlainFunction9<T1,T2,T3,T4,T5,T6,T7,T8,T9,R> - Interface in hu.akarnokd.rxjava2.functions
  A `Function9` with suppressed exception on its `PlainFunction9.apply(Object, Object, Object, Object, Object, Object, Object, Object, Object)` method.
Plan<R> - Class in hu.akarnokd.rxjava2.joins
  Represents an execution plan for join patterns.
Plan() - Constructor for class hu.akarnokd.rxjava2.joins.Plan
poll() - Method in class hu.akarnokd.rxjava2.util.SpscOneQueue

## R

reduce(BiFunction<T, T, T>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Reduces all values within a 'rail' and across 'rails' with a reducer function into a single sequential value.
reduce(Callable<R>, BiFunction<R, T, R>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Reduces all values within a 'rail' to a single value (with a possibly different type) via a reducer function that is initialized on each rail from an initialSupplier value.
repeat() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Repeatedly run this Nono indefinitely.
repeat(long) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Repeatedly run this Nono at most the given number of times.
repeat(BooleanSupplier) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Repeat until the given BooleanSupplier returns true.
repeat() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Repeats this Perhaps indefinitely.
repeat(long) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Repeats this Perhaps at most the given number of times.
repeat(BooleanSupplier) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Repeats this Perhaps until the given boolean supplier returns true when an repeat iteration of this Perhaps completes.
repeat() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Repeats this Solo indefinitely.
repeat(long) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Repeats this Solo at most the given number of times.
repeat(BooleanSupplier) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Repeats this Solo until the given boolean supplier returns true when an repeat iteration of this Solo completes.
repeatWhen(Function<? super Flowable<Object>, ? extends Publisher<?>>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Repeat when the Publisher returned by the handler function signals a value or terminate accordingly.
repeatWhen(Function<? super Flowable<Object>, ? extends Publisher<?>>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Repeats this Perhaps when the Publisher returned by the handler function emits an item or terminates if this Publisher terminates.
repeatWhen(Function<? super Flowable<Object>, ? extends Publisher<?>>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Repeats this Solo when the Publisher returned by the handler function emits an item or terminates if this Publisher terminates.
request(long) - Method in class hu.akarnokd.rxjava2.util.CompositeSubscription
retry() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Repeatedly run this Nono indefinitely if it fails.
retry(long) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Repeatedly run this Nono at most the given number of times if it fails.
retry(Predicate<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Retry a failed Nono if the predicate return true
retry() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Retry this Perhaps indefinitely if it fails.
retry(long) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Retry this Perhaps at most the given number of times if it fails.
retry(Predicate<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Retry this Perhaps if the predicate returns true for the latest failure Throwable.
retry() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Retry this Solo indefinitely if it fails.
retry(long) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Retry this Solo at most the given number of times if it fails.
retry(Predicate<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Retry this Solo if the predicate returns true for the latest failure Throwable.
retryWhen(Function<? super Flowable<Throwable>, ? extends Publisher<?>>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Retry this Nono when the Publisher returned by the handler function signals a normal item or terminate if the Publisher terminates.
retryWhen(Function<? super Flowable<Throwable>, ? extends Publisher<?>>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Retry this Perhaps if the Publisher returned by the handler signals an item in response to the failure Throwable.
retryWhen(Function<? super Flowable<Throwable>, ? extends Publisher<?>>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Retry this solo if the Publisher returned by the handler signals an item in response to the failure Throwable.
runAsync(Scheduler, BiConsumer<? super Subscriber<? super T>, ? super Disposable>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Runs the provided action on the given scheduler and allows propagation of multiple events to the observers of the returned DisposableFlowable.
runAsync(Scheduler, Processor<T, U>, BiConsumer<? super Subscriber<? super T>, ? super Disposable>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Runs the provided action on the given scheduler and allows propagation of multiple events to the observers of the returned DisposableFlowable.
runAsync(Scheduler, BiConsumer<? super Observer<? super T>, ? super Disposable>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Runs the provided action on the given scheduler and allows propagation of multiple events to the observers of the returned DisposableObservable.
runAsync(Scheduler, Subject<T>, BiConsumer<? super Observer<? super T>, ? super Disposable>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Runs the provided action on the given scheduler and allows propagation of multiple events to the observers of the returned DisposableObservable.
runOn(Scheduler) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Specifies where each 'rail' will observe its incoming values with no work-stealing and default prefetch amount.
runOn(Scheduler, int) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Specifies where each 'rail' will observe its incoming values with possibly work-stealing and a given prefetch amount.
RxJavaAssemblyException - Exception in hu.akarnokd.rxjava2.debug
  Holds onto the assembly stacktrace.
RxJavaAssemblyException() - Constructor for exception hu.akarnokd.rxjava2.debug.RxJavaAssemblyException
RxJavaAssemblyTracking - Class in hu.akarnokd.rxjava2.debug
  Utility class to enable and disable tracking of operator application (`source.map().filter()`) by capturing the current stacktrace (warning: very expensive!)

## S

scheduleDirect(Runnable) - Method in class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
scheduleDirect(Runnable, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
scheduleDirect(Runnable) - Method in class hu.akarnokd.rxjava2.schedulers.SharedScheduler
scheduleDirect(Runnable, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.schedulers.SharedScheduler
schedulePeriodicallyDirect(Runnable, long, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
schedulePeriodicallyDirect(Runnable, long, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.schedulers.SharedScheduler
SelfComparator - Enum in hu.akarnokd.rxjava2.util
  Comparator that compares Comparables.
sequential() - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Merges the values from each 'rail' in a round-robin or same-order fashion and exposes it as a regular Publisher sequence, running with a default prefetch value for the rails.
sequential(int) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Merges the values from each 'rail' in a round-robin or same-order fashion and exposes it as a regular Publisher sequence, running with a give prefetch value for the rails.
setOnAssemblyHandler(Function<Nono, Nono>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Sets the onAssembly handler.
setOnAssemblyHandler(Function<Perhaps<T>, Perhaps<T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Set the onAssembly handler.
setOnAssemblyHandler(Function<Solo<T>, Solo<T>>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Set the onAssembly handler.
SharedScheduler - Class in hu.akarnokd.rxjava2.schedulers
  A Scheduler implementation that uses one of the Workers from another Scheduler and shares the access to it through its own Workers.
SharedScheduler(Scheduler) - Constructor for class hu.akarnokd.rxjava2.schedulers.SharedScheduler
  Constructs a SharedScheduler and asks for a Worker from the provided other Scheduler.
SharedScheduler(Scheduler.Worker) - Constructor for class hu.akarnokd.rxjava2.schedulers.SharedScheduler
  Constructs a SharedScheduler and uses the Worker instance provided.
shutdown() - Method in class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
shutdown() - Method in class hu.akarnokd.rxjava2.schedulers.SharedScheduler
SingleSubject<T> - Class in hu.akarnokd.rxjava2.subjects
  Represents a hot Single-like source and consumer of events similar to Subjects.
SneakyThrows - Class in hu.akarnokd.rxjava2.util
  Utility class to throw arbitrary Throwables.
Solo<T> - Class in hu.akarnokd.rxjava2.basetypes
  Base class with fluent API for supporting a Publisher with exactly 1 element or an error.
Solo() - Constructor for class hu.akarnokd.rxjava2.basetypes.Solo
SoloProcessor<T> - Class in hu.akarnokd.rxjava2.basetypes
  A Processor based on the Solo type that emits an onNext+onComplete or an onError.
sorted(Comparator<? super T>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Sorts the 'rails' of this ParallelFlowable and returns a Publisher that sequentially picks the smallest next value from the rails.
sorted(Comparator<? super T>, int) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Sorts the 'rails' of this ParallelFlowable and returns a Publisher that sequentially picks the smallest next value from the rails.
spanout(long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Inserts a time delay between emissions from the upstream source.
spanout(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Inserts a time delay between emissions from the upstream source.
spanout(long, long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Inserts a time delay between emissions from the upstream source, including an initial delay.
spanout(long, long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Inserts a time delay between emissions from the upstream source, including an initial delay.
spanout(long, TimeUnit, boolean) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Inserts a time delay between emissions from the upstream source, including an initial delay.
spanout(long, TimeUnit, Scheduler, boolean) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Inserts a time delay between emissions from the upstream source, including an initial delay.
spanout(long, long, TimeUnit, boolean) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Inserts a time delay between emissions from the upstream source, including an initial delay.
spanout(long, long, TimeUnit, Scheduler, boolean) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Inserts a time delay between emissions from the upstream source, including an initial delay.
split(Pattern) - Static method in class hu.akarnokd.rxjava2.string.StringFlowable
  Splits the input sequence of strings based on a pattern even across subsequent elements if needed.
split(Pattern, int) - Static method in class hu.akarnokd.rxjava2.string.StringFlowable
  Splits the input sequence of strings based on a pattern even across subsequent elements if needed.
split(String) - Static method in class hu.akarnokd.rxjava2.string.StringFlowable
  Splits the input sequence of strings based on a pattern even across subsequent elements if needed.
split(String, int) - Static method in class hu.akarnokd.rxjava2.string.StringFlowable
  Splits the input sequence of strings based on a pattern even across subsequent elements if needed.
SpscOneQueue<T> - Class in hu.akarnokd.rxjava2.util
  A single-producer single-consumer queue with exactly one slot of value.
SpscOneQueue() - Constructor for class hu.akarnokd.rxjava2.util.SpscOneQueue
stacktrace() - Method in exception hu.akarnokd.rxjava2.debug.RxJavaAssemblyException
  Returns the captured and filtered stacktrace.
start(Callable<? extends T>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Invokes the specified function asynchronously and returns an Flowable that emits the result.
start(Callable<? extends T>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Invokes the specified function asynchronously on the specified Scheduler and returns an Flowable that emits the result.
start(Callable<? extends T>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Invokes the specified function asynchronously and returns an Observable that emits the result.
start(Callable<? extends T>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Invokes the specified function asynchronously on the specified Scheduler and returns an Observable that emits the result.
start() - Method in class hu.akarnokd.rxjava2.schedulers.ParallelScheduler
startFuture(Callable<? extends Future<? extends T>>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Invokes the asynchronous function immediately, surfacing the result through an Observable.
startFuture(Callable<? extends Future<? extends T>>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Invokes the asynchronous function immediately, surfacing the result through an Observable and waits on the specified Scheduler.
startFuture(Callable<? extends Future<? extends T>>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Invokes the asynchronous function immediately, surfacing the result through an Observable.
startFuture(Callable<? extends Future<? extends T>>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Invokes the asynchronous function immediately, surfacing the result through an Observable and waits on the specified Scheduler.
StatementFlowable - Class in hu.akarnokd.rxjava2.expr
  Imperative statements expressed as Flowable operators.
StatementObservable - Class in hu.akarnokd.rxjava2.expr
  Imperative statements expressed as Observable operators.
StringFlowable - Class in hu.akarnokd.rxjava2.string
  Utility class for String operations with `Flowable`s.
StringObservable - Class in hu.akarnokd.rxjava2.string
  Utility class for String operations with `Observable`s.
subscribe(Subscriber<? super Void>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
subscribe() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Subscribe to this Nono and ignore the events it produces.
subscribe(Action) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Subscribe to this Nono and execute the given action if this Nono completes.
subscribe(Action, Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Subscribe to this Nono and execute the given action if this Nono completes or call the consumer if this Nono terminates with an error.
subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
subscribe() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Subscribe to this Perhaps and ignore any signal it produces.
subscribe(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Subscribes to this Perhaps and calls the onNext if this Perhaps succeeds.
subscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Subscribes to this Perhaps and calls the appropriate callback for the resulting signal.
subscribe(Consumer<? super T>, Consumer<? super Throwable>, Action) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Subscribes to this Perhaps and calls the appropriate callback for the resulting signal.
subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
subscribe() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Subscribe to this Solo and ignore any signal it produces.
subscribe(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Subscribes to this Solo and calls the onNext if this Solo succeeds.
subscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Subscribes to this Solo and calls the appropriate callback for the resulting signal.
subscribe(Consumer<? super T>, Consumer<? super Throwable>, Action) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Subscribes to this Solo and calls the appropriate callback for the resulting signal.
subscribe(Subscriber<? super T>[]) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Subscribes an array of Subscribers to this ParallelFlowable and triggers the execution chain for all 'rails'.
subscribeActual(Subscriber<? super Void>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Implement this method to signal the terminal events to the given subscriber.
subscribeActual(Subscriber<? super Void>) - Method in class hu.akarnokd.rxjava2.basetypes.NonoProcessor
subscribeActual(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Implement this method to react to a Subscriber subscribing to this Perhaps.
subscribeActual(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.PerhapsProcessor
subscribeActual(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Implement this method to react to a Subscriber subscribing to this Solo.
subscribeActual(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.basetypes.SoloProcessor
subscribeActual(Observer<? super Double>) - Method in class hu.akarnokd.rxjava2.math.ObservableAverageDouble
subscribeActual(Observer<? super Float>) - Method in class hu.akarnokd.rxjava2.math.ObservableAverageFloat
subscribeActual(Observer<? super Double>) - Method in class hu.akarnokd.rxjava2.math.ObservableSumDouble
subscribeActual(Observer<? super Float>) - Method in class hu.akarnokd.rxjava2.math.ObservableSumFloat
subscribeActual(Observer<? super Long>) - Method in class hu.akarnokd.rxjava2.math.ObservableSumLong
subscribeActual(CompletableObserver) - Method in class hu.akarnokd.rxjava2.subjects.CompletableSubject
subscribeActual(MaybeObserver<? super T>) - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject
subscribeActual(SingleObserver<? super T>) - Method in class hu.akarnokd.rxjava2.subjects.SingleSubject
subscribeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Subscribes to the upstream on the specified Scheduler.
subscribeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Subscribes to the upstream Perhaps and requests on the specified Scheduler.
subscribeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Returns a Solo that subscribes to this Solo on the specified scheduler and makes sure downstream requests are forwarded there as well.
subscribeWith(E) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Subscribe with the given subscriber and return the same subscriber, allowing chaining methods on it or fluently reusing the instance.
subscribeWith(E) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Subscribe with a Subscriber (subclass) and return it as is.
subscribeWith(E) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Subscribe with a Subscriber (subclass) and return it as is.
sumDouble(Publisher<Double>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable
sumDouble(ObservableSource<Double>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable
sumFloat(Publisher<Float>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable
sumFloat(ObservableSource<Float>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable
sumInt(Publisher<Integer>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable
sumInt(ObservableSource<Integer>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable
sumLong(Publisher<Long>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable
sumLong(ObservableSource<Long>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable
Supplier<T> - Interface in hu.akarnokd.rxjava2.functions
  A `Callable` with suppressed exception on its `Supplier.call()` method.
switchCase(Callable<? extends K>, Map<? super K, ? extends Publisher<? extends R>>) - Static method in class hu.akarnokd.rxjava2.expr.StatementFlowable
  Return a particular one of several possible Observables based on a case selector.
switchCase(Callable<? extends K>, Map<? super K, ? extends Publisher<? extends R>>, Scheduler) - Static method in class hu.akarnokd.rxjava2.expr.StatementFlowable
  Return a particular one of several possible Observables based on a case selector and run it on the designated scheduler.
switchCase(Callable<? extends K>, Map<? super K, ? extends Publisher<? extends R>>, Publisher<? extends R>) - Static method in class hu.akarnokd.rxjava2.expr.StatementFlowable
  Return a particular one of several possible Observables based on a case selector, or a default Flowable if the case selector does not map to a particular one.
switchCase(Callable<? extends K>, Map<? super K, ? extends ObservableSource<? extends R>>) - Static method in class hu.akarnokd.rxjava2.expr.StatementObservable
  Return a particular one of several possible Observables based on a case selector.
switchCase(Callable<? extends K>, Map<? super K, ? extends ObservableSource<? extends R>>, Scheduler) - Static method in class hu.akarnokd.rxjava2.expr.StatementObservable
  Return a particular one of several possible Observables based on a case selector and run it on the designated scheduler.
switchCase(Callable<? extends K>, Map<? super K, ? extends ObservableSource<? extends R>>, ObservableSource<? extends R>) - Static method in class hu.akarnokd.rxjava2.expr.StatementObservable
  Return a particular one of several possible Observables based on a case selector, or a default Observable if the case selector does not map to a particular one.
switchIfEmpty(Perhaps<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Switch to the other Perhaps if this Perhaps is empty.

## T

takeUntil(Publisher<?>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Run this Nono and cancel it when the other Publisher signals an item or completes.
takeUntil(Publisher<?>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Try consuming this Perhaps until the other Publisher signals an item or completes which then completes the Perhaps.
takeUntil(Publisher<?>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Signal a NoSuchElementException if the other signals before this Solo signals.
test() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Create a TestSubscriber, subscribe it to this Nono and return the TestSubscriber itself.
test(boolean) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Create a TestSubscriber, optionally cancel it, subscribe it to this Nono and return the TestSubscriber itself.
test() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Creates a TestSubscriber and subscribes it to this Perhaps.
test(boolean) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Creates a TestSubscriber, optionally cancels it, and subscribes it to this Perhaps.
test(long) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Creates a TestSubscriber with the given initial request and subscribes it to this Perhaps.
test(long, boolean) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Creates a TestSubscriber with the given initial request, optionally cancels it, and subscribes it to this Perhaps.
test() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Creates a TestSubscriber and subscribes it to this Solo.
test(boolean) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Creates a TestSubscriber, optionally cancels it, and subscribes it to this Solo.
test(long) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Creates a TestSubscriber with the given initial request and subscribes it to this Solo.
test(long, boolean) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Creates a TestSubscriber with the given initial request, optionally cancels it, and subscribes it to this Solo.
then(Function<? super T, ? extends R>) - Method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Matches when the Observable has an available item and projects the item by invoking the selector function.
then(Function<? super T1, ? extends R>) - Method in class hu.akarnokd.rxjava2.joins.Pattern1
  Matches when all observable sequences have an available element and projects the elements by invoking the selector function.
then(BiFunction<T1, T2, R>) - Method in class hu.akarnokd.rxjava2.joins.Pattern2
  Matches when all observable sequences have an available element and projects the elements by invoking the selector function.
then(Function3<T1, T2, T3, R>) - Method in class hu.akarnokd.rxjava2.joins.Pattern3
  Matches when all observable sequences have an available element and projects the elements by invoking the selector function.
then(Function4<T1, T2, T3, T4, R>) - Method in class hu.akarnokd.rxjava2.joins.Pattern4
  Matches when all observable sequences have an available element and projects the elements by invoking the selector function.
then(Function5<T1, T2, T3, T4, T5, R>) - Method in class hu.akarnokd.rxjava2.joins.Pattern5
  Matches when all observable sequences have an available element and projects the elements by invoking the selector function.
then(Function6<T1, T2, T3, T4, T5, T6, R>) - Method in class hu.akarnokd.rxjava2.joins.Pattern6
  Matches when all observable sequences have an available element and projects the elements by invoking the selector function.
then(Function7<T1, T2, T3, T4, T5, T6, T7, R>) - Method in class hu.akarnokd.rxjava2.joins.Pattern7
  Matches when all observable sequences have an available element and projects the elements by invoking the selector function.
then(Function8<T1, T2, T3, T4, T5, T6, T7, T8, R>) - Method in class hu.akarnokd.rxjava2.joins.Pattern8
  Matches when all observable sequences have an available element and projects the elements by invoking the selector function.
then(Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R>) - Method in class hu.akarnokd.rxjava2.joins.Pattern9
  Matches when all observable sequences have an available element and projects the elements by invoking the selector function.
then(Function<? super Object[], R>) - Method in class hu.akarnokd.rxjava2.joins.PatternN
  Matches when all observable sequences have an available element and projects the elements by invoking the selector function.
timeout(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Signals a TimeoutException if this Nono doesn't complete within the specified timeout.
timeout(long, TimeUnit, Nono) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Switches to the fallback Nono if this Nono doesn't complete within the specified timeout.
timeout(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Signals a TimeoutException if this Nono doesn't complete within the specified timeout.
timeout(long, TimeUnit, Scheduler, Nono) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Switches to the fallback Nono if this Nono doesn't complete within the specified timeout.
timeout(Publisher<?>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Signal a TimeoutException if the other Publisher signals an item or completes before this Nono completes.
timeout(Publisher<?>, Nono) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Switch to the fallback Nono if the other Publisher signals an item or completes before this Nono completes.
timeout(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Signals a TimeoutException if the Perhaps doesn't signal an item within the specified time.
timeout(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Signals a TimeoutException if the Perhaps doesn't signal an item or (terminates) within the specified time.
timeout(long, TimeUnit, Perhaps<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Switch to the fallback Perhaps if this Perhaps doesn't signal an item (or terminates) within the specified time.
timeout(long, TimeUnit, Scheduler, Perhaps<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Switch to the fallback Perhaps if this Perhaps doesn't signal an item (or terminates) within the specified time.
timeout(Publisher<?>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Signal a TimeoutException if the other Publisher signals an item or completes before this Perhaps does.
timeout(Publisher<?>, Perhaps<? extends T>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Switch to the fallback Perhaps if the other Publisher signals an item or completes before this Perhaps does.
timeout(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Signal a TimeoutException if there is no item from this Solo within the given timeout time.
timeout(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Signal a TimeoutException if there is no item from this Solo within the given timeout time, running on the specified scheduler.
timeout(long, TimeUnit, Solo<T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Fall back to another Solo if this Solo doesn't signal within the given time period.
timeout(long, TimeUnit, Scheduler, Solo<T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Fall back to another Solo if this Solo doesn't signal within the given time period, waiting on the specified scheduler.
timeout(Publisher<?>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Signal a TimeoutException if the other Publisher signals or completes before this Solo signals a value.
timeout(Publisher<?>, Solo<T>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Fall back to another Solo if the other Publisher signals or completes before this Solo signals a value.
timer(long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Completes after the specified amount of time on the computation scheduler.
timer(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Completes after the specified amount of time on the specified scheduler.
timer(long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Signals a 0L after the specified amount of time has passed since subscription.
timer(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Signals a 0L after the specified amount of time has passed since subscription on the specified scheduler.
timer(long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Signals a 0L after the specified amount of time has passed since subscription.
timer(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Signals a 0L after the specified amount of time has passed since subscription on the specified scheduler.
to(Function<? super Nono, R>) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Fluently convert this Nono via a function callback into some type.
to(Function<? super Perhaps<T>, R>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Applies the function, fluently to this Perhaps and returns the value it returns.
to(Function<? super Solo<T>, R>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Applies the function, fluently to this Solo and returns the value it returns.
to(Function<? super ParallelFlowable<T>, U>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Perform a fluent transformation to a value via a converter function which receives this ParallelFlowable.
toAsync(Action) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through a Flowable.
toAsync(Callable<? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through a Flowable.
toAsync(Consumer<? super T1>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through a Flowable.
toAsync(Function<? super T1, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through a Flowable.
toAsync(BiConsumer<? super T1, ? super T2>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through a Flowable.
toAsync(BiFunction<? super T1, ? super T2, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through a Flowable.
toAsync(Consumer3<? super T1, ? super T2, ? super T3>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function3<? super T1, ? super T2, ? super T3, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer4<? super T1, ? super T2, ? super T3, ? super T4>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Action, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through a Flowable.
toAsync(Callable<? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through a Flowable.
toAsync(Consumer<? super T1>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through a Flowable.
toAsync(Function<? super T1, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through a Flowable.
toAsync(BiConsumer<? super T1, ? super T2>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through a Flowable.
toAsync(BiFunction<? super T1, ? super T2, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through a Flowable.
toAsync(Consumer3<? super T1, ? super T2, ? super T3>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function3<? super T1, ? super T2, ? super T3, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer4<? super T1, ? super T2, ? super T3, ? super T4>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Consumer9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsync(Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsync(Action) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through a Observable.
toAsync(Callable<? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through a Observable.
toAsync(Consumer<? super T1>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through a Observable.
toAsync(Function<? super T1, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through a Observable.
toAsync(BiConsumer<? super T1, ? super T2>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through a Observable.
toAsync(BiFunction<? super T1, ? super T2, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through a Observable.
toAsync(Consumer3<? super T1, ? super T2, ? super T3>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function3<? super T1, ? super T2, ? super T3, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer4<? super T1, ? super T2, ? super T3, ? super T4>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Action, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through a Observable.
toAsync(Callable<? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through a Observable.
toAsync(Consumer<? super T1>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through a Observable.
toAsync(Function<? super T1, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through a Observable.
toAsync(BiConsumer<? super T1, ? super T2>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through a Observable.
toAsync(BiFunction<? super T1, ? super T2, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through a Observable.
toAsync(Consumer3<? super T1, ? super T2, ? super T3>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function3<? super T1, ? super T2, ? super T3, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer4<? super T1, ? super T2, ? super T3, ? super T4>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsync(Consumer9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsync(Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsyncArray(Consumer<? super Object[]>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsyncArray(Function<? super Object[], ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsyncArray(Consumer<? super Object[]>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous action call into an asynchronous function call through an Flowable.
toAsyncArray(Function<? super Object[], ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncFlowable
  Convert a synchronous function call into an asynchronous function call through an Flowable.
toAsyncArray(Consumer<? super Object[]>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsyncArray(Function<? super Object[], ? extends R>) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toAsyncArray(Consumer<? super Object[]>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous action call into an asynchronous function call through an Observable.
toAsyncArray(Function<? super Object[], ? extends R>, Scheduler) - Static method in class hu.akarnokd.rxjava2.async.AsyncObservable
  Convert a synchronous function call into an asynchronous function call through an Observable.
toCompletable() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Convert this Nono instance into a Completable.
toFlowable() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Convert this Nono instance into a Flowable that only terminates.
toFlowable() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Convert this Perhaps into a Flowable.
toFlowable() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Converts this Solo into a Flowable.
toFuture() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Converts this Nono into a Future and signals its single value.
toFuture() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Converts this Perhaps into a Future and signals its single value or null if this Perhaps is empty.
toFuture() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Converts this Solo into a Future and signals its single value.
toMaybe() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Convert this Nono instance into a Maybe that only terminates.
toMaybe() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Convert this Perhaps into a Maybe.
toObservable() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Convert this Nono instance into an Observable that only terminates.
toObservable() - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Convert this Perhaps into an Observable.
toObservable() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Converts this Solo into an Observable.
toObservable() - Method in class hu.akarnokd.rxjava2.joins.JoinObservable
toPerhaps() - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  Convert this Nono instance into a Perhaps that only terminates.
toSingle() - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Converts this Soli into a Single.
toSortedList(Comparator<? super T>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Sorts the 'rails' according to the comparator and returns a full sorted list as a Publisher.
toSortedList(Comparator<? super T>, int) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Sorts the 'rails' according to the comparator and returns a full sorted list as a Publisher.

## U

unsubscribeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Nono
  If the downstream cancels the sequence, the cancellation towards the upstream will happen on the specified Scheduler.
unsubscribeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  If the downstream cancels, the upstream is cancelled on the specified scheduler.
unsubscribeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Returns a Solo which when cancelled, cancels this Solo on the specified scheduler.
using(Callable<R>, Function<? super R, ? extends Nono>, Consumer<? super R>) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Generate a resource and a Nono based on that resource and then dispose that resource eagerly when the Nono terminates or the downstream cancels the sequence.
using(Callable<R>, Function<? super R, ? extends Nono>, Consumer<? super R>, boolean) - Static method in class hu.akarnokd.rxjava2.basetypes.Nono
  Generate a resource and a Nono based on that resource and then dispose that resource optionally eagerly when the Nono terminates or the downstream cancels the sequence.
using(Callable<R>, Function<? super R, ? extends Perhaps<? extends T>>, Consumer<? super R>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Generate a resource and a Perhaps based on that resource and then dispose that resource eagerly when the Perhaps terminates or the downstream cancels the sequence.
using(Callable<R>, Function<? super R, ? extends Perhaps<? extends T>>, Consumer<? super R>, boolean) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Generate a resource and a Perhaps based on that resource and then dispose that resource eagerly when the Perhaps terminates or the downstream cancels the sequence.
using(Callable<R>, Function<? super R, ? extends Solo<T>>, Consumer<? super R>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Generate a resource and a Solo based on that resource and then dispose that resource eagerly when the Solo terminates or the downstream cancels the sequence.
using(Callable<R>, Function<? super R, ? extends Solo<T>>, Consumer<? super R>, boolean) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Generate a resource and a Solo based on that resource and then dispose that resource eagerly when the Solo terminates or the downstream cancels the sequence.

## V

validate(Subscriber<?>[]) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable
  Validates the number of subscribers and returns true if their number matches the parallelism level of this ParallelFlowable.
valueOf(String) - Static method in enum hu.akarnokd.rxjava2.async.AnyValue
  Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum hu.akarnokd.rxjava2.util.AlwaysFalseBooleanSupplier
  Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum hu.akarnokd.rxjava2.util.AlwaysTrueBooleanSupplier
  Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum hu.akarnokd.rxjava2.util.SelfComparator
  Returns the enum constant of this type with the specified name.
values() - Static method in enum hu.akarnokd.rxjava2.async.AnyValue
  Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum hu.akarnokd.rxjava2.util.AlwaysFalseBooleanSupplier
  Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum hu.akarnokd.rxjava2.util.AlwaysTrueBooleanSupplier
  Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum hu.akarnokd.rxjava2.util.SelfComparator
  Returns an array containing the constants of this enum type, in the order they are declared.
valve(Publisher<Boolean>) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Relays values until the other Publisher signals false and resumes if the other Publisher signals true again, like closing and opening a valve and not losing any items from the main source.
valve(Publisher<Boolean>, boolean) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Relays values until the other Publisher signals false and resumes if the other Publisher signals true again, like closing and opening a valve and not losing any items from the main source and starts with the specivied valve state.
valve(Publisher<Boolean>, boolean, int) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers
  Relays values until the other Publisher signals false and resumes if the other Publisher signals true again, like closing and opening a valve and not losing any items from the main source and starts with the specivied valve state and the specified buffer size hint.

## W

when(Iterable<? extends Plan<R>>) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Joins together the results from several patterns via their plans.
when(Plan<R>...) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Joins together the results from several patterns via their plans.
when(Plan<R>) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Joins the results from a pattern via its plan.
when(Plan<R>, Plan<R>) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Joins together the results from two patterns via their plans.
when(Plan<R>, Plan<R>, Plan<R>) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Joins together the results from three patterns via their plans.
when(Plan<R>, Plan<R>, Plan<R>, Plan<R>) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Joins together the results from four patterns via their plans.
when(Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Joins together the results from five patterns via their plans.
when(Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Joins together the results from six patterns via their plans.
when(Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Joins together the results from seven patterns via their plans.
when(Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Joins together the results from eight patterns via their plans.
when(Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>, Plan<R>) - Static method in class hu.akarnokd.rxjava2.joins.JoinObservable
  Joins together the results from nine patterns via their plans.
whileDo(Publisher<? extends T>, BooleanSupplier) - Static method in class hu.akarnokd.rxjava2.expr.StatementFlowable
  Return an Flowable that re-emits the emissions from the source Flowable as long as the condition is true before the first or subsequent subscribe() calls.
whileDo(ObservableSource<? extends T>, BooleanSupplier) - Static method in class hu.akarnokd.rxjava2.expr.StatementObservable
  Return an Observable that re-emits the emissions from the source Observable as long as the condition is true before the first or subsequent subscribe() calls.
wrap(Processor<T, T>) - Static method in class hu.akarnokd.rxjava2.processors.FlowableProcessors
  Wraps an arbitrary Reactive-Streams `Processor` into a `FlowableProcessor`, relaying the onXXX and subscribe() calls to it and providing a rich fluent API on top.

## Z

zip(Iterable<? extends Perhaps<? extends T>>, Function<? super Object[], ? extends R>) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Combines the Perhaps values of all the sources via a zipper function into a single resulting value.
zip(Iterable<? extends Solo<? extends T>>, Function<? super Object[], ? extends R>) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Combines the solo values of all the sources via a zipper function into a single resulting value.
zipArray(Function<? super Object[], ? extends R>, Perhaps<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Combines the Perhaps values of all the sources via a zipper function into a single resulting value.
zipArray(Function<? super Object[], ? extends R>, Solo<? extends T>...) - Static method in class hu.akarnokd.rxjava2.basetypes.Solo
  Combines the solo values of all the sources via a zipper function into a single resulting value.
zipWith(Perhaps<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class hu.akarnokd.rxjava2.basetypes.Perhaps
  Zips the value of this Perhaps with the other Perhaps through a BiFunction.
zipWith(Solo<U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class hu.akarnokd.rxjava2.basetypes.Solo
  Combines the values of this and the other Solo via a BiFunction.

A B C D E F G H I J L M N O P R S T U V W Z