(package private) static class |
BufferUntilSubscriber.OnSubscribeAction<T> |
|
(package private) static class |
CachedObservable.CachedSubscribe<T> |
Manages the subscription of child subscribers by setting up a replay producer and
performs auto-connection of the very first subscription.
|
class |
CompletableOnSubscribeConcat |
|
class |
CompletableOnSubscribeConcatArray |
|
class |
CompletableOnSubscribeConcatIterable |
|
class |
CompletableOnSubscribeMerge |
|
class |
CompletableOnSubscribeMergeArray |
|
class |
CompletableOnSubscribeMergeDelayErrorArray |
|
class |
CompletableOnSubscribeMergeDelayErrorIterable |
|
class |
CompletableOnSubscribeMergeIterable |
|
class |
CompletableOnSubscribeTimeout |
|
class |
EmptyObservableHolder |
Holds a singleton instance of an empty Observable which is stateless and completes
the child subscriber immediately.
|
class |
NeverObservableHolder |
Holds a singleton instance of a never Observable which is stateless doesn't
call any of the Subscriber's methods.
|
class |
OnSubscribeAmb<T> |
Given multiple Observable s, propagates the one that first emits an item.
|
class |
OnSubscribeAutoConnect<T> |
Wraps a ConnectableObservable and calls its connect() method once
the specified number of Subscribers have subscribed.
|
class |
OnSubscribeCollect<T,R> |
|
class |
OnSubscribeCombineLatest<T,R> |
|
class |
OnSubscribeConcatMap<T,R> |
Maps a source sequence into Observables and concatenates them in order, subscribing
to one at a time.
|
class |
OnSubscribeDefer<T> |
Do not create the Observable until an Observer subscribes; create a fresh Observable on each
subscription.
|
class |
OnSubscribeDelaySubscription<T> |
Delays the subscription to the source by the given amount, running on the given scheduler.
|
class |
OnSubscribeDelaySubscriptionOther<T,U> |
Delays the subscription to the main source until the other
observable fires an event or completes.
|
class |
OnSubscribeDelaySubscriptionWithSelector<T,U> |
Delays the subscription until the Observable emits an event.
|
class |
OnSubscribeDetach<T> |
Nulls out references to upstream data structures when the source terminates or
the child unsubscribes.
|
class |
OnSubscribeFilter<T> |
Filters an Observable by discarding any items it emits that do not meet some test.
|
class |
OnSubscribeFlattenIterable<T,R> |
Flattens a sequence if Iterable sources, generated via a function, into a single sequence.
|
(package private) static class |
OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable<T,R> |
A custom flattener that works from a scalar value and computes the iterable
during subscription time.
|
class |
OnSubscribeFromArray<T> |
|
class |
OnSubscribeFromAsync<T> |
|
class |
OnSubscribeFromCallable<T> |
Do not invoke the function until an Observer subscribes; Invokes function on each
subscription.
|
class |
OnSubscribeFromIterable<T> |
Converts an Iterable sequence into an Observable .
|
class |
OnSubscribeGroupJoin<T1,T2,D1,D2,R> |
Correlates two sequences when they overlap and groups the results.
|
(package private) static class |
OnSubscribeGroupJoin.WindowObservableFunc<T> |
The reference-counted window observable.
|
class |
OnSubscribeJoin<TLeft,TRight,TLeftDuration,TRightDuration,R> |
Correlates the elements of two sequences based on overlapping durations.
|
class |
OnSubscribeLift<T,R> |
Transforms the downstream Subscriber into a Subscriber via an operator
callback and calls the parent OnSubscribe.call() method with it.
|
class |
OnSubscribeMap<T,R> |
Applies a function of your choosing to every item emitted by an Observable , and emits the results of
this transformation as a new Observable .
|
class |
OnSubscribeOnAssembly<T> |
Captures the current stack when it is instantiated, makes
it available through a field and attaches it to all
passing exception.
|
class |
OnSubscribeOnAssemblyCompletable<T> |
Captures the current stack when it is instantiated, makes
it available through a field and attaches it to all
passing exception.
|
class |
OnSubscribeOnAssemblySingle<T> |
Captures the current stack when it is instantiated, makes
it available through a field and attaches it to all
passing exception.
|
class |
OnSubscribePublishMulticast<T> |
Multicasts notifications coming through its input Subscriber view to its
client Subscribers via lockstep backpressure mode.
|
class |
OnSubscribeRange |
Emit ints from start to end inclusive.
|
class |
OnSubscribeRedo<T> |
|
class |
OnSubscribeReduce<T> |
|
class |
OnSubscribeReduceSeed<T,R> |
|
class |
OnSubscribeRefCount<T> |
Returns an observable sequence that stays connected to the source as long as
there is at least one subscription to the observable sequence.
|
class |
OnSubscribeSingle<T> |
Allows conversion of an Observable to a Single ensuring that exactly one item is emitted - no more and no less.
|
class |
OnSubscribeTakeLastOne<T> |
|
class |
OnSubscribeThrow<T> |
|
class |
OnSubscribeTimerOnce |
Timer that emits a single 0L and completes after the specified time.
|
class |
OnSubscribeTimerPeriodically |
Emit 0L after the initial period and ever increasing number after each period.
|
(package private) static class |
OnSubscribeToObservableFuture.ToObservableFuture<T> |
|
class |
OnSubscribeUsing<T,Resource> |
Constructs an observable sequence that depends on a resource object.
|
(package private) static class |
OnSubscribeUsing.DisposeAction<Resource> |
|
(package private) static class |
OperatorGroupBy.GroupBySubscriber.EvictionAction<K> |
|
(package private) static class |
OperatorGroupBy.State<T,K> |
|
(package private) static class |
OperatorObserveOn.ObserveOnSubscriber<T> |
Observe through individual queue per observer.
|
(package private) static class |
OperatorSampleWithTime.SamplerSubscriber<T> |
The source subscriber and sampler.
|
class |
OperatorSubscribeOn<T> |
Subscribes Observers on the specified Scheduler .
|
(package private) static class |
OperatorTakeTimed.TakeSubscriber<T> |
Subscribed to source and scheduled on a worker.
|
(package private) static class |
OperatorWindowWithSize.WindowExact<T> |
|
(package private) static class |
OperatorWindowWithSize.WindowOverlap<T> |
|
(package private) static class |
OperatorWindowWithSize.WindowSkip<T> |
|
class |
OperatorWithLatestFromMany<T,R> |
|
class |
SingleDoAfterTerminate<T> |
Execute an action after onSuccess or onError has been delivered.
|
class |
SingleOnSubscribeDelaySubscriptionOther<T> |
Delays the subscription to the Single until the Observable
fires an event or completes.
|
class |
SingleOnSubscribeMap<T,R> |
Applies a function of your choosing to every item emitted by an Single , and emits the results of
this transformation as a new Single .
|
class |
SingleOnSubscribeUsing<T,Resource> |
Generates a resource, derives a Single from it and disposes that resource once the
Single terminates.
|
class |
SingleOperatorOnErrorResumeNext<T> |
|