A B C D E F G H I J M N O P R S T U V 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.rx.util

Utility functions for use with backpressure.

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

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

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

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

bufferEmissionsObserveOnComputation() - 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.OperatorBufferEmissions

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

call(Observable<In>) - Method in class com.github.davidmoten.rx.operators.TransformerStateMachine

call(Observable<T>) - Method in class com.github.davidmoten.rx.util.MapWithIndex

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.rx.util - package com.github.davidmoten.rx.util

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

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

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

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

create(Func0<State>, Func3<State, In, Observer<Out>, State>, Action2<State, Observer<Out>>) - Static method in class com.github.davidmoten.rx.operators.TransformerStateMachine

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.rx.util.DrainerAsyncBiased

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

D

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

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

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

DrainerSyncBiased<T> - Class in com.github.davidmoten.rx.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.rx.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.rx.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

index() - Method in class com.github.davidmoten.rx.util.MapWithIndex.Indexed

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

instance() - Static method in class com.github.davidmoten.rx.util.MapWithIndex

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

J

Jaxws - Class in com.github.davidmoten.rx

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

Jaxws.ObservableAdapter - Class in com.github.davidmoten.rx

Jaxws.ObservableAdapter() - Constructor for class com.github.davidmoten.rx.Jaxws.ObservableAdapter

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

M

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

MapWithIndex<T> - Class in com.github.davidmoten.rx.util

MapWithIndex() - Constructor for class com.github.davidmoten.rx.util.MapWithIndex

MapWithIndex.Indexed<T> - Class in com.github.davidmoten.rx.util

MapWithIndex.Indexed(T, long) - Constructor for class com.github.davidmoten.rx.util.MapWithIndex.Indexed

marshal(Observable) - Method in class com.github.davidmoten.rx.Jaxws.ObservableAdapter

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.rx.util.DrainerAsyncBiased

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

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

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

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

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

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

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

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

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

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

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

read(ObjectInputStream) - Static method in class com.github.davidmoten.rx.Serialized

Returns the deserialized objects from the given InputStream as an Observable stream.

read(File, int) - Static method in class com.github.davidmoten.rx.Serialized

Returns the deserialized objects from the given File as an Observable stream.

read(File) - Static method in class com.github.davidmoten.rx.Serialized

Returns the deserialized objects from the given File as an Observable stream.

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

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

S

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

Serialized - Class in com.github.davidmoten.rx

Utility class for writing Observable streams to ObjectOutputStreams and reading Observable streams of indeterminate size from ObjectInputStreams.

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

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

stateMachine(Func0<State>, Func3<State, In, Observer<Out>, State>, Action2<State, Observer<Out>>) - Static method in class com.github.davidmoten.rx.Transformers

Returns a Observable.Transformer that allows processing of the source stream to be defined in a state machine where transitions of the state machine may also emit items to downstream that are buffered if necessary when backpressure is requested.

stateMachine(State, Func3<State, In, Observer<Out>, State>, Action2<State, Observer<Out>>) - Static method in class com.github.davidmoten.rx.Transformers

stateMachine(State, Func3<State, In, Observer<Out>, State>) - 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

toString() - Method in class com.github.davidmoten.rx.util.MapWithIndex.Indexed

Transformers - Class in com.github.davidmoten.rx

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

TransformerStateMachine<State,In,Out> - Class in com.github.davidmoten.rx.operators

U

unmarshal(List) - Method in class com.github.davidmoten.rx.Jaxws.ObservableAdapter

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

V

value() - Method in class com.github.davidmoten.rx.util.MapWithIndex.Indexed

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

write(Observable<T>, ObjectOutputStream) - Static method in class com.github.davidmoten.rx.Serialized

Returns a duplicate of the input stream but with the side effect that emissions from the source are written to the input stream wrapped as an ObjectOutputStream.

write(Observable<T>, File, boolean, int) - Static method in class com.github.davidmoten.rx.Serialized

Writes the source stream to the given file in given append mode and using the given buffer size.

write(Observable<T>, File, boolean) - Static method in class com.github.davidmoten.rx.Serialized

Writes the source stream to the given file in given append mode and using the a buffer size of 8192 bytes.

write(Observable<T>, File) - Static method in class com.github.davidmoten.rx.Serialized

Writes the source stream to the given file in given append mode and using the a buffer size of 8192 bytes.

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