A C D F G H I J M 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.

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

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

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.

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

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.

F

filter(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable

Filters the source values on each 'rail'.

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.

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.

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.

G

getAsBoolean() - Method in enum hu.akarnokd.rxjava2.util.AlwaysFalseBooleanSupplier

getAsBoolean() - Method in enum hu.akarnokd.rxjava2.util.AlwaysTrueBooleanSupplier

H

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

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.parallel - package hu.akarnokd.rxjava2.parallel

hu.akarnokd.rxjava2.string - package hu.akarnokd.rxjava2.string

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

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

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

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.

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.

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

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 Subscription>) - 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 StoppableObservable.

runAsync(Scheduler, Processor<T, U>, BiConsumer<? super Subscriber<? super T>, ? super Subscription>) - 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 StoppableObservable.

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.

S

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.

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.

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

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.

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

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.

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.

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.

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

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.

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