A C E F G I J L M N O P S T U W

A

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

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

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

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

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

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

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

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

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

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

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

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

Factory method.

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

I

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

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

L

latch() - Method in class com.github.davidmoten.rx.testing.UnsubscribeDetector

Returns a latch that will be at zero if one unsubscribe has occurred.

M

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

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.

S

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

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.

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

U

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

UnsubscribeDetector<T> - Class in com.github.davidmoten.rx.testing

Provides a CountDownLatch to assist with detecting unsubscribe calls.

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

Constructor.

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 C E F G I J L M N O P S T U W