Index (rxjava-extras 0.5.13 API)

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

A

a() - Method in class com.github.davidmoten.rx.util.Pair
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

b() - Method in class com.github.davidmoten.rx.util.Pair
BackpressureUtils - Class in com.github.davidmoten.rx.util: Utility functions for use with backpressure.
bufferEmissions() - Static method in class com.github.davidmoten.rx.Transformers

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.OperatorOrderedMerge
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
collectStats(Func1<? super T, ? extends R>) - Static method in class com.github.davidmoten.rx.Transformers
collectWhile(Func0<R>, Action2<? super R, ? super T>) - Static method in class com.github.davidmoten.rx.Transformers: Returns a Observable.Transformer that returns an Observable that is collected into Collection instances created by factory that are emitted when items are not equal or on completion.
collectWhile(Func0<R>, Action2<? super R, ? super T>, Func2<? super R, ? super T, Boolean>) - Static method in class com.github.davidmoten.rx.Transformers: Returns a Observable.Transformer that returns an Observable that is collected into Collection instances created by factory that are emitted when the collection and latest emission do not satisfy condition or on completion.
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<? super State, ? super In, ? super Observer<Out>, ? extends State>, Action2<? super State, ? super 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<T>, Subscriber<? super T>) - Static method in class com.github.davidmoten.rx.util.DrainerSyncBiased
create(T, S) - Static method in class com.github.davidmoten.rx.util.Pair

D

Drainer<T> - Interface in com.github.davidmoten.rx.util
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

K

kryo() - Static method in class com.github.davidmoten.rx.Serialized
kryo(Kryo) - Static method in class com.github.davidmoten.rx.Serialized

L

left() - Method in class com.github.davidmoten.rx.util.Pair

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.DrainerSyncBiased
onError(Throwable) - Method in class com.github.davidmoten.rx.subjects.PublishSubjectSingleSubscriber
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.DrainerSyncBiased
OperatorBufferEmissions<T> - Class in com.github.davidmoten.rx.operators
OperatorBufferEmissions() - Constructor for class com.github.davidmoten.rx.operators.OperatorBufferEmissions: Internal API.
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<? super Observable<T>, ? extends Observable<R>>) - Constructor for class com.github.davidmoten.rx.operators.OperatorFromTransformer: Constructor.
OperatorOrderedMerge<T> - Class in com.github.davidmoten.rx.operators
OperatorOrderedMerge(Observable<T>, Func2<? super T, ? super T, Integer>) - Constructor for class com.github.davidmoten.rx.operators.OperatorOrderedMerge
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
orderedMergeWith(Observable<T>, Func2<? super T, ? super T, Integer>) - Static method in class com.github.davidmoten.rx.Transformers: Returns the source Observable merged with the other observable using the given Comparator for order.

P

Pair<T,S> - Class in com.github.davidmoten.rx.util
Pair(T, S) - Constructor for class com.github.davidmoten.rx.util.Pair
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(Class<T>, File) - Method in class com.github.davidmoten.rx.Serialized.KryoBuilder
read(Class<T>, File, int) - Method in class com.github.davidmoten.rx.Serialized.KryoBuilder
read(Class<T>, Input, int) - Method in class com.github.davidmoten.rx.Serialized.KryoBuilder
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.DrainerSyncBiased
right() - Method in class com.github.davidmoten.rx.util.Pair

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
Serialized.KryoBuilder - Class in com.github.davidmoten.rx
skipUnsubscribedCheck() - Method in class com.github.davidmoten.rx.testing.TestingHelper.CaseBuilder
sort() - Static method in class com.github.davidmoten.rx.Transformers
sort(Comparator<? super T>) - Static method in class com.github.davidmoten.rx.Transformers
stateMachine(Func0<State>, Func3<? super State, ? super In, ? super Observer<Out>, ? extends State>, Action2<? super State, ? super 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<? super State, ? super In, ? super Observer<Out>, ? extends State>, Action2<? super State, ? super 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<? super State, ? super In, ? super Observer<Out>, ? extends State>) - 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.
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
surplus() - Method in interface com.github.davidmoten.rx.util.Drainer: Returns the current best estimate of
surplus() - Method in class com.github.davidmoten.rx.util.DrainerSyncBiased

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
toListUntilChanged() - Static method in class com.github.davidmoten.rx.Transformers: Returns a Observable.Transformer that returns an Observable that is a buffering of the source Observable into lists of sequential items that are equal.
toListWhile(Func2<? super List<T>, ? super T, Boolean>) - Static method in class com.github.davidmoten.rx.Transformers: Returns a Observable.Transformer that returns an Observable that is a buffering of the source Observable into lists of sequential items that satisfy the condition condition.
toObservable() - Method in class com.github.davidmoten.util.Optional
toOperator(Func1<? super Observable<T>, ? extends Observable<R>>) - Static method in class com.github.davidmoten.rx.operators.OperatorFromTransformer
toOperator(Func1<? super Observable<T>, ? extends 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
toString() - Method in class com.github.davidmoten.rx.util.Pair
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>, File) - Method in class com.github.davidmoten.rx.Serialized.KryoBuilder
write(Observable<T>, File, boolean) - Method in class com.github.davidmoten.rx.Serialized.KryoBuilder
write(Observable<T>, File, boolean, int) - Method in class com.github.davidmoten.rx.Serialized.KryoBuilder
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 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 K L M N O P R S T U V W