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

A

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

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

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

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

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

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

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

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.

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.

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

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

call() - Method in interface hu.akarnokd.rxjava2.functions.Supplier

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.

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<T> - Class in hu.akarnokd.rxjava2.subjects

Represents a hot Completable-like source and consumer of events similar to Subjects.

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.

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.

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() - 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

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.

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.parallel.ParallelFlowable

Call the specified consumer with the current element passing through any 'rail' after it has been delivered to downstream within the rail.

doAfterTerminated(Action) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable

Run the specified Action when a 'rail' completes or signals an error.

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.parallel.ParallelFlowable

Run the specified Action when a 'rail' completes.

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.parallel.ParallelFlowable

Call the specified consumer with the current element passing through any 'rail'.

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

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.

F

fillInStackTrace() - Method in exception hu.akarnokd.rxjava2.debug.RxJavaAssemblyException

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

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.

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.

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

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

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

hu.akarnokd.rxjava2.async - package hu.akarnokd.rxjava2.async

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.

instance() - Static method in enum hu.akarnokd.rxjava2.util.SelfComparator

J

JoinObservable<T> - Class in hu.akarnokd.rxjava2.joins

Represents an observable that supports join operations.

M

map(Function<? super T, ? extends R>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable

Maps the source values on each 'rail' to another value.

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.

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

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

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.subjects.CompletableSubject

onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.MaybeSubject

onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.SingleSubject

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.

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

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

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.

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.

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.

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.

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 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(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

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.

T

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.

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.

toObservable() - Method in class hu.akarnokd.rxjava2.joins.JoinObservable

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.

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.

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