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

A

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

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

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

includeBackpressureRequestOverflowTest - Static variable in class com.github.davidmoten.rx.testing.TestingHelper

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

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

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

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.

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

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 N O P S T U W