Observable like Observable.cache()
except that the cache can be reset by calling
CachedObservable.reset().Observable like Observable.cache()
except that the cache can be reset by calling
CachedObservable.reset() and the cache will be automatically
reset an interval after first subscription (or first subscription after
reset).Observable like Observable.cache()
except that the cache may be reset by the user calling
CloseableObservableWithReset.reset().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.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.PublishSubjectSingleSubscriber.Observable.Transformer that applied to a source Observable
calls the given action on the first onNext emission.Observable.Transformer that applied to a source Observable
calls the given action on the nth onNext emission.Func0 that reports any exception thrown by f wrapped by
a RuntimeException.n to requested field and returns the value prior to
addition once the addition is successful (uses CAS semantics).n to requested and returns the value prior to
addition once the addition is successful (uses CAS semantics).Observable.Operator.Observable merged with the other
observable using the given Comparator for order.Observable merged with all of the other
observables using the given Comparator for order.Subject that supports a maximum of one Subscriber.InputStream as an
Observable stream.File as an
Observable stream.File as an
Observable stream.t without completing.Func1 parameter of
Observable.retryWhen(Func1).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.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.TestSuite comprised of the test cases
created so far.Observable.Transformer that returns an Observable that is
a buffering of the source Observable into lists of sequential items that
are equal.Observable.Transformer that returns an Observable that is
a buffering of the source Observable into lists of sequential items that
satisfy the condition condition.ObjectOutputStream.Copyright © 2013–2015. All rights reserved.