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

A

a0(Checked.A0) - Static method in class com.github.davidmoten.rx.Checked

a0(Checked.A0) - Static method in class com.github.davidmoten.rx.Ignore

a1(Checked.A1<T>) - Static method in class com.github.davidmoten.rx.Checked

a1(Checked.A1<T>) - Static method in class com.github.davidmoten.rx.Ignore

absent() - Static method in class com.github.davidmoten.util.Optional

add() - Static method in class com.github.davidmoten.rx.Functions

Returns a Func2 that adds numbers.

add(Number) - Method in class com.github.davidmoten.rx.Statistics

alwaysFalse() - Static method in class com.github.davidmoten.rx.Functions

alwaysTrue() - Static method in class com.github.davidmoten.rx.Functions

B

BackpressureUtils - Class in com.github.davidmoten.util

Utility functions for use with backpressure.

bufferRequests() - Static method in class com.github.davidmoten.rx.Operators

bufferRequestsAsyncOptimized() - Static method in class com.github.davidmoten.rx.Operators

bufferRequestsAsyncOptimized(Scheduler) - Static method in class com.github.davidmoten.rx.Operators

C

call() - Method in interface com.github.davidmoten.rx.Checked.A0

call(T) - Method in interface com.github.davidmoten.rx.Checked.A1

call() - Method in interface com.github.davidmoten.rx.Checked.F0

call(T) - Method in interface com.github.davidmoten.rx.Checked.F1

call(T, R) - Method in interface com.github.davidmoten.rx.Checked.F2

call(Subscriber<? super T>) - Method in class com.github.davidmoten.rx.operators.OperatorBufferRequests

call(Subscriber<? super T>) - Method in class com.github.davidmoten.rx.operators.OperatorDoAfterOnNext

call(Subscriber<? super R>) - Method in class com.github.davidmoten.rx.operators.OperatorFromTransformer

call(Subscriber<? super T>) - Method in class com.github.davidmoten.rx.operators.OperatorUnsubscribeEagerly

checkArgument(boolean, String) - Static method in class com.github.davidmoten.util.Preconditions

Checked - Class in com.github.davidmoten.rx

Utility functions that are useful for brevity when using checked exceptions in lambdas with RxJava.

Checked() - Constructor for class com.github.davidmoten.rx.Checked

Checked.A0 - Interface in com.github.davidmoten.rx

Checked.A1<T> - Interface in com.github.davidmoten.rx

Checked.F0<T> - Interface in com.github.davidmoten.rx

Checked.F1<T,R> - Interface in com.github.davidmoten.rx

Checked.F2<T,R,S> - Interface in com.github.davidmoten.rx

checkNotNull(Object) - Static method in class com.github.davidmoten.util.Preconditions

checkNotNull(Object, String) - Static method in class com.github.davidmoten.util.Preconditions

collectStats() - Static method in class com.github.davidmoten.rx.Functions

collectStats() - Static method in class com.github.davidmoten.rx.Transformers

com.github.davidmoten.rx - package com.github.davidmoten.rx

com.github.davidmoten.rx.operators - package com.github.davidmoten.rx.operators

com.github.davidmoten.rx.subjects - package com.github.davidmoten.rx.subjects

com.github.davidmoten.rx.testing - package com.github.davidmoten.rx.testing

com.github.davidmoten.util - package com.github.davidmoten.util

constant(R) - Static method in class com.github.davidmoten.rx.Functions

count() - Method in class com.github.davidmoten.rx.Statistics

create() - Static method in class com.github.davidmoten.rx.Statistics

create() - Static method in class com.github.davidmoten.rx.subjects.PublishSubjectSingleSubscriber

Returns a new instance of a PublishSubjectSingleSubscriber.

create(Queue<Object>, Subscription, Scheduler.Worker, Subscriber<? super T>, Producer) - Static method in class com.github.davidmoten.util.DrainerAsyncBiased

create(Queue<T>, Subscriber<? super T>, Producer) - Static method in class com.github.davidmoten.util.DrainerSyncBiased

D

Drainer<T> - Interface in com.github.davidmoten.util

DrainerAsyncBiased<T> - Class in com.github.davidmoten.util

Optimized for when request method is called on a different thread from the Observer methods.

DrainerSyncBiased<T> - Class in com.github.davidmoten.util

Optimized for when request method is called on same thread as the Observer methods.

E

expect(R...) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

expect(List<R>) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

expectAnyOrder(R...) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

expectEmpty() - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

expectError() - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

expectError(Class<? extends Throwable>) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

expectException(Class<? extends RuntimeException>) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

expectSize(long) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

F

f0(Checked.F0<T>) - Static method in class com.github.davidmoten.rx.Checked

Returns a Func0 that reports any exception thrown by f wrapped by a RuntimeException.

f1(Checked.F1<T, R>) - Static method in class com.github.davidmoten.rx.Checked

f2(Checked.F2<T, R, S>) - Static method in class com.github.davidmoten.rx.Checked

from(T...) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

from(Observable<T>) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

fromEmpty() - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

fromError() - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

fromErrorAfter(T...) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

fromErrorAfter(Observable<T>) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

fromNullable(T) - Static method in class com.github.davidmoten.util.Optional

function(Func1<Observable<T>, Observable<R>>) - Method in class com.github.davidmoten.rx.testing.TestingHelper.Builder

Sets transformation to be tested and returns the current builder.

function(Func1<Observable<T>, Observable<R>>) - Static method in class com.github.davidmoten.rx.testing.TestingHelper

Sets the transformation to be tested and returns a builder to create test cases.

Functions - Class in com.github.davidmoten.rx

G

get() - Method in class com.github.davidmoten.util.Optional

getAndAddRequest(AtomicLongFieldUpdater<T>, T, long) - Static method in class com.github.davidmoten.util.BackpressureUtils

Adds n to requested field and returns the value prior to addition once the addition is successful (uses CAS semantics).

getAndAddRequest(AtomicLong, long) - Static method in class com.github.davidmoten.util.BackpressureUtils

Adds n to requested and returns the value prior to addition once the addition is successful (uses CAS semantics).

H

hasObservers() - Method in class com.github.davidmoten.rx.subjects.PublishSubjectSingleSubscriber

I

identity() - Static method in class com.github.davidmoten.rx.Functions

Ignore - Class in com.github.davidmoten.rx

Ignore() - Constructor for class com.github.davidmoten.rx.Ignore

instance() - Static method in class com.github.davidmoten.rx.operators.OperatorUnsubscribeEagerly

isPresent() - Method in class com.github.davidmoten.util.Optional

J

just() - Static method in class com.github.davidmoten.rx.Functions

M

mean() - Method in class com.github.davidmoten.rx.Statistics

Multiplier<T> - Interface in com.github.davidmoten.rx

A convenient shorthand way of specifying a Func1 used in a flatMap for instance.

N

name(String) - Method in class com.github.davidmoten.rx.testing.TestingHelper.Builder

Sets the name of the test which is used in the name of a junit test.

name(String) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

not(Func1<T, Boolean>) - Static method in class com.github.davidmoten.rx.Functions

O

of(T) - Static method in class com.github.davidmoten.util.Optional

onCompleted() - Method in class com.github.davidmoten.rx.subjects.PublishSubjectSingleSubscriber

onCompleted() - Method in class com.github.davidmoten.util.DrainerAsyncBiased

onCompleted() - Method in class com.github.davidmoten.util.DrainerSyncBiased

onError(Throwable) - Method in class com.github.davidmoten.rx.subjects.PublishSubjectSingleSubscriber

onError(Throwable) - Method in class com.github.davidmoten.util.DrainerAsyncBiased

onError(Throwable) - Method in class com.github.davidmoten.util.DrainerSyncBiased

onNext(T) - Method in class com.github.davidmoten.rx.subjects.PublishSubjectSingleSubscriber

onNext(T) - Method in class com.github.davidmoten.util.DrainerAsyncBiased

onNext(T) - Method in class com.github.davidmoten.util.DrainerSyncBiased

OperatorBufferRequests<T> - Class in com.github.davidmoten.rx.operators

OperatorBufferRequests() - Constructor for class com.github.davidmoten.rx.operators.OperatorBufferRequests

OperatorBufferRequests(Scheduler) - Constructor for class com.github.davidmoten.rx.operators.OperatorBufferRequests

OperatorDoAfterOnNext<T> - Class in com.github.davidmoten.rx.operators

OperatorDoAfterOnNext(Action1<T>) - Constructor for class com.github.davidmoten.rx.operators.OperatorDoAfterOnNext

OperatorFromTransformer<R,T> - Class in com.github.davidmoten.rx.operators

Converts an Transformer (a function converting one Observable into another) into an Observable.Operator.

OperatorFromTransformer(Func1<Observable<T>, Observable<R>>) - Constructor for class com.github.davidmoten.rx.operators.OperatorFromTransformer

Constructor.

Operators - Class in com.github.davidmoten.rx

Operators() - Constructor for class com.github.davidmoten.rx.Operators

OperatorUnsubscribeEagerly<T> - Class in com.github.davidmoten.rx.operators

Optional<T> - Class in com.github.davidmoten.util

Optional.NotPresentException - Exception in com.github.davidmoten.util

Optional.NotPresentException() - Constructor for exception com.github.davidmoten.util.Optional.NotPresentException

or(T) - Method in class com.github.davidmoten.util.Optional

P

Preconditions - Class in com.github.davidmoten.util

Preconditions() - Constructor for class com.github.davidmoten.util.Preconditions

Predicate<T> - Interface in com.github.davidmoten.rx

A convenient sorthand way of specifying a Func1 used in a filter for instance.

PublishSubjectSingleSubscriber<T> - Class in com.github.davidmoten.rx.subjects

A Subject that supports a maximum of one Subscriber.

R

request(long) - Method in class com.github.davidmoten.util.DrainerAsyncBiased

request(long) - Method in class com.github.davidmoten.util.DrainerSyncBiased

S

sd() - Method in class com.github.davidmoten.rx.Statistics

skipUnsubscribedCheck() - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

sort() - Static method in class com.github.davidmoten.rx.Transformers

sort(Comparator<T>) - Static method in class com.github.davidmoten.rx.Transformers

Statistics - Class in com.github.davidmoten.rx

sum() - Method in class com.github.davidmoten.rx.Statistics

sumSquares() - Method in class com.github.davidmoten.rx.Statistics

T

TestingHelper - Class in com.github.davidmoten.rx.testing

Testing utility functions.

TestingHelper() - Constructor for class com.github.davidmoten.rx.testing.TestingHelper

TestingHelper.AssertionException - Exception in com.github.davidmoten.rx.testing

RuntimeException implementation to represent an assertion failure.

TestingHelper.AssertionException(String) - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.AssertionException

TestingHelper.Builder<T,R> - Class in com.github.davidmoten.rx.testing

Defines test cases and builds a JUnit test suite.

TestingHelper.CaseBuilder<T,R> - Class in com.github.davidmoten.rx.testing

TestingHelper.DeliveredMoreThanRequestedException - Exception in com.github.davidmoten.rx.testing

RuntimeException implementation to represent the situation of more items being delivered by a source than are requested via backpressure.

TestingHelper.DeliveredMoreThanRequestedException() - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.DeliveredMoreThanRequestedException

TestingHelper.DownstreamUnsubscriptionDidNotOccurException - Exception in com.github.davidmoten.rx.testing

TestingHelper.DownstreamUnsubscriptionDidNotOccurException() - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.DownstreamUnsubscriptionDidNotOccurException

TestingHelper.ExpectedErrorNotReceivedException - Exception in com.github.davidmoten.rx.testing

TestingHelper.ExpectedErrorNotReceivedException() - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.ExpectedErrorNotReceivedException

TestingHelper.ExpectedExceptionNotThrownException - Exception in com.github.davidmoten.rx.testing

TestingHelper.ExpectedExceptionNotThrownException() - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.ExpectedExceptionNotThrownException

TestingHelper.TerminalEventTimeoutException - Exception in com.github.davidmoten.rx.testing

TestingHelper.TerminalEventTimeoutException() - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.TerminalEventTimeoutException

TestingHelper.TooManyOnCompletedException - Exception in com.github.davidmoten.rx.testing

TestingHelper.TooManyOnCompletedException() - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.TooManyOnCompletedException

TestingHelper.UnexpectedOnCompletedException - Exception in com.github.davidmoten.rx.testing

TestingHelper.UnexpectedOnCompletedException() - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.UnexpectedOnCompletedException

TestingHelper.UnexpectedOnErrorException - Exception in com.github.davidmoten.rx.testing

TestingHelper.UnexpectedOnErrorException() - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.UnexpectedOnErrorException

TestingHelper.UnexpectedOnNextException - Exception in com.github.davidmoten.rx.testing

TestingHelper.UnexpectedOnNextException(String) - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.UnexpectedOnNextException

TestingHelper.UnsubscriptionFromSourceTimeoutException - Exception in com.github.davidmoten.rx.testing

TestingHelper.UnsubscriptionFromSourceTimeoutException() - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.UnsubscriptionFromSourceTimeoutException

TestingHelper.WrongOnNextCountException - Exception in com.github.davidmoten.rx.testing

TestingHelper.WrongOnNextCountException() - Constructor for exception com.github.davidmoten.rx.testing.TestingHelper.WrongOnNextCountException

testSuite(Class<?>) - Method in class com.github.davidmoten.rx.testing.TestingHelper.Builder

Returns the JUnit TestSuite comprised of the test cases created so far.

toFunc2(Comparator<T>) - Static method in class com.github.davidmoten.rx.Functions

toObservable() - Method in class com.github.davidmoten.util.Optional

toOperator(Func1<Observable<T>, Observable<R>>) - Static method in class com.github.davidmoten.rx.operators.OperatorFromTransformer

toOperator(Func1<Observable<T>, Observable<R>>) - Static method in class com.github.davidmoten.rx.Transformers

toSet() - Static method in class com.github.davidmoten.rx.Transformers

toString() - Method in class com.github.davidmoten.rx.Statistics

Transformers - Class in com.github.davidmoten.rx

Transformers() - Constructor for class com.github.davidmoten.rx.Transformers

U

unsubscribeAfter(int) - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder

W

waitForMoreTerminalEvents(long, TimeUnit) - Method in class com.github.davidmoten.rx.testing.TestingHelper.Builder

Sets duration to wait for more terminal events after one has been received.

waitForTerminalEvent(long, TimeUnit) - Method in class com.github.davidmoten.rx.testing.TestingHelper.Builder

Sets duration to wait for a terminal event (completed or error) when one is expected.

waitForUnsubscribe(long, TimeUnit) - Method in class com.github.davidmoten.rx.testing.TestingHelper.Builder

Sets duration to wait for unusubscription to occur (either of source or of downstream subscriber).

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