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

A

actual - Variable in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

add(T) - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

add(T) - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

addAll(Collection<? extends T>) - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

addAll(Collection<? extends T>) - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

averageDouble(Publisher<? extends Number>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable

averageDouble(ObservableConsumable<? 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(ObservableConsumable<? extends Number>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable

B

BaseIntQueueDisposable<T> - Class in hu.akarnokd.rxjava2.util

BaseIntQueueDisposable() - Constructor for class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

BaseQueueDisposable<T> - Class in hu.akarnokd.rxjava2.util

BaseQueueDisposable() - Constructor for class hu.akarnokd.rxjava2.util.BaseQueueDisposable

C

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

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

clear() - Method in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

compare(Comparable, Comparable) - Method in enum hu.akarnokd.rxjava2.util.SelfComparator

complete(R) - Method in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

contains(Object) - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

contains(Object) - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

containsAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

containsAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

D

DeferredScalarObserver<T,R> - Class in hu.akarnokd.rxjava2.util

A subscriber that is unbounded-in and can generate 0 or 1 resulting value.

DeferredScalarObserver(Observer<? super R>) - Constructor for class hu.akarnokd.rxjava2.util.DeferredScalarObserver

DeferredScalarSubscriber<T,R> - Class in hu.akarnokd.rxjava2.util

A subscriber that is unbounded-in and can generate 0 or 1 resulting value.

DeferredScalarSubscriber(Subscriber<? super R>) - Constructor for class hu.akarnokd.rxjava2.util.DeferredScalarSubscriber

dispose() - Method in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

E

element() - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

element() - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

F

FlowableCharSequence - Class in hu.akarnokd.rxjava2.string

Streams the characters of a string.

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

fusionState - Variable in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

H

hasValue - Variable in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

hasValue - Variable in class hu.akarnokd.rxjava2.util.DeferredScalarSubscriber

hu.akarnokd.rxjava2.math - package hu.akarnokd.rxjava2.math

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

isDisposed() - Method in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

isEmpty() - Method in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

iterator() - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

iterator() - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

M

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(ObservableConsumable<T>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable

max(ObservableConsumable<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(ObservableConsumable<T>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable

min(ObservableConsumable<T>, Comparator<? super T>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable

O

ObservableAverageDouble - Class in hu.akarnokd.rxjava2.math

ObservableAverageDouble(ObservableConsumable<Number>) - Constructor for class hu.akarnokd.rxjava2.math.ObservableAverageDouble

ObservableAverageFloat - Class in hu.akarnokd.rxjava2.math

ObservableAverageFloat(ObservableConsumable<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(ObservableConsumable<Double>) - Constructor for class hu.akarnokd.rxjava2.math.ObservableSumDouble

ObservableSumFloat - Class in hu.akarnokd.rxjava2.math

ObservableSumFloat(ObservableConsumable<Float>) - Constructor for class hu.akarnokd.rxjava2.math.ObservableSumFloat

ObservableSumLong - Class in hu.akarnokd.rxjava2.math

ObservableSumLong(ObservableConsumable<Long>) - Constructor for class hu.akarnokd.rxjava2.math.ObservableSumLong

offer(T) - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

offer(T) - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

onComplete() - Method in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

onComplete() - Method in class hu.akarnokd.rxjava2.util.DeferredScalarSubscriber

onError(Throwable) - Method in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

onError(Throwable) - Method in class hu.akarnokd.rxjava2.util.DeferredScalarSubscriber

onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.util.DeferredScalarSubscriber

P

peek() - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

peek() - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

poll() - Method in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

R

remove() - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

remove(Object) - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

remove() - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

remove(Object) - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

removeAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

removeAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

requestFusion(int) - Method in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

retainAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

retainAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

S

s - Variable in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

s - Variable in class hu.akarnokd.rxjava2.util.DeferredScalarSubscriber

SelfComparator - Enum in hu.akarnokd.rxjava2.util

Comparator that compares Comparables.

size() - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

size() - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

StringFlowable - Class in hu.akarnokd.rxjava2.string

StringObservable - Class in hu.akarnokd.rxjava2.string

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(ObservableConsumable<Double>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable

sumFloat(Publisher<Float>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable

sumFloat(ObservableConsumable<Float>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable

sumInt(Publisher<Integer>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable

sumInt(ObservableConsumable<Integer>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable

sumLong(Publisher<Long>) - Static method in class hu.akarnokd.rxjava2.math.MathFlowable

sumLong(ObservableConsumable<Long>) - Static method in class hu.akarnokd.rxjava2.math.MathObservable

T

toArray() - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

toArray(U[]) - Method in class hu.akarnokd.rxjava2.util.BaseIntQueueDisposable

toArray() - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

toArray(U[]) - Method in class hu.akarnokd.rxjava2.util.BaseQueueDisposable

V

value - Variable in class hu.akarnokd.rxjava2.util.DeferredScalarObserver

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 B C D E F H I M O P R S T V