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

Consum the input parameters.

accept(T1, T2, T3, T4) - Method in interface hu.akarnokd.rxjava2.functions.Consumer4

Consum the input parameters.

accept(T1, T2, T3, T4, T5) - Method in interface hu.akarnokd.rxjava2.functions.Consumer5

Consum the input parameters.

accept(T1, T2, T3, T4, T5, T6) - Method in interface hu.akarnokd.rxjava2.functions.Consumer6

Consum the input parameters.

accept(T1, T2, T3, T4, T5, T6, T7) - Method in interface hu.akarnokd.rxjava2.functions.Consumer7

Consum the input parameters.

accept(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface hu.akarnokd.rxjava2.functions.Consumer8

Consum the input parameters.

accept(T1, T2, T3, T4, T5, T6, T7, T8, T9) - Method in interface hu.akarnokd.rxjava2.functions.Consumer9

Consum the input parameters.

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.

every(long) - Static method in class hu.akarnokd.rxjava2.operators.FlowableTransformers

Relays every Nth item from upstream.

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.

repeat(T) - Static method in class hu.akarnokd.rxjava2.operators.Flowables

Repeats a scalar value indefinitely.

repeatCallable(Callable<T>) - Static method in class hu.akarnokd.rxjava2.operators.Flowables

Repeatedly calls the given Callable to produce items indefinitely.

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 Flowables.

StringObservable - Class in hu.akarnokd.rxjava2.string

Utility class for String operations with Observables.

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