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

A

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

characters(CharSequence) - Static method in class hu.akarnokd.rxjava2.string.StringFlowable

characters(CharSequence) - Static method in class hu.akarnokd.rxjava2.string.StringObservable

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.

D

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(Consumer<? super Subscription>) - Method in class hu.akarnokd.rxjava2.parallel.ParallelFlowable

Call the specified callback when a 'rail' receives a Subscription from its upstream.

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.

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.

FlowableCharSequence - Class in hu.akarnokd.rxjava2.string

Streams the characters of a string.

FlowableCharSequence(CharSequence) - Constructor for class hu.akarnokd.rxjava2.string.FlowableCharSequence

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.

H

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

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

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

ObservableCharSequence - Class in hu.akarnokd.rxjava2.string

ObservableCharSequence(CharSequence) - Constructor for class hu.akarnokd.rxjava2.string.ObservableCharSequence

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

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.

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.

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.

StringFlowable - Class in hu.akarnokd.rxjava2.string

StringObservable - Class in hu.akarnokd.rxjava2.string

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(Subscriber<? super Integer>) - Method in class hu.akarnokd.rxjava2.string.FlowableCharSequence

subscribeActual(Observer<? super Integer>) - Method in class hu.akarnokd.rxjava2.string.ObservableCharSequence

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

T

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.

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

Returns the enum constant of this type with the specified name.

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.

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