Index

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

A

AbstractOnSubscribe < T , S> - Class in rx.observables: Abstract base class for the Observable.OnSubscribe interface that helps you build Observable sources one onNext at a time, and automatically supports unsubscription and backpressure.
AbstractOnSubscribe() - Constructor for class rx .observables . AbstractOnSubscribe
AbstractOnSubscribe.SubscriptionState < T , S> - Class in rx.observables: Represents a per-subscription state for the AbstractOnSubscribe operation.
accept(Observer<? super T>, Object) - Method in class rx .internal .operators . NotificationLite: Unwraps the lite notification and calls the appropriate method on the Observer.
accept(Object) - Method in interface rx .internal .util . BackpressureDrainManager.BackpressureQueueCallback: Override this method to deliver an element to downstream.
accept(Object, Observer) - Method in class rx .internal .util . RxRingBuffer
accept(Observer<? super T>) - Method in class rx . Notification: Forwards this notification on to a specified Observer.
accept() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Emits the onNext and/or the terminal value to the actual subscriber.
Action - Interface in rx.functions: All Action interfaces extend from this.
Action0 - Interface in rx.functions: A zero-argument action.
Action1 < T> - Interface in rx.functions: A one-argument action.
Action2 < T1 , T2> - Interface in rx.functions: A two-argument action.
Action3 < T1 , T2 , T3> - Interface in rx.functions: A three-argument action.
Action4 < T1 , T2 , T3 , T4> - Interface in rx.functions: A four-argument action.
Action5 < T1 , T2 , T3 , T4 , T5> - Interface in rx.functions: A five-argument action.
Action6 < T1 , T2 , T3 , T4 , T5 , T6> - Interface in rx.functions: A six-argument action.
Action7 < T1 , T2 , T3 , T4 , T5 , T6 , T7> - Interface in rx.functions: A seven-argument action.
Action8 < T1 , T2 , T3 , T4 , T5 , T6 , T7 , T8> - Interface in rx.functions: An eight-argument action.
Action9 < T1 , T2 , T3 , T4 , T5 , T6 , T7 , T8 , T9> - Interface in rx.functions: A nine-argument action.
ActionN - Interface in rx.functions: A vector-argument action.
Actions - Class in rx.functions: Utility class for the Action interfaces.
actual - Variable in class rx .internal .util . BackpressureDrainManager: The callbacks to manage the drain.
add(Subscription) - Method in class rx .internal .schedulers . ScheduledAction: Adds a general Subscription to this ScheduledAction that will be unsubscribed if the underlying action completes or the this scheduled action is cancelled.
add(Future<?>) - Method in class rx .internal .schedulers . ScheduledAction: Adds the given Future to the unsubscription composite in order to support cancelling the underlying task in the executor framework.
add(T) - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
add(T) - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
add(T) - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
add(E) - Method in class rx .internal .util . IndexedRingBuffer: Add an element and return the index where it was added to allow removal.
add(Object) - Method in class rx .internal .util . LinkedArrayList: Adds a new element to this list.
add(Subscription) - Method in class rx .internal .util . SubscriptionList: Adds a new Subscription to this SubscriptionList if the SubscriptionList is not yet unsubscribed.
add(T) - Method in class rx .internal .util . SynchronizedQueue
add(Subscription) - Method in class rx . SingleSubscriber: Adds a Subscription to this Subscriber's list of subscriptions if this list is not marked as unsubscribed.
add(Subscription) - Method in class rx . Subscriber: Adds a Subscription to this Subscriber's list of subscriptions if this list is not marked as unsubscribed.
add(Subscription) - Method in class rx .subscriptions . CompositeSubscription: Adds a new Subscription to this CompositeSubscription if the CompositeSubscription is not yet unsubscribed.
addAll(Collection<? extends T>) - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
addAll(Collection<? extends T>) - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
addAll(Collection<? extends T>) - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
addAll(Collection<? extends T>) - Method in class rx .internal .util . SynchronizedQueue
addCap(long, long) - Static method in class rx .internal .operators . BackpressureUtils: Adds two positive longs and caps the result at Long.MAX_VALUE.
addCause(Throwable, Throwable) - Static method in class rx .exceptions . Exceptions: Adds a Throwable to a causality-chain of Throwables, as an additional cause (if it does not already appear in the chain among the causes).
addParent(CompositeSubscription) - Method in class rx .internal .schedulers . ScheduledAction: Adds a parent CompositeSubscription to this ScheduledAction so when the action is cancelled or terminates, it can remove itself from this parent.
addParent(SubscriptionList) - Method in class rx .internal .schedulers . ScheduledAction: Adds a parent CompositeSubscription to this ScheduledAction so when the action is cancelled or terminates, it can remove itself from this parent.
addressOf(Class<?>, String) - Static method in class rx .internal .util .unsafe . UnsafeAccess: Returns the address of the specific field on the class and wraps a NoSuchFieldException into an internal error.
addValueAsLastCause(Throwable, Object) - Static method in exception rx .exceptions . OnErrorThrowable: Adds the given item as the final cause of the given Throwable, wrapped in OnNextValue (which extends RuntimeException).
advancePhase() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Advance the current phase by 1.
advancePhaseBy(int) - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Advance the current phase by the given amount (can be negative).
advanceTimeBy(long, TimeUnit) - Method in class rx .schedulers . TestScheduler: Moves the Scheduler's clock forward by a specified amount of time.
advanceTimeTo(long, TimeUnit) - Method in class rx .schedulers . TestScheduler: Moves the Scheduler's clock to a particular moment in time.
all(Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that emits a Boolean that indicates whether all of the items emitted by the source Observable satisfy a condition.
alwaysFalse() - Static method in class rx .internal .util . UtilityFunctions: Returns a function that always returns false.
alwaysTrue() - Static method in class rx .internal .util . UtilityFunctions: Returns a function that always returns true.
amb(Observable<? extends T>, Observable<? extends T>) - Static method in class rx .internal .operators . OnSubscribeAmb: Given two Observables, propagates the one that first emits an item.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx .internal .operators . OnSubscribeAmb: Given three Observables, propagates the one that first emits an item.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx .internal .operators . OnSubscribeAmb: Given four Observables, propagates the one that first emits an item.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx .internal .operators . OnSubscribeAmb: Given five Observables, propagates the one that first emits an item.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx .internal .operators . OnSubscribeAmb: Given six Observables, propagates the one that first emits an item.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx .internal .operators . OnSubscribeAmb: Given seven Observables, propagates the one that first emits an item.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx .internal .operators . OnSubscribeAmb: Given eight Observables, propagates the one that first emits an item.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx .internal .operators . OnSubscribeAmb: Given nine Observables, propagates the one that first emits an item.
amb(Iterable<? extends Observable<? extends T>>) - Static method in class rx .internal .operators . OnSubscribeAmb: Given a set of Observables, propagates the one that first emits an item.
amb(Iterable<? extends Observable<? extends T>>) - Static method in class rx . Observable: Mirrors the one Observable in an Iterable of several Observables that first either emits an item or sends a termination notification.
amb(Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Given two Observables, mirrors the one that first either emits an item or sends a termination notification.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Given three Observables, mirrors the one that first either emits an item or sends a termination notification.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Given four Observables, mirrors the one that first either emits an item or sends a termination notification.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Given five Observables, mirrors the one that first either emits an item or sends a termination notification.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Given six Observables, mirrors the one that first either emits an item or sends a termination notification.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Given seven Observables, mirrors the one that first either emits an item or sends a termination notification.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Given eight Observables, mirrors the one that first either emits an item or sends a termination notification.
amb(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Given nine Observables, mirrors the one that first either emits an item or sends a termination notification.
ambWith(Observable<? extends T>) - Method in class rx . Observable: Mirrors the Observable (current or provided) that first either emits an item or sends a termination notification.
ANDROID_API_VERSION_IS_NOT_ANDROID - Static variable in class rx .internal .util . PlatformDependent: Possible value of PlatformDependent.getAndroidApiVersion() which means that the current platform is not Android.
asError(Object) - Method in class rx .internal .util . RxRingBuffer
asObservable() - Method in class rx . Observable: Portrays a object of an Observable subclass as a simple Observable object.
assertCompleted() - Method in class rx .observers . TestSubscriber: Asserts that there is exactly one completion event.
assertError(Class<? extends Throwable>) - Method in class rx .observers . TestSubscriber: Asserts that there is exactly one error event which is a subclass of the given class.
assertError(Throwable) - Method in class rx .observers . TestSubscriber: Asserts that there is a single onError event with the exact exception.
assertNoErrors() - Method in class rx .observers . TestSubscriber: Asserts that this Subscriber has received no onError notifications.
assertNotCompleted() - Method in class rx .observers . TestSubscriber: Asserts that there is no completion event.
assertNoTerminalEvent() - Method in class rx .observers . TestSubscriber: Asserts that there are no onError and onCompleted events.
assertNoValues() - Method in class rx .observers . TestSubscriber: Asserts that there are no onNext events received.
assertReceivedOnNext(List<T>) - Method in class rx .observers . TestObserver: Assert that a particular sequence of items was received in order.
assertReceivedOnNext(List<T>) - Method in class rx .observers . TestSubscriber: Asserts that a particular sequence of items was received by this Subscriber in order.
assertTerminalEvent() - Method in class rx .observers . TestObserver: Assert that a single terminal event occurred, either TestObserver.onCompleted() or TestObserver.onError(java.lang.Throwable).
assertTerminalEvent() - Method in class rx .observers . TestSubscriber: Asserts that a single terminal event occurred, either TestSubscriber.onCompleted() or TestSubscriber.onError(java.lang.Throwable).
assertUnsubscribed() - Method in class rx .observers . TestSubscriber: Asserts that this Subscriber is unsubscribed.
assertValue(T) - Method in class rx .observers . TestSubscriber: Asserts that there is only a single received onNext event and that it marks the emission of a specific item.
assertValueCount(int) - Method in class rx .observers . TestSubscriber: Asserts that the given number of onNext events are received.
assertValues(T...) - Method in class rx .observers . TestSubscriber: Asserts that the received onNext events, in order, are the specified items.
AsyncOnSubscribe < S , T> - Class in rx.observables: A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
AsyncOnSubscribe() - Constructor for class rx .observables . AsyncOnSubscribe
AsyncSubject < T> - Class in rx.subjects: Subject that publishes only the last item observed to each Observer that has subscribed, when the source Observable completes.
AsyncSubject(Observable.OnSubscribe<T>, SubjectSubscriptionManager<T>) - Constructor for class rx .subjects . AsyncSubject
autoConnect() - Method in class rx .observables . ConnectableObservable: Returns an Observable that automatically connects to this ConnectableObservable when the first Subscriber subscribes.
autoConnect(int) - Method in class rx .observables . ConnectableObservable: Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it.
autoConnect(int, Action1<? super Subscription>) - Method in class rx .observables . ConnectableObservable: Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it and calls the specified callback with the Subscription associated with the established connection.
available() - Method in class rx .internal .util . RxRingBuffer
awaitForComplete(CountDownLatch, Subscription) - Static method in class rx .internal .util . BlockingUtils: Blocks and waits for a Subscription to complete.
awaitTerminalEvent() - Method in class rx .observers . TestSubscriber: Blocks until this Subscriber receives a notification that the Observable is complete (either an onCompleted or onError notification).
awaitTerminalEvent(long, TimeUnit) - Method in class rx .observers . TestSubscriber: Blocks until this Subscriber receives a notification that the Observable is complete (either an onCompleted or onError notification), or until a timeout expires.
awaitTerminalEventAndUnsubscribeOnTimeout(long, TimeUnit) - Method in class rx .observers . TestSubscriber: Blocks until this Subscriber receives a notification that the Observable is complete (either an onCompleted or onError notification), or until a timeout expires; if the Subscriber is interrupted before either of these events take place, this method unsubscribes the Subscriber from the Observable).

B

BackpressureDrainManager - Class in rx.internal.util: Manages the producer-backpressure-consumer interplay by matching up available elements with requested elements and/or terminal events.
BackpressureDrainManager(BackpressureDrainManager.BackpressureQueueCallback) - Constructor for class rx .internal .util . BackpressureDrainManager: Constructs a backpressure drain manager with 0 requesedCount, no terminal event and not emitting.
BackpressureDrainManager.BackpressureQueueCallback - Interface in rx.internal.util: Interface representing the minimal callbacks required to operate the drain part of a backpressure system.
BackpressureUtils - Class in rx.internal.operators: Utility functions for use with backpressure.
BehaviorSubject < T> - Class in rx.subjects: Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
BehaviorSubject(Observable.OnSubscribe<T>, SubjectSubscriptionManager<T>) - Constructor for class rx .subjects . BehaviorSubject
Beta - Annotation Type in rx.annotations: Signifies that a public API (public class, method or field) is subject to incompatible changes, or even removal, in a future release.
BlockingObservable < T> - Class in rx.observables: BlockingObservable is a variety of Observable that provides blocking operators.
BlockingOperatorLatest - Class in rx.internal.operators: Wait for and iterate over the latest values of the source observable.
BlockingOperatorMostRecent - Class in rx.internal.operators: Returns an Iterable that always returns the item most recently emitted by an Observable, or a seed value if no item has yet been emitted.
BlockingOperatorNext - Class in rx.internal.operators: Returns an Iterable that blocks until the Observable emits another item, then returns that item.
BlockingOperatorToFuture - Class in rx.internal.operators: Returns a Future representing the single value emitted by an Observable.
BlockingOperatorToIterator - Class in rx.internal.operators: Returns an Iterator that iterates over all items emitted by a specified Observable.
BlockingOperatorToIterator.SubscriberIterator < T> - Class in rx.internal.operators
BlockingSingle < T> - Class in rx.singles: BlockingSingle is a blocking "version" of Single that provides blocking operators.
BlockingUtils - Class in rx.internal.util: Utility functions relating to blocking types.
BooleanSubscription - Class in rx.subscriptions: Subscription that can be checked for status such as in a loop inside an Observable to exit the loop if unsubscribed.
BooleanSubscription() - Constructor for class rx .subscriptions . BooleanSubscription
borrowObject() - Method in class rx .internal .util . ObjectPool: Gets the next free object from the pool.
buffer - Variable in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue
buffer(Func0<? extends Observable<? extends TClosing>>) - Method in class rx . Observable: Returns an Observable that emits buffers of items it collects from the source Observable.
buffer(int) - Method in class rx . Observable: Returns an Observable that emits buffers of items it collects from the source Observable.
buffer(int, int) - Method in class rx . Observable: Returns an Observable that emits buffers of items it collects from the source Observable.
buffer(long, long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits buffers of items it collects from the source Observable.
buffer(long, long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits buffers of items it collects from the source Observable.
buffer(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits buffers of items it collects from the source Observable.
buffer(long, TimeUnit, int) - Method in class rx . Observable: Returns an Observable that emits buffers of items it collects from the source Observable.
buffer(long, TimeUnit, int, Scheduler) - Method in class rx . Observable: Returns an Observable that emits buffers of items it collects from the source Observable.
buffer(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits buffers of items it collects from the source Observable.
buffer(Observable<? extends TOpening>, Func1<? super TOpening, ? extends Observable<? extends TClosing>>) - Method in class rx . Observable: Returns an Observable that emits buffers of items it collects from the source Observable.
buffer(Observable) - Method in class rx . Observable: Returns an Observable that emits non-overlapping buffered items from the source Observable each time the specified boundary Observable emits an item.
buffer(Observable, int) - Method in class rx . Observable: Returns an Observable that emits non-overlapping buffered items from the source Observable each time the specified boundary Observable emits an item.
BUFFER_PAD - Static variable in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue
BufferUntilSubscriber < T> - Class in rx.internal.operators: A solution to the "time gap" problem that occurs with groupBy and pivot.

C

cache() - Method in class rx . Observable: Caches the emissions from the source Observable and replays them in order to any subsequent Subscribers.
cache(int) - Method in class rx . Observable: Caches emissions from the source Observable and replays them in order to any subsequent Subscribers.
CachedObservable < T> - Class in rx.internal.operators: An observable which auto-connects to another observable, caches the elements from that observable but allows terminating the connection and completing the cache.
calcElementOffset(long) - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue
calcElementOffset(long, long) - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue
calcSequenceOffset(long) - Method in class rx .internal .util .unsafe . ConcurrentSequencedCircularArrayQueue
call() - Method in interface rx .functions . Action0
call(T) - Method in interface rx .functions . Action1
call(T1, T2) - Method in interface rx .functions . Action2
call(T1, T2, T3) - Method in interface rx .functions . Action3
call(T1, T2, T3, T4) - Method in interface rx .functions . Action4
call(T1, T2, T3, T4, T5) - Method in interface rx .functions . Action5
call(T1, T2, T3, T4, T5, T6) - Method in interface rx .functions . Action6
call(T1, T2, T3, T4, T5, T6, T7) - Method in interface rx .functions . Action7
call(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface rx .functions . Action8
call(T1, T2, T3, T4, T5, T6, T7, T8, T9) - Method in interface rx .functions . Action9
call(Object...) - Method in interface rx .functions . ActionN
call() - Method in interface rx .functions . Func0
call(T) - Method in interface rx .functions . Func1
call(T1, T2) - Method in interface rx .functions . Func2
call(T1, T2, T3) - Method in interface rx .functions . Func3
call(T1, T2, T3, T4) - Method in interface rx .functions . Func4
call(T1, T2, T3, T4, T5) - Method in interface rx .functions . Func5
call(T1, T2, T3, T4, T5, T6) - Method in interface rx .functions . Func6
call(T1, T2, T3, T4, T5, T6, T7) - Method in interface rx .functions . Func7
call(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface rx .functions . Func8
call(T1, T2, T3, T4, T5, T6, T7, T8, T9) - Method in interface rx .functions . Func9
call(Object...) - Method in interface rx .functions . FuncN
call(Subscriber<? super T>) - Method in class rx .internal .operators . OnSubscribeAmb
call(Subscriber<? super T>) - Method in class rx .internal .operators . OnSubscribeAutoConnect
call(Subscriber<? super R>) - Method in class rx .internal .operators . OnSubscribeCombineLatest
call(Subscriber<? super T>) - Method in class rx .internal .operators . OnSubscribeDefer
call(Subscriber<? super T>) - Method in class rx .internal .operators . OnSubscribeDelaySubscription
call(Subscriber<? super T>) - Method in class rx .internal .operators . OnSubscribeDelaySubscriptionWithSelector
call(Subscriber<? super T>) - Method in class rx .internal .operators . OnSubscribeFromCallable
call(Subscriber<? super T>) - Method in class rx .internal .operators . OnSubscribeFromIterable
call(Subscriber<? super R>) - Method in class rx .internal .operators . OnSubscribeGroupJoin
call(Subscriber<? super R>) - Method in class rx .internal .operators . OnSubscribeJoin
call(Subscriber<? super Integer>) - Method in class rx .internal .operators . OnSubscribeRange
call(Subscriber<? super T>) - Method in class rx .internal .operators . OnSubscribeRedo
call(Observable<? extends Notification<?>>) - Method in class rx .internal .operators . OnSubscribeRedo.RedoFinite
call(Observable<? extends Notification<?>>) - Method in class rx .internal .operators . OnSubscribeRedo.RetryWithPredicate
call(Subscriber<? super T>) - Method in class rx .internal .operators . OnSubscribeRefCount
call(SingleSubscriber<? super T>) - Method in class rx .internal .operators . OnSubscribeSingle
call(Subscriber<? super Long>) - Method in class rx .internal .operators . OnSubscribeTimerOnce
call(Subscriber<? super Long>) - Method in class rx .internal .operators . OnSubscribeTimerPeriodically
call(Subscriber<? super T>) - Method in class rx .internal .operators . OnSubscribeUsing
call(Subscriber<? super Boolean>) - Method in class rx .internal .operators . OperatorAll
call(Subscriber<? super Boolean>) - Method in class rx .internal .operators . OperatorAny
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorAsObservable
call(Subscriber<? super List<T>>) - Method in class rx .internal .operators . OperatorBufferWithSingleObservable
call(Subscriber<? super List<T>>) - Method in class rx .internal .operators . OperatorBufferWithSize
call(Subscriber<? super List<T>>) - Method in class rx .internal .operators . OperatorBufferWithStartEndObservable
call(Subscriber<? super List<T>>) - Method in class rx .internal .operators . OperatorBufferWithTime
call(Subscriber<? super R>) - Method in class rx .internal .operators . OperatorCast
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorConcat
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorDebounceWithSelector
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorDebounceWithTime
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorDelay
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorDelayWithSelector
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorDematerialize
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorDistinct
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorDistinctUntilChanged
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorDoOnEach
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorDoOnRequest
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorDoOnSubscribe
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorDoOnUnsubscribe
call(Subscriber<? super R>) - Method in class rx .internal .operators . OperatorEagerConcatMap
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorElementAt
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorFilter
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorFinally
call(Subscriber<? super GroupedObservable<K, R>>) - Method in class rx .internal .operators . OperatorGroupBy
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorIgnoreElements
call(Subscriber<? super R>) - Method in class rx .internal .operators . OperatorMap
call(Subscriber<? super R>) - Method in class rx .internal .operators . OperatorMapNotification
call(Subscriber<? super Observable<? extends R>>) - Method in class rx .internal .operators . OperatorMapPair
call(Subscriber<? super Notification<T>>) - Method in class rx .internal .operators . OperatorMaterialize
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorMerge
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorObserveOn
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorOnBackpressureBlock
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorOnBackpressureBuffer
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorOnBackpressureDrop
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorOnBackpressureLatest
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorOnErrorResumeNextViaFunction
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorOnErrorResumeNextViaObservable
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorOnErrorReturn
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorOnExceptionResumeNextViaObservable
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorRetryWithPredicate
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSampleWithObservable
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSampleWithTime
call(Subscriber<? super R>) - Method in class rx .internal .operators . OperatorScan
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSerialize
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSingle
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSkip
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSkipLast
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSkipLastTimed
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSkipTimed
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSkipUntil
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSkipWhile
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSubscribeOn
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSwitch
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorSwitchIfEmpty
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorTake
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorTakeLast
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorTakeLastOne
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorTakeLastTimed
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorTakeTimed
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorTakeUntil
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorTakeUntilPredicate
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorTakeWhile
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorThrottleFirst
call(Subscriber<? super TimeInterval<T>>) - Method in class rx .internal .operators . OperatorTimeInterval
call(Subscriber<? super Timestamped<T>>) - Method in class rx .internal .operators . OperatorTimestamp
call(Subscriber<? super Map<K, V>>) - Method in class rx .internal .operators . OperatorToMap
call() - Method in class rx .internal .operators . OperatorToMap.DefaultToMapFactory
call(Subscriber<? super Map<K, Collection<V>>>) - Method in class rx .internal .operators . OperatorToMultimap
call(K) - Method in class rx .internal .operators . OperatorToMultimap.DefaultMultimapCollectionFactory
call() - Method in class rx .internal .operators . OperatorToMultimap.DefaultToMultimapFactory
call(Subscriber<? super List<T>>) - Method in class rx .internal .operators . OperatorToObservableList
call(Subscriber<? super List<T>>) - Method in class rx .internal .operators . OperatorToObservableSortedList
call(Subscriber<? super T>) - Method in class rx .internal .operators . OperatorUnsubscribeOn
call(Subscriber<? super Observable<T>>) - Method in class rx .internal .operators . OperatorWindowWithObservable
call(Subscriber<? super Observable<T>>) - Method in class rx .internal .operators . OperatorWindowWithObservableFactory
call(Subscriber<? super Observable<T>>) - Method in class rx .internal .operators . OperatorWindowWithSize
call(Subscriber<? super Observable<T>>) - Method in class rx .internal .operators . OperatorWindowWithStartEndObservable
call(Subscriber<? super Observable<T>>) - Method in class rx .internal .operators . OperatorWindowWithTime
call(Subscriber<? super R>) - Method in class rx .internal .operators . OperatorWithLatestFrom
call(Subscriber<? super R>) - Method in class rx .internal .operators . OperatorZip
call(Subscriber<? super R>) - Method in class rx .internal .operators . OperatorZipIterable
call(Subscriber<? super T>) - Method in class rx .observables . AbstractOnSubscribe
call(Subscriber<? super T>) - Method in class rx .observables . AsyncOnSubscribe
call(Subscriber<? super T>) - Method in class rx .observables . SyncOnSubscribe
calls() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState
capacity() - Method in class rx .internal .util . RxRingBuffer
capacityHint() - Method in class rx .internal .util . LinkedArrayList: Returns the capacity hint that indicates the capacity of each buffer segment.
cast(Class<R>) - Method in class rx . Observable: Returns an Observable that emits the items emitted by the source Observable, converted to the specified type.
clear() - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
clear() - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
clear() - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
clear() - Method in class rx .internal .util . SubscriptionList
clear() - Method in class rx .internal .util . SynchronizedQueue
clear() - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue
clear() - Method in class rx .subscriptions . CompositeSubscription: Unsubscribes any subscriptions that are currently part of this CompositeSubscription and remove them from the CompositeSubscription so that the CompositeSubscription is empty and able to manage new subscriptions.
clone() - Method in class rx .internal .util . SynchronizedQueue
collect(Func0<R>, Action2<R, ? super T>) - Method in class rx . Observable: Collects items emitted by the source Observable into a single mutable data structure and returns an Observable that emits this structure.
combineLatest(Observable<? extends T1>, Observable<? extends T2>, Func2<? super T1, ? super T2, ? extends R>) - Static method in class rx . Observable: Combines two source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from either of the source Observables, where this aggregation is defined by a specified function.
combineLatest(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Func3<? super T1, ? super T2, ? super T3, ? extends R>) - Static method in class rx . Observable: Combines three source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function.
combineLatest(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Func4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>) - Static method in class rx . Observable: Combines four source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function.
combineLatest(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Observable<? extends T5>, Func5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>) - Static method in class rx . Observable: Combines five source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function.
combineLatest(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Observable<? extends T5>, Observable<? extends T6>, Func6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>) - Static method in class rx . Observable: Combines six source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function.
combineLatest(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Observable<? extends T5>, Observable<? extends T6>, Observable<? extends T7>, Func7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>) - Static method in class rx . Observable: Combines seven source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function.
combineLatest(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Observable<? extends T5>, Observable<? extends T6>, Observable<? extends T7>, Observable<? extends T8>, Func8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>) - Static method in class rx . Observable: Combines eight source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function.
combineLatest(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Observable<? extends T5>, Observable<? extends T6>, Observable<? extends T7>, Observable<? extends T8>, Observable<? extends T9>, Func9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>) - Static method in class rx . Observable: Combines nine source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function.
combineLatest(List<? extends Observable<? extends T>>, FuncN<? extends R>) - Static method in class rx . Observable: Combines a list of source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function.
compareAndSwapInt(Object, long, int, int) - Static method in class rx .internal .util .unsafe . UnsafeAccess
complete(Throwable) - Method in interface rx .internal .util . BackpressureDrainManager.BackpressureQueueCallback: Override this method to deliver a normal or exceptional terminal event.
completed() - Method in class rx .internal .operators . NotificationLite: Creates a lite onCompleted notification without doing any allocation.
compose(Observable.Transformer<? super T, ? extends R>) - Method in class rx . Observable: Transform an Observable by applying a particular Transformer function to it.
compose(Single.Transformer<? super T, ? extends R>) - Method in class rx . Single: Transform a Single by applying a particular Transformer function to it.
CompositeException - Exception in rx.exceptions: Represents an exception that is a composite of one or more other exceptions.
CompositeException(String, Collection<? extends Throwable>) - Constructor for exception rx .exceptions . CompositeException
CompositeException(Collection<? extends Throwable>) - Constructor for exception rx .exceptions . CompositeException
CompositeSubscription - Class in rx.subscriptions: Subscription that represents a group of Subscriptions that are unsubscribed together.
CompositeSubscription() - Constructor for class rx .subscriptions . CompositeSubscription
CompositeSubscription(Subscription...) - Constructor for class rx .subscriptions . CompositeSubscription
computation() - Static method in class rx .schedulers . Schedulers: Creates and returns a Scheduler intended for computational work.
concat(Observable<? extends Observable<? extends T>>) - Static method in class rx . Observable: Returns an Observable that emits the items emitted by each of the Observables emitted by the source Observable, one after the other, without interleaving them.
concat(Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Returns an Observable that emits the items emitted by two Observables, one after the other, without interleaving them.
concat(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Returns an Observable that emits the items emitted by three Observables, one after the other, without interleaving them.
concat(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Returns an Observable that emits the items emitted by four Observables, one after the other, without interleaving them.
concat(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Returns an Observable that emits the items emitted by five Observables, one after the other, without interleaving them.
concat(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Returns an Observable that emits the items emitted by six Observables, one after the other, without interleaving them.
concat(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Returns an Observable that emits the items emitted by seven Observables, one after the other, without interleaving them.
concat(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Returns an Observable that emits the items emitted by eight Observables, one after the other, without interleaving them.
concat(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Returns an Observable that emits the items emitted by nine Observables, one after the other, without interleaving them.
concat(Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Returns an Observable that emits the items emitted by two Singles, one after the other.
concat(Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Returns an Observable that emits the items emitted by three Singles, one after the other.
concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Returns an Observable that emits the items emitted by four Singles, one after the other.
concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Returns an Observable that emits the items emitted by five Singles, one after the other.
concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Returns an Observable that emits the items emitted by six Singles, one after the other.
concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Returns an Observable that emits the items emitted by seven Singles, one after the other.
concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Returns an Observable that emits the items emitted by eight Singles, one after the other.
concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Returns an Observable that emits the items emitted by nine Singles, one after the other.
concatEager(Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Concatenates two source Observables eagerly into a single stream of values.
concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Concatenates three sources eagerly into a single stream of values.
concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Concatenates four sources eagerly into a single stream of values.
concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Concatenates five sources eagerly into a single stream of values.
concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Concatenates six sources eagerly into a single stream of values.
concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Concatenates seven sources eagerly into a single stream of values.
concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Concatenates eight sources eagerly into a single stream of values.
concatEager(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Concatenates nine sources eagerly into a single stream of values.
concatEager(Iterable<? extends Observable<? extends T>>) - Static method in class rx . Observable: Concatenates a sequence of Observables eagerly into a single stream of values.
concatEager(Iterable<? extends Observable<? extends T>>, int) - Static method in class rx . Observable: Concatenates a sequence of Observables eagerly into a single stream of values.
concatEager(Observable<? extends Observable<? extends T>>) - Static method in class rx . Observable: Concatenates an Observable sequence of Observables eagerly into a single stream of values.
concatEager(Observable<? extends Observable<? extends T>>, int) - Static method in class rx . Observable: Concatenates an Observable sequence of Observables eagerly into a single stream of values.
concatMap(Func1<? super T, ? extends Observable<? extends R>>) - Method in class rx . Observable: Returns a new Observable that emits items resulting from applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then emitting the items that result from concatinating those resulting Observables.
concatMapEager(Func1<? super T, ? extends Observable<? extends R>>) - Method in class rx . Observable: Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable.
concatMapEager(Func1<? super T, ? extends Observable<? extends R>>, int) - Method in class rx . Observable: Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable.
concatWith(Observable<? extends T>) - Method in class rx . Observable: Returns an Observable that emits the items emitted from the current Observable, then the next, one after the other, without interleaving them.
concatWith(Single<? extends T>) - Method in class rx . Single: Returns an Observable that emits the item emitted by the source Single, then the item emitted by the specified Single.
ConcurrentCircularArrayQueue < E> - Class in rx.internal.util.unsafe: A concurrent access enabling class used by circular array based queues this class exposes an offset computation method along with differently memory fenced load/store methods into the underlying array.
ConcurrentCircularArrayQueue(int) - Constructor for class rx .internal .util .unsafe . ConcurrentCircularArrayQueue
ConcurrentSequencedCircularArrayQueue < E> - Class in rx.internal.util.unsafe
ConcurrentSequencedCircularArrayQueue(int) - Constructor for class rx .internal .util .unsafe . ConcurrentSequencedCircularArrayQueue
connect(Action1<? super Subscription>) - Method in class rx .internal .operators . OperatorMulticast
connect(Action1<? super Subscription>) - Method in class rx .internal .operators . OperatorPublish
connect(Action1<? super Subscription>) - Method in class rx .internal .operators . OperatorReplay
connect() - Method in class rx .observables . ConnectableObservable: Instructs the ConnectableObservable to begin emitting the items from its underlying Observable to its Subscribers.
connect(Action1<? super Subscription>) - Method in class rx .observables . ConnectableObservable: Instructs the ConnectableObservable to begin emitting the items from its underlying Observable to its Subscribers.
ConnectableObservable < T> - Class in rx.observables: A ConnectableObservable resembles an ordinary Observable, except that it does not begin emitting items when it is subscribed to, but only when its ConnectableObservable.connect() method is called.
ConnectableObservable(Observable.OnSubscribe<T>) - Constructor for class rx .observables . ConnectableObservable
consumerBuffer - Variable in class rx .internal .util .atomic . SpscLinkedArrayQueue
consumerBuffer - Variable in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
consumerIndex - Variable in class rx .internal .util .atomic . SpscLinkedArrayQueue
consumerIndex - Variable in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
consumerMask - Variable in class rx .internal .util .atomic . SpscLinkedArrayQueue
consumerMask - Variable in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
contains(Object) - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
contains(Object) - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
contains(Object) - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
contains(Object) - Method in class rx .internal .util . SynchronizedQueue
contains(Object) - Method in class rx . Observable: Returns an Observable that emits a Boolean that indicates whether the source Observable emitted a specified item.
containsAll(Collection<?>) - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
containsAll(Collection<?>) - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
containsAll(Collection<?>) - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
containsAll(Collection<?>) - Method in class rx .internal .util . SynchronizedQueue
convertSelector(Func1<? super T, ? extends Iterable<? extends U>>) - Static method in class rx .internal .operators . OperatorMapPair: Creates the function that generates a Observable based on an item emitted by another Observable.
count() - Method in class rx .internal .util . RxRingBuffer
count() - Method in class rx . Observable: Returns an Observable that emits the count of the total number of items emitted by the source Observable.
countLong() - Method in class rx . Observable: Returns an Observable that counts the total number of items emitted by the source Observable and emits this count as a 64-bit Long.
create() - Static method in class rx .internal .operators . BufferUntilSubscriber
create(Observable<T>) - Static method in class rx .internal .operators . OnSubscribeSingle
create(Observable<? extends T>) - Static method in class rx .internal .operators . OperatorPublish: Creates a OperatorPublish instance to publish values of the given source observable.
create(Observable<? extends T>, Func1<? super Observable<T>, ? extends Observable<R>>) - Static method in class rx .internal .operators . OperatorPublish
create(Observable<? extends T>) - Static method in class rx .internal .operators . OperatorReplay: Creates a replaying ConnectableObservable with an unbounded buffer.
create(Observable<? extends T>, int) - Static method in class rx .internal .operators . OperatorReplay: Creates a replaying ConnectableObservable with a size bound buffer.
create(Observable<? extends T>, long, TimeUnit, Scheduler) - Static method in class rx .internal .operators . OperatorReplay: Creates a replaying ConnectableObservable with a time bound buffer.
create(Observable<? extends T>, long, TimeUnit, Scheduler, int) - Static method in class rx .internal .operators . OperatorReplay: Creates a replaying ConnectableObservable with a size and time bound buffer.
create() - Static method in class rx .internal .operators . UnicastSubject: Constructs an empty UnicastSubject instance with the default capacity hint of 16 elements.
create(int) - Static method in class rx .internal .operators . UnicastSubject: Constructs an empty UnicastSubject instance with a capacity hint.
create(T) - Static method in class rx .internal .util . ScalarSynchronousObservable
create(Observable.OnSubscribe<T>) - Static method in class rx . Observable: Returns an Observable that will execute the specified function when a Subscriber subscribes to it.
create(Action1<AbstractOnSubscribe.SubscriptionState<T, S>>) - Static method in class rx .observables . AbstractOnSubscribe: Creates an AbstractOnSubscribe instance which calls the provided next action.
create(Action1<AbstractOnSubscribe.SubscriptionState<T, S>>, Func1<? super Subscriber<? super T>, ? extends S>) - Static method in class rx .observables . AbstractOnSubscribe: Creates an AbstractOnSubscribe instance which creates a custom state with the onSubscribe function and calls the provided next action.
create(Action1<AbstractOnSubscribe.SubscriptionState<T, S>>, Func1<? super Subscriber<? super T>, ? extends S>, Action1<? super S>) - Static method in class rx .observables . AbstractOnSubscribe: Creates an AbstractOnSubscribe instance which creates a custom state with the onSubscribe function, calls the provided next action and calls the onTerminated action to release the state when its no longer needed.
create(K, Observable.OnSubscribe<T>) - Static method in class rx .observables . GroupedObservable: Returns an Observable that will execute the specified function when a Subscriber subscribes to it.
create(Action1<? super T>) - Static method in class rx .observers . Observers: Creates an Observer that receives the emissions of any Observable it subscribes to via onNext but ignores onCompleted notifications; it will throw an OnErrorNotImplementedException if onError is invoked.
create(Action1<? super T>, Action1<Throwable>) - Static method in class rx .observers . Observers: Creates an Observer that receives the emissions of any Observable it subscribes to via onNext and handles any onError notification but ignores an onCompleted notification.
create(Action1<? super T>, Action1<Throwable>, Action0) - Static method in class rx .observers . Observers: Creates an Observer that receives the emissions of any Observable it subscribes to via onNext and handles any onError or onCompleted notifications.
create(Action1<? super T>) - Static method in class rx .observers . Subscribers: Creates a Subscriber that receives the emissions of any Observable it subscribes to via onNext but ignores onError and onCompleted notifications.
create(Action1<? super T>, Action1<Throwable>) - Static method in class rx .observers . Subscribers: Creates an Subscriber that receives the emissions of any Observable it subscribes to via onNext and handles any onError notification but ignores an onCompleted notification.
create(Action1<? super T>, Action1<Throwable>, Action0) - Static method in class rx .observers . Subscribers: Creates an Subscriber that receives the emissions of any Observable it subscribes to via onNext and handles any onError or onCompleted notifications.
create() - Static method in class rx .observers . TestSubscriber
create(long) - Static method in class rx .observers . TestSubscriber
create(Observer<T>, long) - Static method in class rx .observers . TestSubscriber
create(Subscriber<T>) - Static method in class rx .observers . TestSubscriber
create(Observer<T>) - Static method in class rx .observers . TestSubscriber
create(Single.OnSubscribe<T>) - Static method in class rx . Single: Returns a Single that will execute the specified function when a SingleSubscriber executes it or a Subscriber subscribes to it.
create() - Static method in class rx .subjects . AsyncSubject: Creates and returns a new AsyncSubject.
create() - Static method in class rx .subjects . BehaviorSubject: Creates a BehaviorSubject without a default item.
create(T) - Static method in class rx .subjects . BehaviorSubject: Creates a BehaviorSubject that emits the last item it observed and all subsequent items to each Observer that subscribes to it.
create() - Static method in class rx .subjects . PublishSubject: Creates and returns a new PublishSubject.
create() - Static method in class rx .subjects . ReplaySubject: Creates an unbounded replay subject.
create(int) - Static method in class rx .subjects . ReplaySubject: Creates an unbounded replay subject with the specified initial buffer capacity.
create(TestScheduler) - Static method in class rx .subjects . TestSubject: Creates and returns a new TestSubject.
create() - Static method in class rx .subscriptions . BooleanSubscription: Creates a BooleanSubscription without unsubscribe behavior.
create(Action0) - Static method in class rx .subscriptions . BooleanSubscription: Creates a BooleanSubscription with a specified function to invoke upon unsubscribe.
create(Action0) - Static method in class rx .subscriptions . Subscriptions: Creates and returns a Subscription that invokes the given Action0 when unsubscribed.
createObject() - Method in class rx .internal .util . ObjectPool: Creates a new object.
createOnCompleted() - Static method in class rx . Notification: Creates and returns a Notification of variety Kind.OnCompleted.
createOnCompleted(Class<T>) - Static method in class rx . Notification: Creates and returns a Notification of variety Kind.OnCompleted.
createOnError(Throwable) - Static method in class rx . Notification: Creates and returns a Notification of variety Kind.OnError, and assigns it an exception.
createOnNext(T) - Static method in class rx . Notification: Creates and returns a Notification of variety Kind.OnNext, and assigns it a value.
createSingleState(Func0<? extends S>, Action3<? super S, Long, ? super Observer<Observable<? extends T>>>) - Static method in class rx .observables . AsyncOnSubscribe: Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createSingleState(Func0<? extends S>, Action3<? super S, Long, ? super Observer<Observable<? extends T>>>, Action1<? super S>) - Static method in class rx .observables . AsyncOnSubscribe: Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createSingleState(Func0<? extends S>, Action2<? super S, ? super Observer<? super T>>) - Static method in class rx .observables . SyncOnSubscribe: Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createSingleState(Func0<? extends S>, Action2<? super S, ? super Observer<? super T>>, Action1<? super S>) - Static method in class rx .observables . SyncOnSubscribe: Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createStateful(Func0<? extends S>, Func3<? super S, Long, ? super Observer<Observable<? extends T>>, ? extends S>, Action1<? super S>) - Static method in class rx .observables . AsyncOnSubscribe: Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createStateful(Func0<? extends S>, Func3<? super S, Long, ? super Observer<Observable<? extends T>>, ? extends S>) - Static method in class rx .observables . AsyncOnSubscribe: Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createStateful(Func0<? extends S>, Func2<? super S, ? super Observer<? super T>, ? extends S>, Action1<? super S>) - Static method in class rx .observables . SyncOnSubscribe: Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createStateful(Func0<? extends S>, Func2<? super S, ? super Observer<? super T>, ? extends S>) - Static method in class rx .observables . SyncOnSubscribe: Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createStateless(Action2<Long, ? super Observer<Observable<? extends T>>>) - Static method in class rx .observables . AsyncOnSubscribe: Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createStateless(Action2<Long, ? super Observer<Observable<? extends T>>>, Action0) - Static method in class rx .observables . AsyncOnSubscribe: Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createStateless(Action1<? super Observer<? super T>>) - Static method in class rx .observables . SyncOnSubscribe: Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createStateless(Action1<? super Observer<? super T>>, Action0) - Static method in class rx .observables . SyncOnSubscribe: Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
createWithSize(int) - Static method in class rx .subjects . ReplaySubject: Creates a size-bounded replay subject.
createWithTime(long, TimeUnit, Scheduler) - Static method in class rx .subjects . ReplaySubject: Creates a time-bounded replay subject.
createWithTimeAndSize(long, TimeUnit, int, Scheduler) - Static method in class rx .subjects . ReplaySubject: Creates a time- and size-bounded replay subject.
createWorker() - Method in class rx .internal .schedulers . EventLoopsScheduler
createWorker() - Method in class rx . Scheduler: Retrieves or creates a new Scheduler.Worker that represents serial execution of actions.
createWorker() - Method in class rx .schedulers . ImmediateScheduler
createWorker() - Method in class rx .schedulers . NewThreadScheduler
createWorker() - Method in class rx .schedulers . TestScheduler
createWorker() - Method in class rx .schedulers . TrampolineScheduler
currentConsumerIndex() - Method in interface rx .internal .util .unsafe . QueueProgressIndicators: This method has no concurrent visibility semantics.
currentConsumerIndex() - Method in class rx .internal .util .unsafe . SpscUnboundedArrayQueue
currentProducerIndex() - Method in interface rx .internal .util .unsafe . QueueProgressIndicators: This method has no concurrent visibility semantics.
currentProducerIndex() - Method in class rx .internal .util .unsafe . SpscUnboundedArrayQueue

D

debounce(Func1<? super T, ? extends Observable>) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable, except that it drops items emitted by the source Observable that are followed by another item within a computed debounce duration.
debounce(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable, except that it drops items emitted by the source Observable that are followed by newer items before a timeout value expires.
debounce(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable, except that it drops items emitted by the source Observable that are followed by newer items before a timeout value expires on a specified Scheduler.
defaultIfEmpty(T) - Method in class rx . Observable: Returns an Observable that emits the items emitted by the source Observable or a specified default item if the source Observable is empty.
DefaultMultimapCollectionFactory() - Constructor for class rx .internal .operators . OperatorToMultimap.DefaultMultimapCollectionFactory
DefaultToMapFactory() - Constructor for class rx .internal .operators . OperatorToMap.DefaultToMapFactory
DefaultToMultimapFactory() - Constructor for class rx .internal .operators . OperatorToMultimap.DefaultToMultimapFactory
defer(Func0<Observable<T>>) - Static method in class rx . Observable: Returns an Observable that calls an Observable factory to create an Observable for each new Observer that subscribes.
defer(Callable<Single<T>>) - Static method in class rx . Single: Returns a Single that calls a Single factory to create a Single for each new Observer that subscribes.
delay(Func0<? extends Observable>, Func1<? super T, ? extends Observable<V>>) - Method in class rx . Observable: Returns an Observable that delays the subscription to and emissions from the souce Observable via another Observable on a per-item basis.
delay(Func1<? super T, ? extends Observable>) - Method in class rx . Observable: Returns an Observable that delays the emissions of the source Observable via another Observable on a per-item basis.
delay(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits the items emitted by the source Observable shifted forward in time by a specified delay.
delay(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits the items emitted by the source Observable shifted forward in time by a specified delay.
delay(long, TimeUnit, Scheduler) - Method in class rx . Single: Returns an Single that emits the items emitted by the source Single shifted forward in time by a specified delay.
delay(long, TimeUnit) - Method in class rx . Single: Returns an Single that emits the items emitted by the source Single shifted forward in time by a specified delay.
delaySubscription(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that delays the subscription to the source Observable by a given amount of time.
delaySubscription(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that delays the subscription to the source Observable by a given amount of time, both waiting and subscribing on a given Scheduler.
delaySubscription(Func0<? extends Observable>) - Method in class rx . Observable: Returns an Observable that delays the subscription to the source Observable until a second Observable emits an item.
dematerialize() - Method in class rx . Observable: Returns an Observable that reverses the effect of materialize by transforming the Notification objects emitted by the source Observable into the items or notifications they represent.
deregisterExecutor(ScheduledExecutorService) - Static method in class rx .internal .schedulers . NewThreadWorker: Deregisters the executor service.
distinct() - Method in class rx . Observable: Returns an Observable that emits all items emitted by the source Observable that are distinct.
distinct(Func1<? super T, ? extends U>) - Method in class rx . Observable: Returns an Observable that emits all items emitted by the source Observable that are distinct according to a key selector function.
distinctUntilChanged() - Method in class rx . Observable: Returns an Observable that emits all items emitted by the source Observable that are distinct from their immediate predecessors.
distinctUntilChanged(Func1<? super T, ? extends U>) - Method in class rx . Observable: Returns an Observable that emits all items emitted by the source Observable that are distinct from their immediate predecessors, according to a key selector function.
doOnCompleted(Action0) - Method in class rx . Observable: Modifies the source Observable so that it invokes an action when it calls onCompleted.
doOnEach(Action1<Notification<? super T>>) - Method in class rx . Observable: Modifies the source Observable so that it invokes an action for each item it emits.
doOnEach(Observer<? super T>) - Method in class rx . Observable: Modifies the source Observable so that it notifies an Observer for each item it emits.
doOnError(Action1<Throwable>) - Method in class rx . Observable: Modifies the source Observable so that it invokes an action if it calls onError.
doOnError(Action1<Throwable>) - Method in class rx . Single: Modifies the source Single so that it invokes an action if it calls onError.
doOnNext(Action1<? super T>) - Method in class rx . Observable: Modifies the source Observable so that it invokes an action when it calls onNext.
doOnRequest(Action1<Long>) - Method in class rx . Observable: Modifies the source Observable so that it invokes the given action when it receives a request for more items.
doOnSubscribe(Action0) - Method in class rx . Observable: Modifies the source Observable so that it invokes the given action when it is subscribed from its subscribers.
doOnSuccess(Action1<? super T>) - Method in class rx . Single: Modifies the source Single so that it invokes an action when it calls onSuccess.
doOnTerminate(Action0) - Method in class rx . Observable: Modifies the source Observable so that it invokes an action when it calls onCompleted or onError.
doOnUnsubscribe(Action0) - Method in class rx . Observable: Modifies the source Observable so that it invokes the given action when it is unsubscribed from its subscribers.
drain() - Method in class rx .internal .util . BackpressureDrainManager: Try to drain the "queued" elements and terminal events by considering the available and requested event counts.

E

element() - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
element() - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
element() - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
element() - Method in class rx .internal .util . SynchronizedQueue
elementAt(int) - Method in class rx . Observable: Returns an Observable that emits the single item at a specified index in a sequence of emissions from a source Observbable.
elementAtOrDefault(int, T) - Method in class rx . Observable: Returns an Observable that emits the item found at a specified index in a sequence of emissions from a source Observable, or a default item if that index is out of range.
emitLoop() - Method in class rx .internal .producers . ProducerArbiter
emitting - Variable in class rx .internal .util . BackpressureDrainManager: Indicates if one is in emitting phase, guarded by this.
empty() - Static method in class rx .functions . Actions
empty() - Static method in class rx . Observable: Returns an Observable that emits no items to the Observer and immediately invokes its onCompleted method.
empty() - Static method in class rx .observers . Observers: Returns an inert Observer that does nothing in response to the emissions or notifications from any Observable it subscribes to but will throw an exception if its onError method is called.
empty() - Static method in class rx .observers . Subscribers: Returns an inert Subscriber that does nothing in response to the emissions or notifications from any Observable it subscribes to.
empty() - Static method in class rx .subscriptions . Subscriptions: Returns a Subscription to which unsubscribe does nothing except to change isUnsubscribed to true.
equals(Object) - Method in class rx .internal .util . SynchronizedQueue
equals(Object) - Method in class rx . Notification
equals(Object) - Method in class rx .schedulers . TimeInterval
equals(Object) - Method in class rx .schedulers . Timestamped
error(Throwable) - Method in class rx .internal .operators . NotificationLite: Create a lite onError notification.
error(Throwable) - Static method in class rx . Observable: Returns an Observable that invokes an Observer's onError method when the Observer subscribes to it.
error(Throwable) - Static method in class rx . Single: Returns a Single that invokes a subscriber's onError method when the subscriber subscribes to it.
ERROR_IN_RENDERING_SUFFIX - Static variable in class rx .plugins . RxJavaErrorHandler
EventLoopsScheduler - Class in rx.internal.schedulers
EventLoopsScheduler() - Constructor for class rx .internal .schedulers . EventLoopsScheduler: Create a scheduler with pool size equal to the available processor count and using least-recent worker selection policy.
exception - Variable in class rx .internal .util . BackpressureDrainManager: Indicates an error state, barrier is provided via terminated.
Exceptions - Class in rx.exceptions
exists(Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that emits true if any item emitted by the source Observable satisfies a specified condition, otherwise false.
Experimental - Annotation Type in rx.annotations: Signifies that a public API (public class, method or field) is will almost certainly be changed or removed in a future release.
extend(Func1<? super Observable.OnSubscribe<T>, ? extends R>) - Method in class rx . Observable: Passes all emitted values from this Observable to the provided conversion function to be collected and returned as a single value.

F

filter(Func1<? super T, Boolean>) - Method in class rx . Observable: Filters items emitted by an Observable by only emitting those that satisfy a specified predicate.
finallyDo(Action0) - Method in class rx . Observable: Registers an Action0 to be called when this Observable invokes either onCompleted or onError.
first() - Method in class rx . Observable: Returns an Observable that emits only the very first item emitted by the source Observable, or notifies of an NoSuchElementException if the source Observable is empty.
first(Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that emits only the very first item emitted by the source Observable that satisfies a specified condition, or notifies of an NoSuchElementException if no such items are emitted.
first() - Method in class rx .observables . BlockingObservable: Returns the first item emitted by this BlockingObservable, or throws NoSuchElementException if it emits no items.
first(Func1<? super T, Boolean>) - Method in class rx .observables . BlockingObservable: Returns the first item emitted by this BlockingObservable that matches a predicate, or throws NoSuchElementException if it emits no such item.
firstOrDefault(T) - Method in class rx . Observable: Returns an Observable that emits only the very first item emitted by the source Observable, or a default item if the source Observable completes without emitting anything.
firstOrDefault(T, Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that emits only the very first item emitted by the source Observable that satisfies a specified condition, or a default item if the source Observable emits no such items.
firstOrDefault(T) - Method in class rx .observables . BlockingObservable: Returns the first item emitted by this BlockingObservable, or a default value if it emits no items.
firstOrDefault(T, Func1<? super T, Boolean>) - Method in class rx .observables . BlockingObservable: Returns the first item emitted by this BlockingObservable that matches a predicate, or a default value if it emits no such items.
flatMap(Func1<? super T, ? extends Observable<? extends R>>) - Method in class rx . Observable: Returns an Observable that emits items based on applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then merging those resulting Observables and emitting the results of this merger.
flatMap(Func1<? super T, ? extends Observable<? extends R>>, int) - Method in class rx . Observable: Returns an Observable that emits items based on applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then merging those resulting Observables and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to these Observables.
flatMap(Func1<? super T, ? extends Observable<? extends R>>, Func1<? super Throwable, ? extends Observable<? extends R>>, Func0<? extends Observable<? extends R>>) - Method in class rx . Observable: Returns an Observable that applies a function to each item emitted or notification raised by the source Observable and then flattens the Observables returned from these functions and emits the resulting items.
flatMap(Func1<? super T, ? extends Observable<? extends R>>, Func1<? super Throwable, ? extends Observable<? extends R>>, Func0<? extends Observable<? extends R>>, int) - Method in class rx . Observable: Returns an Observable that applies a function to each item emitted or notification raised by the source Observable and then flattens the Observables returned from these functions and emits the resulting items, while limiting the maximum number of concurrent subscriptions to these Observables.
flatMap(Func1<? super T, ? extends Observable<? extends U>>, Func2<? super T, ? super U, ? extends R>) - Method in class rx . Observable: Returns an Observable that emits the results of a specified function to the pair of values emitted by the source Observable and a specified collection Observable.
flatMap(Func1<? super T, ? extends Observable<? extends U>>, Func2<? super T, ? super U, ? extends R>, int) - Method in class rx . Observable: Returns an Observable that emits the results of a specified function to the pair of values emitted by the source Observable and a specified collection Observable, while limiting the maximum number of concurrent subscriptions to these Observables.
flatMap(Func1<? super T, ? extends Single<? extends R>>) - Method in class rx . Single: Returns a Single that is based on applying a specified function to the item emitted by the source Single, where that function returns a Single.
flatMapIterable(Func1<? super T, ? extends Iterable<? extends R>>) - Method in class rx . Observable: Returns an Observable that merges each item emitted by the source Observable with the values in an Iterable corresponding to that item that is generated by a selector.
flatMapIterable(Func1<? super T, ? extends Iterable<? extends U>>, Func2<? super T, ? super U, ? extends R>) - Method in class rx . Observable: Returns an Observable that emits the results of applying a function to the pair of values from the source Observable and an Iterable corresponding to that item that is generated by a selector.
flatMapObservable(Func1<? super T, ? extends Observable<? extends R>>) - Method in class rx . Single: Returns an Observable that emits items based on applying a specified function to the item emitted by the source Observable, where that function returns an Observable.
forEach(Func1<? super E, Boolean>) - Method in class rx .internal .util . IndexedRingBuffer
forEach(Func1<? super E, Boolean>, int) - Method in class rx .internal .util . IndexedRingBuffer
forEach(Action1<? super T>) - Method in class rx . Observable: Subscribes to the Observable and receives notifications for each element.
forEach(Action1<? super T>, Action1<Throwable>) - Method in class rx . Observable: Subscribes to the Observable and receives notifications for each element and error events.
forEach(Action1<? super T>, Action1<Throwable>, Action0) - Method in class rx . Observable: Subscribes to the Observable and receives notifications for each element and the terminal events.
forEach(Action1<? super T>) - Method in class rx .observables . BlockingObservable: Invokes a method on each item emitted by this BlockingObservable and blocks until the Observable completes.
free() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Release the state if there are no more interest in it and it is not in use.
from(Throwable) - Static method in exception rx .exceptions . OnErrorThrowable: Converts a Throwable into an OnErrorThrowable.
from(Observable<? extends T>) - Static method in class rx .internal .operators . CachedObservable: Creates a cached Observable with a default capacity hint of 16.
from(Observable<? extends T>, int) - Static method in class rx .internal .operators . CachedObservable: Creates a cached Observable with the given capacity hint.
from(Future<? extends T>) - Static method in class rx . Observable: Converts a Future into an Observable.
from(Future<? extends T>, long, TimeUnit) - Static method in class rx . Observable: Converts a Future into an Observable, with a timeout on the Future.
from(Future<? extends T>, Scheduler) - Static method in class rx . Observable: Converts a Future, operating on a specified Scheduler, into an Observable.
from(Iterable<? extends T>) - Static method in class rx . Observable: Converts an Iterable sequence into an Observable that emits the items in the sequence.
from(T[]) - Static method in class rx . Observable: Converts an Array into an Observable that emits the items in the Array.
from(Observable<? extends T>) - Static method in class rx .observables . BlockingObservable: Converts an Observable into a BlockingObservable.
from(K, Observable<T>) - Static method in class rx .observables . GroupedObservable: Converts an Observable into a GroupedObservable with a particular key.
from(Observer<? super T>) - Static method in class rx .observers . Subscribers: Converts an Observer into a Subscriber.
from(Executor) - Static method in class rx .schedulers . Schedulers: Converts an Executor into a new Scheduler instance.
from(Future<? extends T>) - Static method in class rx . Single: Converts a Future into a Single.
from(Future<? extends T>, long, TimeUnit) - Static method in class rx . Single: Converts a Future into a Single, with a timeout on the Future.
from(Future<? extends T>, Scheduler) - Static method in class rx . Single: Converts a Future, operating on a specified Scheduler, into a Single.
from(Single<? extends T>) - Static method in class rx .singles . BlockingSingle: Converts a Single into a BlockingSingle.
from(Future<?>) - Static method in class rx .subscriptions . Subscriptions: Converts a Future into a Subscription and cancels it when unsubscribed.
from(Subscription...) - Static method in class rx .subscriptions . Subscriptions: Converts a set of Subscriptions into a CompositeSubscription that groups the multiple Subscriptions together and unsubscribes from all of them together.
fromAction(Action0) - Static method in class rx .functions . Functions: Converts an Action0 to a FuncN to allow heterogeneous handling of functions with different arities.
fromAction(Action1<? super T0>) - Static method in class rx .functions . Functions: Converts an Action1 to a FuncN to allow heterogeneous handling of functions with different arities.
fromAction(Action2<? super T0, ? super T1>) - Static method in class rx .functions . Functions: Converts an Action2 to a FuncN to allow heterogeneous handling of functions with different arities.
fromAction(Action3<? super T0, ? super T1, ? super T2>) - Static method in class rx .functions . Functions: Converts an Action3 to a FuncN to allow heterogeneous handling of functions with different arities.
fromCallable(Callable<? extends T>) - Static method in class rx . Observable: Returns an Observable that, when an observer subscribes to it, invokes a function you specify and then emits the value returned from that function.
fromCallable(Callable<? extends T>) - Static method in class rx . Single: Returns a Single that invokes passed function and emits its result for each new Observer that subscribes.
fromFunc(Func0<? extends R>) - Static method in class rx .functions . Functions: Converts a Func0 to a FuncN to allow heterogeneous handling of functions with different arities.
fromFunc(Func1<? super T0, ? extends R>) - Static method in class rx .functions . Functions: Converts a Func1 to a FuncN to allow heterogeneous handling of functions with different arities.
fromFunc(Func2<? super T0, ? super T1, ? extends R>) - Static method in class rx .functions . Functions: Converts a Func2 to a FuncN to allow heterogeneous handling of functions with different arities.
fromFunc(Func3<? super T0, ? super T1, ? super T2, ? extends R>) - Static method in class rx .functions . Functions: Converts a Func3 to a FuncN to allow heterogeneous handling of functions with different arities.
fromFunc(Func4<? super T0, ? super T1, ? super T2, ? super T3, ? extends R>) - Static method in class rx .functions . Functions: Converts a Func4 to a FuncN to allow heterogeneous handling of functions with different arities.
fromFunc(Func5<? super T0, ? super T1, ? super T2, ? super T3, ? super T4, ? extends R>) - Static method in class rx .functions . Functions: Converts a Func5 to a FuncN to allow heterogeneous handling of functions with different arities.
fromFunc(Func6<? super T0, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>) - Static method in class rx .functions . Functions: Converts a Func6 to a FuncN to allow heterogeneous handling of functions with different arities.
fromFunc(Func7<? super T0, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>) - Static method in class rx .functions . Functions: Converts a Func7 to a FuncN to allow heterogeneous handling of functions with different arities.
fromFunc(Func8<? super T0, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>) - Static method in class rx .functions . Functions: Converts a Func8 to a FuncN to allow heterogeneous handling of functions with different arities.
fromFunc(Func9<? super T0, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>) - Static method in class rx .functions . Functions: Converts a Func9 to a FuncN to allow heterogeneous handling of functions with different arities.
Func0 < R> - Interface in rx.functions: Represents a function with zero arguments.
Func1 < T , R> - Interface in rx.functions: Represents a function with one argument.
Func2 < T1 , T2 , R> - Interface in rx.functions: Represents a function with two arguments.
Func3 < T1 , T2 , T3 , R> - Interface in rx.functions: Represents a function with three arguments.
Func4 < T1 , T2 , T3 , T4 , R> - Interface in rx.functions: Represents a function with four arguments.
Func5 < T1 , T2 , T3 , T4 , T5 , R> - Interface in rx.functions: Represents a function with five arguments.
Func6 < T1 , T2 , T3 , T4 , T5 , T6 , R> - Interface in rx.functions: Represents a function with six arguments.
Func7 < T1 , T2 , T3 , T4 , T5 , T6 , T7 , R> - Interface in rx.functions: Represents a function with seven arguments.
Func8 < T1 , T2 , T3 , T4 , T5 , T6 , T7 , T8 , R> - Interface in rx.functions: Represents a function with eight arguments.
Func9 < T1 , T2 , T3 , T4 , T5 , T6 , T7 , T8 , T9 , R> - Interface in rx.functions: Represents a function with nine arguments.
FuncN < R> - Interface in rx.functions: Represents a vector-argument function.
Function - Interface in rx.functions: All Func and Action interfaces extend from this.
Functions - Class in rx.functions

G

generateState() - Method in class rx .observables . AsyncOnSubscribe: Executed once when subscribed to by a subscriber (via OnSubscribe#call(Subscriber)) to produce a state value.
generateState() - Method in class rx .observables . SyncOnSubscribe: Executed once when subscribed to by a subscriber (via OnSubscribe#call(Subscriber)) to produce a state value.
GenericScheduledExecutorService - Class in rx.internal.schedulers: A default ScheduledExecutorService that can be used for scheduling actions when a Scheduler implementation doesn't have that ability.
get() - Method in class rx .internal .util . ScalarSynchronousObservable
get() - Method in class rx .subscriptions . MultipleAssignmentSubscription: Gets the underlying subscription.
get() - Method in class rx .subscriptions . RefCountSubscription: Returns a new sub-subscription
get() - Method in class rx .subscriptions . SerialSubscription: Retrieves the current Subscription that is being represented by this SerialSubscription.
getActual() - Method in class rx .observers . SafeSubscriber: Returns the Subscriber underlying this SafeSubscriber.
getAndAddInt(Object, long, int) - Static method in class rx .internal .util .unsafe . UnsafeAccess
getAndAddRequest(AtomicLongFieldUpdater<T>, T, long) - Static method in class rx .internal .operators . 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 rx .internal .operators . BackpressureUtils: Adds n to requested and returns the value prior to addition once the addition is successful (uses CAS semantics).
getAndIncrementInt(Object, long) - Static method in class rx .internal .util .unsafe . UnsafeAccess
getAndNullValue() - Method in class rx .internal .util .atomic . LinkedQueueNode: Gets the current value and nulls out the reference to it from this node.
getAndroidApiVersion() - Static method in class rx .internal .util . PlatformDependent: Returns version of Android API.
getAndSetInt(Object, long, int) - Static method in class rx .internal .util .unsafe . UnsafeAccess
getCause() - Method in exception rx .exceptions . CompositeException
getComputationScheduler() - Method in class rx .plugins . RxJavaSchedulersHook: Scheduler to return from Schedulers.computation() or null if default should be used.
getDefaultInstance() - Static method in class rx .plugins . RxJavaSchedulersHook
getError(Object) - Method in class rx .internal .operators . NotificationLite: Returns the Throwable corresponding to this OnError lite notification.
getErrorHandler() - Method in class rx .plugins . RxJavaPlugins: Retrieves an instance of RxJavaErrorHandler to use based on order of precedence as defined in RxJavaPlugins class header.
getEvents() - Method in class rx .observers . TestObserver: Get a list containing all of the items and notifications received by this observer, where the items will be given as-is, any error notifications will be represented by their Throwables, and any sequence-complete notifications will be represented by their Notification objects.
getExceptions() - Method in exception rx .exceptions . CompositeException: Retrieves the list of exceptions that make up the CompositeException
getFinalCause(Throwable) - Static method in class rx .exceptions . Exceptions: Get the Throwable at the end of the causality-chain for a particular Throwable
getInstance() - Static method in class rx .internal .schedulers . GenericScheduledExecutorService: See class Javadoc for information on what this is for and how to use.
getInstance() - Static method in class rx .internal .util . IndexedRingBuffer
getInstance() - Static method in class rx .plugins . RxJavaPlugins: Retrieves the single RxJavaPlugins instance.
getIntervalInMilliseconds() - Method in class rx .schedulers . TimeInterval: Returns the time interval, expressed in milliseconds.
getIOScheduler() - Method in class rx .plugins . RxJavaSchedulersHook: Scheduler to return from Schedulers.io() or null if default should be used.
getIterator() - Method in class rx .observables . BlockingObservable: Returns an Iterator that iterates over all items emitted by this BlockingObservable.
getKey() - Method in class rx .observables . GroupedObservable: Returns the key that identifies the group of items emited by this GroupedObservable
getKind() - Method in class rx . Notification: Retrieves the kind of this notification: OnNext, OnError, or OnCompleted
getLastSeenThread() - Method in class rx .observers . TestSubscriber: Returns the last thread that was in use when an item or notification was received by this Subscriber.
getMessage() - Method in exception rx .exceptions . CompositeException
getNewThreadScheduler() - Method in class rx .plugins . RxJavaSchedulersHook: Scheduler to return from Schedulers.newThread() or null if default should be used.
getObservableExecutionHook() - Method in class rx .plugins . RxJavaPlugins: Retrieves the instance of RxJavaObservableExecutionHook to use based on order of precedence as defined in RxJavaPlugins class header.
getOnCompletedEvents() - Method in class rx .observers . TestObserver: Get the Notifications representing each time this observer was notified of sequence completion via TestObserver.onCompleted(), as a List.
getOnCompletedEvents() - Method in class rx .observers . TestSubscriber: Returns the Notifications representing each time this Subscriber was notified of sequence completion via TestSubscriber.onCompleted(), as a List.
getOnErrorEvents() - Method in class rx .observers . TestObserver: Get the Throwables this observer was notified of via TestObserver.onError(java.lang.Throwable) as a List.
getOnErrorEvents() - Method in class rx .observers . TestSubscriber: Returns the Throwables this Subscriber was notified of via TestSubscriber.onError(java.lang.Throwable) as a List.
getOnNextEvents() - Method in class rx .observers . TestObserver: Get the sequence of items observed by this observer, as an ordered List.
getOnNextEvents() - Method in class rx .observers . TestSubscriber: Returns the sequence of items observed by this Subscriber, as an ordered List.
getSchedulersHook() - Method in class rx .plugins . RxJavaPlugins: Retrieves the instance of RxJavaSchedulersHook to use based on order of precedence as defined in the RxJavaPlugins class header.
getSpmcInstance() - Static method in class rx .internal .util . RxRingBuffer
getSpscInstance() - Static method in class rx .internal .util . RxRingBuffer
getThrowable() - Method in class rx . Notification: Retrieves the exception associated with this (onError) notification.
getThrowable() - Method in class rx .subjects . AsyncSubject: Returns the Throwable that terminated the Subject.
getThrowable() - Method in class rx .subjects . BehaviorSubject: Returns the Throwable that terminated the Subject.
getThrowable() - Method in class rx .subjects . PublishSubject: Returns the Throwable that terminated the Subject.
getThrowable() - Method in class rx .subjects . ReplaySubject: Returns the Throwable that terminated the Subject.
getThrowable() - Method in class rx .subjects . SerializedSubject: Deprecated.
this method is scheduled to be removed in the next release
getThrowable() - Method in class rx .subjects . Subject: Deprecated.
this method will be moved to each Subject class individually in the next release
getTimestampMillis() - Method in class rx .schedulers . Timestamped: Returns the timestamp, expressed in milliseconds.
getValue() - Method in exception rx .exceptions . OnErrorThrowable: Get the value associated with this OnErrorThrowable
getValue() - Method in exception rx .exceptions . OnErrorThrowable.OnNextValue: Retrieve the item that the Observable was trying to emit at the time this exception occurred.
getValue(Object) - Method in class rx .internal .operators . NotificationLite: Returns the item corresponding to this OnNext lite notification.
getValue(Object) - Method in class rx .internal .util . RxRingBuffer
getValue() - Method in class rx . Notification: Retrieves the item associated with this (onNext) notification.
getValue() - Method in class rx .schedulers . TimeInterval: Returns the item that was emitted by the Observable after this time interval.
getValue() - Method in class rx .schedulers . Timestamped: Returns the value embedded in the Timestamped object.
getValue() - Method in class rx .subjects . AsyncSubject: Returns the current value of the Subject if there is such a value and the subject hasn't terminated with an exception.
getValue() - Method in class rx .subjects . BehaviorSubject: Returns the current value of the Subject if there is such a value and the subject hasn't terminated yet.
getValue() - Method in class rx .subjects . PublishSubject: Deprecated.
this method is scheduled to be removed in the next release
getValue() - Method in class rx .subjects . ReplaySubject
getValue() - Method in class rx .subjects . SerializedSubject: Deprecated.
this method is scheduled to be removed in the next release
getValue() - Method in class rx .subjects . Subject: Deprecated.
this method will be moved to each Subject class individually in the next release
getValues(T[]) - Method in class rx .subjects . AsyncSubject: Deprecated.
getValues(T[]) - Method in class rx .subjects . BehaviorSubject
getValues() - Method in class rx .subjects . PublishSubject: Deprecated.
this method is scheduled to be removed in the next release
getValues(T[]) - Method in class rx .subjects . PublishSubject: Deprecated.
this method is scheduled to be removed in the next release
getValues(T[]) - Method in class rx .subjects . ReplaySubject: Returns a snapshot of the currently buffered non-terminal events into the provided a array or creates a new array if it has not enough capacity.
getValues() - Method in class rx .subjects . SerializedSubject: Deprecated.
this method is scheduled to be removed in the next release
getValues(T[]) - Method in class rx .subjects . SerializedSubject: Deprecated.
this method is scheduled to be removed in the next release
getValues() - Method in class rx .subjects . Subject: Deprecated.
this method will be moved to each Subject class individually in the next release
getValues(T[]) - Method in class rx .subjects . Subject: Deprecated.
this method will be moved to each Subject class individually in the next release
groupBy(Func1<? super T, ? extends K>, Func1<? super T, ? extends R>) - Method in class rx . Observable: Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as GroupedObservables, one GroupedObservable per group.
groupBy(Func1<? super T, ? extends K>) - Method in class rx . Observable: Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as GroupedObservables, one GroupedObservable per group.
GroupedObservable < K , T> - Class in rx.observables: An Observable that has been grouped by key, the value of which can be obtained with GroupedObservable.getKey().
GroupedObservable(K, Observable.OnSubscribe<T>) - Constructor for class rx .observables . GroupedObservable
groupJoin(Observable<T2>, Func1<? super T, ? extends Observable<D1>>, Func1<? super T2, ? extends Observable<D2>>, Func2<? super T, ? super Observable<T2>, ? extends R>) - Method in class rx . Observable: Returns an Observable that correlates two Observables when they overlap in time and groups the results.

H

handleError(Throwable) - Method in class rx .plugins . RxJavaErrorHandler: Receives all Exceptions from an Observable passed to Observer.onError(Throwable).
handleException(Throwable) - Static method in class rx .internal .util . RxJavaPluginUtils
handleOnNextValueRendering(Object) - Method in class rx .plugins . RxJavaErrorHandler: Receives items causing OnErrorThrowable.OnNextValue and gives a chance to choose the String representation of the item in the OnNextValue stacktrace rendering.
hasAnyValue() - Method in class rx .subjects . ReplaySubject
hasCompleted() - Method in class rx .subjects . AsyncSubject: Check if the Subject has terminated normally.
hasCompleted() - Method in class rx .subjects . BehaviorSubject: Check if the Subject has terminated normally.
hasCompleted() - Method in class rx .subjects . PublishSubject: Check if the Subject has terminated normally.
hasCompleted() - Method in class rx .subjects . ReplaySubject: Check if the Subject has terminated normally.
hasCompleted() - Method in class rx .subjects . SerializedSubject: Deprecated.
this method is scheduled to be removed in the next release
hasCompleted() - Method in class rx .subjects . Subject: Deprecated.
this method will be moved to each Subject class individually in the next release
hashCode() - Method in class rx .internal .util . SynchronizedQueue
hashCode() - Method in class rx . Notification
hashCode() - Method in class rx .schedulers . TimeInterval
hashCode() - Method in class rx .schedulers . Timestamped
hasNext() - Method in class rx .internal .operators . BlockingOperatorToIterator.SubscriberIterator
hasObservers() - Method in class rx .internal .operators . BufferUntilSubscriber
hasObservers() - Method in class rx .internal .operators . UnicastSubject
hasObservers() - Method in class rx .subjects . AsyncSubject
hasObservers() - Method in class rx .subjects . BehaviorSubject
hasObservers() - Method in class rx .subjects . PublishSubject
hasObservers() - Method in class rx .subjects . ReplaySubject
hasObservers() - Method in class rx .subjects . SerializedSubject
hasObservers() - Method in class rx .subjects . Subject: Indicates whether the Subject has Observers subscribed to it.
hasObservers() - Method in class rx .subjects . TestSubject
hasSubscriptions() - Method in class rx .internal .util . SubscriptionList: Returns true if this composite is not unsubscribed and contains subscriptions.
hasSubscriptions() - Method in class rx .subscriptions . CompositeSubscription: Returns true if this composite is not unsubscribed and contains subscriptions.
hasThrowable() - Method in class rx . Notification: Indicates whether this notification has an exception associated with it.
hasThrowable() - Method in class rx .subjects . AsyncSubject: Check if the Subject has terminated with an exception.
hasThrowable() - Method in class rx .subjects . BehaviorSubject: Check if the Subject has terminated with an exception.
hasThrowable() - Method in class rx .subjects . PublishSubject: Check if the Subject has terminated with an exception.
hasThrowable() - Method in class rx .subjects . ReplaySubject: Check if the Subject has terminated with an exception.
hasThrowable() - Method in class rx .subjects . SerializedSubject: Deprecated.
this method is scheduled to be removed in the next release
hasThrowable() - Method in class rx .subjects . Subject: Deprecated.
this method will be moved to each Subject class individually in the next release
hasValue() - Method in class rx . Notification: Indicates whether this notification has an item associated with it.
hasValue() - Method in class rx .subjects . AsyncSubject: Check if the Subject has a value.
hasValue() - Method in class rx .subjects . BehaviorSubject: Check if the Subject has a value.
hasValue() - Method in class rx .subjects . PublishSubject: Deprecated.
this method is scheduled to be removed in the next release
hasValue() - Method in class rx .subjects . ReplaySubject
hasValue() - Method in class rx .subjects . SerializedSubject: Deprecated.
this method is scheduled to be removed in the next release
hasValue() - Method in class rx .subjects . Subject: Deprecated.
this method will be moved to each Subject class individually in the next release
head() - Method in class rx .internal .util . LinkedArrayList: Returns the head buffer segment or null if the list is empty.

I

identity() - Static method in class rx .internal .util . UtilityFunctions: Returns a function that always returns the Object it is passed.
ignoreElements() - Method in class rx . Observable: Ignores all items emitted by the source Observable and only calls onCompleted or onError.
immediate() - Static method in class rx .schedulers . Schedulers: Creates and returns a Scheduler that executes work immediately on the current thread.
ImmediateScheduler - Class in rx.schedulers: Executes work immediately on the current thread.
IndexedRingBuffer < E> - Class in rx.internal.util: Add/Remove without object allocation (after initial construction).
indexInTail() - Method in class rx .internal .util . LinkedArrayList: Returns the index of the next slot in the tail buffer segment.
instance() - Static method in class rx .internal .operators . NotificationLite: Gets the NotificationLite singleton.
instance() - Static method in class rx .internal .operators . OperatorAsObservable
instance() - Static method in class rx .internal .operators . OperatorConcat
instance() - Static method in class rx .internal .operators . OperatorDematerialize
instance() - Static method in class rx .internal .operators . OperatorDistinct: Returns a singleton instance of OperatorDistinct that was built using the identity function for comparison ( new OperatorDistinct(UtilityFunctions.identity())).
instance() - Static method in class rx .internal .operators . OperatorDistinctUntilChanged: Returns a singleton instance of OperatorDistinctUntilChanged that was built using the identity function for comparison ( new OperatorDistinctUntilChanged(UtilityFunctions.identity())).
instance() - Static method in class rx .internal .operators . OperatorIgnoreElements
instance() - Static method in class rx .internal .operators . OperatorMaterialize
instance(boolean) - Static method in class rx .internal .operators . OperatorMerge
instance(boolean, int) - Static method in class rx .internal .operators . OperatorMerge: Creates a new instance of the operator with the given delayError and maxConcurrency settings.
instance() - Static method in class rx .internal .operators . OperatorOnBackpressureBuffer
instance() - Static method in class rx .internal .operators . OperatorOnBackpressureDrop
instance() - Static method in class rx .internal .operators . OperatorOnBackpressureLatest: Returns a singleton instance of the OnBackpressureLatest operator since it is stateless.
instance() - Static method in class rx .internal .operators . OperatorSerialize
instance() - Static method in class rx .internal .operators . OperatorSingle: Returns a singleton instance of OperatorSingle (if the stream is empty or has more than one element an error will be emitted) that is cast to the generic type.
instance() - Static method in class rx .internal .operators . OperatorSwitch
instance() - Static method in class rx .internal .operators . OperatorTakeLastOne
instance() - Static method in class rx .internal .operators . OperatorToObservableList
INSTANCE - Static variable in class rx .internal .schedulers . GenericScheduledExecutorService
interval(long, TimeUnit) - Static method in class rx . Observable: Returns an Observable that emits a sequential number every specified interval of time.
interval(long, TimeUnit, Scheduler) - Static method in class rx . Observable: Returns an Observable that emits a sequential number every specified interval of time, on a specified Scheduler.
interval(long, long, TimeUnit) - Static method in class rx . Observable: Returns an Observable that emits a 0L after the initialDelay and ever increasing numbers after each period of time thereafter.
interval(long, long, TimeUnit, Scheduler) - Static method in class rx . Observable: Returns an Observable that emits a 0L after the initialDelay and ever increasing numbers after each period of time thereafter, on a specified Scheduler.
io() - Static method in class rx .schedulers . Schedulers: Creates and returns a Scheduler intended for IO-bound work.
isAndroid() - Static method in class rx .internal .util . PlatformDependent: Returns true if and only if the current platform is Android.
isCompleted(Object) - Method in class rx .internal .operators . NotificationLite: Indicates whether or not the lite notification represents an onCompleted event.
isCompleted(Object) - Method in class rx .internal .util . RxRingBuffer
isEmpty() - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
isEmpty() - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
isEmpty() - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
isEmpty() - Method in class rx .internal .util . RxRingBuffer
isEmpty() - Method in class rx .internal .util . SynchronizedQueue
isEmpty() - Method in class rx .internal .util .unsafe . MpmcArrayQueue
isEmpty() - Method in class rx .internal .util .unsafe . SpmcArrayQueue
isEmpty() - Method in class rx . Observable: Returns an Observable that emits true if the source Observable is empty, otherwise false.
isError(Object) - Method in class rx .internal .operators . NotificationLite: Indicates whether or not the lite notification represents an onError event.
isError(Object) - Method in class rx .internal .util . RxRingBuffer
isNext(Object) - Method in class rx .internal .operators . NotificationLite: Indicates whether or not the lite notification represents an onNext event.
isNull(Object) - Method in class rx .internal .operators . NotificationLite: Indicates whether or not the lite notification represents a wrapped null onNext event.
isOnCompleted() - Method in class rx . Notification: Indicates whether this notification represents an onCompleted event.
isOnError() - Method in class rx . Notification: Indicates whether this notification represents an onError event.
isOnNext() - Method in class rx . Notification: Indicates whether this notification represents an onNext event.
isPowerOfTwo(int) - Static method in class rx .internal .util .unsafe . Pow2: Is this value a power of two.
isTerminated() - Method in class rx .internal .util . BackpressureDrainManager: Checks if a terminal state has been reached.
isUnsafeAvailable() - Static method in class rx .internal .util .unsafe . UnsafeAccess
isUnsubscribed() - Method in class rx .internal .schedulers . NewThreadWorker
isUnsubscribed() - Method in class rx .internal .schedulers . ScheduledAction
isUnsubscribed() - Method in class rx .internal .util . IndexedRingBuffer
isUnsubscribed() - Method in class rx .internal .util . RxRingBuffer
isUnsubscribed() - Method in class rx .internal .util . SubscriptionList
isUnsubscribed() - Method in class rx .internal .util . SynchronizedSubscription
isUnsubscribed() - Method in class rx . SingleSubscriber: Indicates whether this Subscriber has unsubscribed from its list of subscriptions.
isUnsubscribed() - Method in class rx . Subscriber: Indicates whether this Subscriber has unsubscribed from its list of subscriptions.
isUnsubscribed() - Method in interface rx . Subscription: Indicates whether this Subscription is currently unsubscribed.
isUnsubscribed() - Method in class rx .subscriptions . BooleanSubscription
isUnsubscribed() - Method in class rx .subscriptions . CompositeSubscription
isUnsubscribed() - Method in class rx .subscriptions . MultipleAssignmentSubscription
isUnsubscribed() - Method in class rx .subscriptions . RefCountSubscription
isUnsubscribed() - Method in class rx .subscriptions . SerialSubscription
isValueNull() - Method in exception rx .exceptions . OnErrorThrowable: Indicates whether or not there is a value associated with this OnErrorThrowable
iterator() - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
iterator() - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
iterator() - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
iterator() - Method in class rx .internal .util . SynchronizedQueue
iterator() - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue
iterator() - Method in class rx .internal .util .unsafe . SpscUnboundedArrayQueue

J

join(Observable<TRight>, Func1<T, Observable<TLeftDuration>>, Func1<TRight, Observable<TRightDuration>>, Func2<T, TRight, R>) - Method in class rx . Observable: Correlates the items emitted by two Observables based on overlapping durations.
just(T) - Static method in class rx . Observable: Returns an Observable that emits a single item and then completes.
just(T, T) - Static method in class rx . Observable: Converts two items into an Observable that emits those items.
just(T, T, T) - Static method in class rx . Observable: Converts three items into an Observable that emits those items.
just(T, T, T, T) - Static method in class rx . Observable: Converts four items into an Observable that emits those items.
just(T, T, T, T, T) - Static method in class rx . Observable: Converts five items into an Observable that emits those items.
just(T, T, T, T, T, T) - Static method in class rx . Observable: Converts six items into an Observable that emits those items.
just(T, T, T, T, T, T, T) - Static method in class rx . Observable: Converts seven items into an Observable that emits those items.
just(T, T, T, T, T, T, T, T) - Static method in class rx . Observable: Converts eight items into an Observable that emits those items.
just(T, T, T, T, T, T, T, T, T) - Static method in class rx . Observable: Converts nine items into an Observable that emits those items.
just(T, T, T, T, T, T, T, T, T, T) - Static method in class rx . Observable: Converts ten items into an Observable that emits those items.
just(T) - Static method in class rx . Single: Returns a Single that emits a specified item.

K

kind(Object) - Method in class rx .internal .operators . NotificationLite: Indicates which variety a particular lite notification is.

L

last() - Method in class rx . Observable: Returns an Observable that emits the last item emitted by the source Observable or notifies observers of a NoSuchElementException if the source Observable is empty.
last(Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that emits only the last item emitted by the source Observable that satisfies a given condition, or notifies of a NoSuchElementException if no such items are emitted.
last() - Method in class rx .observables . BlockingObservable: Returns the last item emitted by this BlockingObservable, or throws NoSuchElementException if this BlockingObservable emits no items.
last(Func1<? super T, Boolean>) - Method in class rx .observables . BlockingObservable: Returns the last item emitted by this BlockingObservable that matches a predicate, or throws NoSuchElementException if it emits no such items.
lastOrDefault(T) - Method in class rx . Observable: Returns an Observable that emits only the last item emitted by the source Observable, or a default item if the source Observable completes without emitting any items.
lastOrDefault(T, Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that emits only the last item emitted by the source Observable that satisfies a specified condition, or a default item if no such item is emitted by the source Observable.
lastOrDefault(T) - Method in class rx .observables . BlockingObservable: Returns the last item emitted by this BlockingObservable, or a default value if it emits no items.
lastOrDefault(T, Func1<? super T, Boolean>) - Method in class rx .observables . BlockingObservable: Returns the last item emitted by this BlockingObservable that matches a predicate, or a default value if it emits no such items.
latest(Observable<? extends T>) - Static method in class rx .internal .operators . BlockingOperatorLatest: Returns an Iterable that blocks until or unless the Observable emits an item that has not been returned by the Iterable, then returns that item
latest() - Method in class rx .observables . BlockingObservable: Returns an Iterable that returns the latest item emitted by this BlockingObservable, waiting if necessary for one to become available.
left - Variable in class rx .internal .operators . OnSubscribeGroupJoin
leftDuration - Variable in class rx .internal .operators . OnSubscribeGroupJoin
lift(Observable.Operator<? extends R, ? super T>) - Method in class rx . Observable: Lifts a function to the current Observable and returns a new Observable that when subscribed to will pass the values of the current Observable through the Operator function.
limit(int) - Method in class rx . Observable: Returns an Observable that emits only the first count items emitted by the source Observable.
LinkedArrayList - Class in rx.internal.util: A list implementation which combines an ArrayList with a LinkedList to avoid copying values when the capacity needs to be increased.
LinkedArrayList(int) - Constructor for class rx .internal .util . LinkedArrayList: Constructor with the capacity hint of each array segment.
LinkedQueueNode < E> - Class in rx.internal.util.atomic
LinkedQueueNode() - Constructor for class rx .internal .util .atomic . LinkedQueueNode
LinkedQueueNode(E) - Constructor for class rx .internal .util .atomic . LinkedQueueNode
lpElement(long) - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue: A plain load (no ordering/fences) of an element from a given offset.
lpElement(E[], long) - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue: A plain load (no ordering/fences) of an element from a given offset.
lpValue() - Method in class rx .internal .util .atomic . LinkedQueueNode
lvElement(long) - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue: A volatile load (load + LoadLoad barrier) of an element from a given offset.
lvElement(E[], long) - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue: A volatile load (load + LoadLoad barrier) of an element from a given offset.
lvNext() - Method in class rx .internal .util .atomic . LinkedQueueNode
lvSequence(long[], long) - Method in class rx .internal .util .unsafe . ConcurrentSequencedCircularArrayQueue

M

map(Func1<? super T, ? extends R>) - Method in class rx . Observable: Returns an Observable that applies a specified function to each item emitted by the source Observable and emits the results of these function applications.
map(Func1<? super T, ? extends R>) - Method in class rx . Single: Returns a Single that applies a specified function to the item emitted by the source Single and emits the result of this function application.
mask - Variable in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue
materialize() - Method in class rx . Observable: Returns an Observable that represents all of the emissions and notifications from the source Observable into emissions marked with their original types within Notification objects.
merge(Iterable<? extends Observable<? extends T>>) - Static method in class rx . Observable: Flattens an Iterable of Observables into one Observable, without any transformation.
merge(Iterable<? extends Observable<? extends T>>, int) - Static method in class rx . Observable: Flattens an Iterable of Observables into one Observable, without any transformation, while limiting the number of concurrent subscriptions to these Observables.
merge(Observable<? extends Observable<? extends T>>) - Static method in class rx . Observable: Flattens an Observable that emits Observables into a single Observable that emits the items emitted by those Observables, without any transformation.
merge(Observable<? extends Observable<? extends T>>, int) - Static method in class rx . Observable: Flattens an Observable that emits Observables into a single Observable that emits the items emitted by those Observables, without any transformation, while limiting the maximum number of concurrent subscriptions to these Observables.
merge(Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens two Observables into a single Observable, without any transformation.
merge(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens three Observables into a single Observable, without any transformation.
merge(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens four Observables into a single Observable, without any transformation.
merge(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens five Observables into a single Observable, without any transformation.
merge(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens six Observables into a single Observable, without any transformation.
merge(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens seven Observables into a single Observable, without any transformation.
merge(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens eight Observables into a single Observable, without any transformation.
merge(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens nine Observables into a single Observable, without any transformation.
merge(Observable<? extends T>[]) - Static method in class rx . Observable: Flattens an Array of Observables into one Observable, without any transformation.
merge(Observable<? extends T>[], int) - Static method in class rx . Observable: Flattens an Array of Observables into one Observable, without any transformation, while limiting the number of concurrent subscriptions to these Observables.
merge(Single<? extends Single<? extends T>>) - Static method in class rx . Single: Flattens a Single that emits a Single into a single Single that emits the item emitted by the nested Single, without any transformation.
merge(Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Flattens two Singles into a single Observable, without any transformation.
merge(Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Flattens three Singles into a single Observable, without any transformation.
merge(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Flattens four Singles into a single Observable, without any transformation.
merge(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Flattens five Singles into a single Observable, without any transformation.
merge(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Flattens six Singles into a single Observable, without any transformation.
merge(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Flattens seven Singles into a single Observable, without any transformation.
merge(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Flattens eight Singles into a single Observable, without any transformation.
merge(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class rx . Single: Flattens nine Singles into a single Observable, without any transformation.
mergeDelayError(Observable<? extends Observable<? extends T>>) - Static method in class rx . Observable: Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them.
mergeDelayError(Observable<? extends Observable<? extends T>>, int) - Static method in class rx . Observable: Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to these Observables.
mergeDelayError(Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens two Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from each of the source Observables without being interrupted by an error notification from one of them.
mergeDelayError(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens three Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them.
mergeDelayError(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens four Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them.
mergeDelayError(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens five Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them.
mergeDelayError(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens six Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them.
mergeDelayError(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens seven Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them.
mergeDelayError(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens eight Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them.
mergeDelayError(Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Flattens nine Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them.
mergeWith(Observable<? extends T>) - Method in class rx . Observable: Flattens this and another Observable into a single Observable, without any transformation.
mergeWith(Single<? extends T>) - Method in class rx . Single: Flattens this and another Single into a single Observable, without any transformation.
MissingBackpressureException - Exception in rx.exceptions: Represents an exception that indicates that a Subscriber or operator attempted to apply reactive pull backpressure to an Observable that does not implement it.
MissingBackpressureException() - Constructor for exception rx .exceptions . MissingBackpressureException: Constructs the exception without any custom message.
MissingBackpressureException(String) - Constructor for exception rx .exceptions . MissingBackpressureException: Constructs the exception with the given customized message.
mostRecent(Observable<? extends T>, T) - Static method in class rx .internal .operators . BlockingOperatorMostRecent: Returns an Iterable that always returns the item most recently emitted by the Observable.
mostRecent(T) - Method in class rx .observables . BlockingObservable: Returns an Iterable that always returns the item most recently emitted by this BlockingObservable.
MpmcArrayQueue < E> - Class in rx.internal.util.unsafe: A Multi-Producer-Multi-Consumer queue based on a ConcurrentCircularArrayQueue.
MpmcArrayQueue(int) - Constructor for class rx .internal .util .unsafe . MpmcArrayQueue
MpscLinkedAtomicQueue < E> - Class in rx.internal.util.atomic: This is a direct Java port of the MPSC algorithm as presented on 1024 Cores by D.
MpscLinkedAtomicQueue() - Constructor for class rx .internal .util .atomic . MpscLinkedAtomicQueue
MpscLinkedQueue < E> - Class in rx.internal.util.unsafe: This is a direct Java port of the MPSC algorithm as presented on 1024 Cores by D.
MpscLinkedQueue() - Constructor for class rx .internal .util .unsafe . MpscLinkedQueue
multicastSelector(Func0<? extends ConnectableObservable>, Func1<? super Observable, ? extends Observable<R>>) - Static method in class rx .internal .operators . OperatorReplay: Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.
MultipleAssignmentSubscription - Class in rx.subscriptions: Subscription that can be checked for status such as in a loop inside an Observable to exit the loop if unsubscribed.
MultipleAssignmentSubscription() - Constructor for class rx .subscriptions . MultipleAssignmentSubscription
multiplyCap(long, long) - Static method in class rx .internal .operators . BackpressureUtils: Multiplies two positive longs and caps the result at Long.MAX_VALUE.

N

nest() - Method in class rx . Observable: Converts the source Observable<T> into an Observable<Observable<T>> that emits the source Observable as its single emission.
never() - Static method in class rx . Observable: Returns an Observable that never sends any items or notifications to an Observer.
newThread(Runnable) - Method in class rx .internal .util . RxThreadFactory
newThread() - Static method in class rx .schedulers . Schedulers: Creates and returns a Scheduler that creates a new Thread for each unit of work.
NewThreadScheduler - Class in rx.schedulers: Schedules work on a new thread.
NewThreadWorker - Class in rx.internal.schedulers
NewThreadWorker(ThreadFactory) - Constructor for class rx .internal .schedulers . NewThreadWorker
next(Observable<? extends T>) - Static method in class rx .internal .operators . BlockingOperatorNext: Returns an Iterable that blocks until the Observable emits another item, then returns that item.
next() - Method in class rx .internal .operators . BlockingOperatorToIterator.SubscriberIterator
next(T) - Method in class rx .internal .operators . NotificationLite: Creates a lite onNext notification for the value passed in without doing any allocation.
next(AbstractOnSubscribe.SubscriptionState<T, S>) - Method in class rx .observables . AbstractOnSubscribe: Override this method to create an emission state-machine.
next(S, long, Observer<Observable<? extends T>>) - Method in class rx .observables . AsyncOnSubscribe: Called to produce data to the downstream subscribers.
next() - Method in class rx .observables . BlockingObservable: Returns an Iterable that blocks until this BlockingObservable emits another item, then returns that item.
next(S, Observer<? super T>) - Method in class rx .observables . SyncOnSubscribe: Called to produce data to the downstream subscribers.
Notification < T> - Class in rx: An object representing a notification sent to an Observable.
Notification.Kind - Enum in rx
NotificationLite < T> - Class in rx.internal.operators: For use in internal operators that need something like materialize and dematerialize wholly within the implementation of the operator but don't want to incur the allocation cost of actually creating Notification objects for every onNext and onCompleted.
now() - Method in class rx . Scheduler: Gets the current time, in milliseconds, according to this Scheduler.
now() - Method in class rx . Scheduler.Worker: Gets the current time, in milliseconds, according to this Scheduler.
now() - Method in class rx .schedulers . TestScheduler

O

ObjectPool < T> - Class in rx.internal.util
ObjectPool() - Constructor for class rx .internal .util . ObjectPool
Observable < T> - Class in rx: The Observable class that implements the Reactive Pattern.
Observable(Observable.OnSubscribe<T>) - Constructor for class rx . Observable: Creates an Observable with a Function to execute when it is subscribed to.
Observable.OnSubscribe < T> - Interface in rx: Invoked when Observable.subscribe is called.
Observable.Operator < R , T> - Interface in rx: Operator function for lifting into an Observable.
Observable.Transformer < T , R> - Interface in rx: Transformer function used by Observable.compose(rx.Observable.Transformer<? super T, ? extends R>).
observeOn(ConnectableObservable<T>, Scheduler) - Static method in class rx .internal .operators . OperatorReplay: Child Subscribers will observe the events of the ConnectableObservable on the specified scheduler.
observeOn(Scheduler) - Method in class rx . Observable: Modifies an Observable to perform its emissions and notifications on a specified Scheduler, asynchronously with an unbounded buffer.
observeOn(Scheduler) - Method in class rx . Single: Modifies a Single to emit its item (or notify of its error) on a specified Scheduler, asynchronously.
Observer < T> - Interface in rx: Provides a mechanism for receiving push-based notifications.
Observers - Class in rx.observers: Helper methods and utilities for creating and working with Observer objects.
offer(T) - Method in class rx .internal .producers . QueuedProducer: Offers a value to this producer and tries to emit any queud values if the child requests allow it.
offer(T) - Method in class rx .internal .producers . QueuedValueProducer: Offers a value to this producer and tries to emit any queud values if the child requests allow it.
offer(E) - Method in class rx .internal .util .atomic . MpscLinkedAtomicQueue
offer(E) - Method in class rx .internal .util .atomic . SpscAtomicArrayQueue
offer(T) - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
offer(T) - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
offer(T, T) - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue: Offer two elements at the same time.
offer(E) - Method in class rx .internal .util .atomic . SpscLinkedAtomicQueue: IMPLEMENTATION NOTES:
Offer is allowed from a SINGLE thread.
Offer allocates a new node (holding the offered value) and: Sets that node as the producerNode.next Sets the new node as the producerNode From this follows that producerNode.next is always null and for all other nodes node.next is not null.
offer(T) - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
offer(T) - Method in class rx .internal .util . SynchronizedQueue
offer(E) - Method in class rx .internal .util .unsafe . MpmcArrayQueue
offer(E) - Method in class rx .internal .util .unsafe . MpscLinkedQueue
offer(E) - Method in class rx .internal .util .unsafe . SpmcArrayQueue
offer(E) - Method in class rx .internal .util .unsafe . SpscArrayQueue
offer(E) - Method in class rx .internal .util .unsafe . SpscLinkedQueue: IMPLEMENTATION NOTES:
Offer is allowed from a SINGLE thread.
Offer allocates a new node (holding the offered value) and: Sets that node as the producerNode.next Sets the new node as the producerNode From this follows that producerNode.next is always null and for all other nodes node.next is not null.
offer(E) - Method in class rx .internal .util .unsafe . SpscUnboundedArrayQueue
ofType(Class<R>) - Method in class rx . Observable: Filters the items emitted by an Observable, only emitting those of the specified type.
onBackpressureBlock(int) - Method in class rx . Observable: Deprecated.
The operator doesn't work properly with Observable.subscribeOn(Scheduler) and is prone to deadlocks. It will be removed/unavailable starting from 1.1.
onBackpressureBlock() - Method in class rx . Observable: Deprecated.
The operator doesn't work properly with Observable.subscribeOn(Scheduler) and is prone to deadlocks. It will be removed/unavailable starting from 1.1.
onBackpressureBuffer() - Method in class rx . Observable: Instructs an Observable that is emitting items faster than its observer can consume them to buffer these items indefinitely until they can be emitted.
onBackpressureBuffer(long) - Method in class rx . Observable: Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to a given amount of items until they can be emitted.
onBackpressureBuffer(long, Action0) - Method in class rx . Observable: Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to a given amount of items until they can be emitted.
onBackpressureDrop(Action1<? super T>) - Method in class rx . Observable: Instructs an Observable that is emitting items faster than its observer can consume them to discard, rather than emit, those items that its observer is not prepared to observe.
onBackpressureDrop() - Method in class rx . Observable: Instructs an Observable that is emitting items faster than its observer can consume them to discard, rather than emit, those items that its observer is not prepared to observe.
onBackpressureLatest() - Method in class rx . Observable: Instructs an Observable that is emitting items faster than its observer can consume them to hold onto the latest value and emit that on request.
onCompleted() - Method in class rx .internal .operators . BlockingOperatorToIterator.SubscriberIterator
onCompleted() - Method in class rx .internal .operators . BufferUntilSubscriber
onCompleted() - Method in class rx .internal .operators . UnicastSubject
onCompleted() - Method in class rx .internal .producers . ProducerObserverArbiter
onCompleted() - Method in class rx .internal .producers . QueuedProducer
onCompleted() - Method in class rx .internal .util . RxRingBuffer
onCompleted() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Call this method to send an onCompleted to the subscriber and terminate all further activities.
onCompleted() - Method in interface rx . Observer: Notifies the Observer that the Observable has finished sending push-based notifications.
onCompleted() - Method in class rx .observers . SafeSubscriber: Notifies the Subscriber that the Observable has finished sending push-based notifications.
onCompleted() - Method in class rx .observers . SerializedObserver
onCompleted() - Method in class rx .observers . SerializedSubscriber: Notifies the Subscriber that the Observable has finished sending push-based notifications.
onCompleted() - Method in class rx .observers . TestObserver
onCompleted() - Method in class rx .observers . TestSubscriber: Notifies the Subscriber that the Observable has finished sending push-based notifications.
onCompleted() - Method in class rx .subjects . AsyncSubject
onCompleted() - Method in class rx .subjects . BehaviorSubject
onCompleted() - Method in class rx .subjects . PublishSubject
onCompleted() - Method in class rx .subjects . ReplaySubject
onCompleted() - Method in class rx .subjects . SerializedSubject
onCompleted() - Method in class rx .subjects . TestSubject: Schedule a call to onCompleted on TestScheduler.
onCompleted(long) - Method in class rx .subjects . TestSubject: Schedule a call to onCompleted relative to "now()" +n milliseconds in the future.
OnCompletedFailedException - Exception in rx.exceptions: Represents an exception used to re-throw errors thrown from Observer.onCompleted().
OnCompletedFailedException(Throwable) - Constructor for exception rx .exceptions . OnCompletedFailedException: Wraps the Throwable before it is to be re-thrown as an OnCompletedFailedException.
OnCompletedFailedException(String, Throwable) - Constructor for exception rx .exceptions . OnCompletedFailedException: Customizes the Throwable with a custom message and wraps it before it is to be re-thrown as an OnCompletedFailedException.
onCreate(Observable.OnSubscribe<T>) - Method in class rx .plugins . RxJavaObservableExecutionHook: Invoked during the construction by Observable.create(OnSubscribe)
onError(Throwable) - Method in class rx .internal .operators . BlockingOperatorToIterator.SubscriberIterator
onError(Throwable) - Method in class rx .internal .operators . BufferUntilSubscriber
onError(Throwable) - Method in class rx .internal .operators . UnicastSubject
onError(Throwable) - Method in class rx .internal .producers . ProducerObserverArbiter
onError(Throwable) - Method in class rx .internal .producers . QueuedProducer
onError(Throwable) - Method in class rx .internal .util . RxRingBuffer
onError(Throwable) - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Call this method to send an onError to the subscriber and terminate all further activities.
onError(Throwable) - Method in interface rx . Observer: Notifies the Observer that the Observable has experienced an error condition.
onError(Throwable) - Method in class rx .observers . SafeSubscriber: Notifies the Subscriber that the Observable has experienced an error condition.
onError(Throwable) - Method in class rx .observers . SerializedObserver
onError(Throwable) - Method in class rx .observers . SerializedSubscriber: Notifies the Subscriber that the Observable has experienced an error condition.
onError(Throwable) - Method in class rx .observers . TestObserver
onError(Throwable) - Method in class rx .observers . TestSubscriber: Notifies the Subscriber that the Observable has experienced an error condition.
onError(Throwable) - Method in class rx . SingleSubscriber: Notifies the SingleSubscriber that the Single has experienced an error condition.
onError(Throwable) - Method in class rx .subjects . AsyncSubject
onError(Throwable) - Method in class rx .subjects . BehaviorSubject
onError(Throwable) - Method in class rx .subjects . PublishSubject
onError(Throwable) - Method in class rx .subjects . ReplaySubject
onError(Throwable) - Method in class rx .subjects . SerializedSubject
onError(Throwable) - Method in class rx .subjects . TestSubject: Schedule a call to onError on TestScheduler.
onError(Throwable, long) - Method in class rx .subjects . TestSubject: Schedule a call to onError relative to "now()" +n milliseconds in the future.
OnErrorFailedException - Exception in rx.exceptions: Represents an exception used to re-throw errors thrown from Observer.onError(Throwable).
OnErrorFailedException(String, Throwable) - Constructor for exception rx .exceptions . OnErrorFailedException: Customizes the Throwable with a custom message and wraps it before it is to be re-thrown as an OnErrorFailedException.
OnErrorFailedException(Throwable) - Constructor for exception rx .exceptions . OnErrorFailedException: Wraps the Throwable before it is to be re-thrown as an OnErrorFailedException.
OnErrorNotImplementedException - Exception in rx.exceptions: Represents an exception used to re-throw Observer.onError(Throwable) when an implementation doesn't exist.
OnErrorNotImplementedException(String, Throwable) - Constructor for exception rx .exceptions . OnErrorNotImplementedException: Customizes the Throwable with a custom message and wraps it before it is to be re-thrown as an OnErrorNotImplementedException.
OnErrorNotImplementedException(Throwable) - Constructor for exception rx .exceptions . OnErrorNotImplementedException: Wraps the Throwable before it is to be re-thrown as an OnErrorNotImplementedException.
onErrorResumeNext(Func1<Throwable, ? extends Observable<? extends T>>) - Method in class rx . Observable: Instructs an Observable to pass control to another Observable rather than invoking onError if it encounters an error.
onErrorResumeNext(Observable<? extends T>) - Method in class rx . Observable: Instructs an Observable to pass control to another Observable rather than invoking onError if it encounters an error.
onErrorReturn(Func1<Throwable, ? extends T>) - Method in class rx . Observable: Instructs an Observable to emit an item (returned by a specified function) rather than invoking onError if it encounters an error.
onErrorReturn(Func1<Throwable, ? extends T>) - Method in class rx . Single: Instructs a Single to emit an item (returned by a specified function) rather than invoking onError if it encounters an error.
OnErrorThrowable - Exception in rx.exceptions: Represents a Throwable that an Observable might notify its subscribers of, but that then can be handled by an operator that is designed to recover from or react appropriately to such an error.
OnErrorThrowable.OnNextValue - Exception in rx.exceptions: Represents an exception that was encountered while trying to emit an item from an Observable, and tries to preserve that item for future use and/or reporting.
onExceptionResumeNext(Observable<? extends T>) - Method in class rx . Observable: Instructs an Observable to pass control to another Observable rather than invoking onError if it encounters an Exception.
onLift(Observable.Operator<? extends R, ? super T>) - Method in class rx .plugins . RxJavaObservableExecutionHook: Invoked just as the operator functions is called to bind two operations together into a new Observable and the return value is used as the lifted function
onNext(Notification<? extends T>) - Method in class rx .internal .operators . BlockingOperatorToIterator.SubscriberIterator
onNext(T) - Method in class rx .internal .operators . BufferUntilSubscriber
onNext(T) - Method in class rx .internal .operators . UnicastSubject
onNext(T) - Method in class rx .internal .producers . ProducerObserverArbiter
onNext(T) - Method in class rx .internal .producers . QueuedProducer
onNext(Object) - Method in class rx .internal .util . RxRingBuffer
onNext(T) - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Call this method to offer the next onNext value for the subscriber.
onNext(T) - Method in interface rx . Observer: Provides the Observer with a new item to observe.
onNext(T) - Method in class rx .observers . SafeSubscriber: Provides the Subscriber with a new item to observe.
onNext(T) - Method in class rx .observers . SerializedObserver
onNext(T) - Method in class rx .observers . SerializedSubscriber: Provides the Subscriber with a new item to observe.
onNext(T) - Method in class rx .observers . TestObserver
onNext(T) - Method in class rx .observers . TestSubscriber: Provides the Subscriber with a new item to observe.
onNext(T) - Method in class rx .subjects . AsyncSubject
onNext(T) - Method in class rx .subjects . BehaviorSubject
onNext(T) - Method in class rx .subjects . PublishSubject
onNext(T) - Method in class rx .subjects . ReplaySubject
onNext(T) - Method in class rx .subjects . SerializedSubject
onNext(T) - Method in class rx .subjects . TestSubject: Schedule a call to onNext on TestScheduler.
onNext(T, long) - Method in class rx .subjects . TestSubject: Schedule a call to onNext relative to "now()" +n milliseconds in the future.
OnNextValue(Object) - Constructor for exception rx .exceptions . OnErrorThrowable.OnNextValue: Create an OnNextValue exception and include in its error message a string representation of the item that was intended to be emitted at the time the exception was handled.
onSchedule(Action0) - Method in class rx .plugins . RxJavaSchedulersHook: Invoked before the Action is handed over to the scheduler.
onStart() - Method in class rx .internal .operators . BlockingOperatorToIterator.SubscriberIterator
onStart() - Method in class rx .observers . TestSubscriber
onStart() - Method in class rx . Subscriber: This method is invoked when the Subscriber and Observable have been connected but the Observable has not yet begun to emit items or send notifications to the Subscriber.
onSubscribe(Subscriber<? super T>) - Method in class rx .observables . AbstractOnSubscribe: Called when a Subscriber subscribes and lets the implementor create a per-subscriber custom state.
OnSubscribeAmb < T> - Class in rx.internal.operators: Given multiple Observables, propagates the one that first emits an item.
OnSubscribeAutoConnect < T> - Class in rx.internal.operators: Wraps a ConnectableObservable and calls its connect() method once the specified number of Subscribers have subscribed.
OnSubscribeAutoConnect(ConnectableObservable<? extends T>, int, Action1<? super Subscription>) - Constructor for class rx .internal .operators . OnSubscribeAutoConnect
OnSubscribeCombineLatest < T , R> - Class in rx.internal.operators: Returns an Observable that combines the emissions of multiple source observables.
OnSubscribeCombineLatest(List<? extends Observable<? extends T>>, FuncN<? extends R>) - Constructor for class rx .internal .operators . OnSubscribeCombineLatest
OnSubscribeDefer < T> - Class in rx.internal.operators: Do not create the Observable until an Observer subscribes; create a fresh Observable on each subscription.
OnSubscribeDefer(Func0<? extends Observable<? extends T>>) - Constructor for class rx .internal .operators . OnSubscribeDefer
OnSubscribeDelaySubscription < T> - Class in rx.internal.operators: Delays the subscription to the source by the given amount, running on the given scheduler.
OnSubscribeDelaySubscription(Observable<? extends T>, long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OnSubscribeDelaySubscription
OnSubscribeDelaySubscriptionWithSelector < T , U> - Class in rx.internal.operators: Delays the subscription until the Observable emits an event.
OnSubscribeDelaySubscriptionWithSelector(Observable<? extends T>, Func0<? extends Observable>) - Constructor for class rx .internal .operators . OnSubscribeDelaySubscriptionWithSelector
onSubscribeError(Throwable) - Method in class rx .plugins . RxJavaObservableExecutionHook: Invoked after failed execution of Observable.subscribe(Subscriber) with thrown Throwable.
OnSubscribeFromCallable < T> - Class in rx.internal.operators: Do not invoke the function until an Observer subscribes; Invokes function on each subscription.
OnSubscribeFromCallable(Callable<? extends T>) - Constructor for class rx .internal .operators . OnSubscribeFromCallable
OnSubscribeFromIterable < T> - Class in rx.internal.operators: Converts an Iterable sequence into an Observable.
OnSubscribeFromIterable(Iterable<? extends T>) - Constructor for class rx .internal .operators . OnSubscribeFromIterable
OnSubscribeGroupJoin < T1 , T2 , D1 , D2 , R> - Class in rx.internal.operators: Corrrelates two sequences when they overlap and groups the results.
OnSubscribeGroupJoin(Observable<T1>, Observable<T2>, Func1<? super T1, ? extends Observable<D1>>, Func1<? super T2, ? extends Observable<D2>>, Func2<? super T1, ? super Observable<T2>, ? extends R>) - Constructor for class rx .internal .operators . OnSubscribeGroupJoin
OnSubscribeJoin < TLeft , TRight , TLeftDuration , TRightDuration , R> - Class in rx.internal.operators: Correlates the elements of two sequences based on overlapping durations.
OnSubscribeJoin(Observable<TLeft>, Observable<TRight>, Func1<TLeft, Observable<TLeftDuration>>, Func1<TRight, Observable<TRightDuration>>, Func2<TLeft, TRight, R>) - Constructor for class rx .internal .operators . OnSubscribeJoin
OnSubscribeRange - Class in rx.internal.operators: Emit ints from start to end inclusive.
OnSubscribeRange(int, int) - Constructor for class rx .internal .operators . OnSubscribeRange
OnSubscribeRedo < T> - Class in rx.internal.operators
OnSubscribeRedo.RedoFinite - Class in rx.internal.operators
OnSubscribeRedo.RetryWithPredicate - Class in rx.internal.operators
OnSubscribeRefCount < T> - Class in rx.internal.operators: Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence.
OnSubscribeRefCount(ConnectableObservable<? extends T>) - Constructor for class rx .internal .operators . OnSubscribeRefCount: Constructor.
onSubscribeReturn(Subscription) - Method in class rx .plugins . RxJavaObservableExecutionHook: Invoked after successful execution of Observable.subscribe(rx.Subscriber) with returned Subscription.
OnSubscribeSingle < T> - Class in rx.internal.operators: Allows conversion of an Observable to a Single ensuring that exactly one item is emitted - no more and no less.
OnSubscribeSingle(Observable<T>) - Constructor for class rx .internal .operators . OnSubscribeSingle
onSubscribeStart(Observable<? extends T>, Observable.OnSubscribe<T>) - Method in class rx .plugins . RxJavaObservableExecutionHook: Invoked before Observable.subscribe(rx.Subscriber) is about to be executed.
OnSubscribeTimerOnce - Class in rx.internal.operators: Timer that emits a single 0L and completes after the specified time.
OnSubscribeTimerOnce(long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OnSubscribeTimerOnce
OnSubscribeTimerPeriodically - Class in rx.internal.operators: Emit 0L after the initial period and ever increasing number after each period.
OnSubscribeTimerPeriodically(long, long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OnSubscribeTimerPeriodically
OnSubscribeToObservableFuture - Class in rx.internal.operators: Converts a Future into an Observable.
OnSubscribeUsing < T , Resource> - Class in rx.internal.operators: Constructs an observable sequence that depends on a resource object.
OnSubscribeUsing(Func0<Resource>, Func1<? super Resource, ? extends Observable<? extends T>>, Action1<? super Resource>, boolean) - Constructor for class rx .internal .operators . OnSubscribeUsing
onSuccess(T) - Method in class rx . SingleSubscriber: Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.
onTerminated(S) - Method in class rx .observables . AbstractOnSubscribe: Called after the terminal emission or when the downstream unsubscribes.
onUnsubscribe(S) - Method in class rx .observables . AsyncOnSubscribe: Clean up behavior that is executed after the downstream subscriber's subscription is unsubscribed.
onUnsubscribe(S) - Method in class rx .observables . SyncOnSubscribe: Clean up behavior that is executed after the downstream subscriber's subscription is unsubscribed.
OperatorAll < T> - Class in rx.internal.operators: Returns an Observable that emits a Boolean that indicates whether all items emitted by an Observable satisfy a condition.
OperatorAll(Func1<? super T, Boolean>) - Constructor for class rx .internal .operators . OperatorAll
OperatorAny < T> - Class in rx.internal.operators: Returns an Observable that emits true if any element of an observable sequence satisfies a condition, otherwise false.
OperatorAny(Func1<? super T, Boolean>, boolean) - Constructor for class rx .internal .operators . OperatorAny
OperatorAsObservable < T> - Class in rx.internal.operators: Hides the identity of another observable.
OperatorBufferWithSingleObservable < T , TClosing> - Class in rx.internal.operators: This operation takes values from the specified Observable source and stores them in a buffer until the Observable constructed using the Func0 argument, produces a value.
OperatorBufferWithSingleObservable(Func0<? extends Observable<? extends TClosing>>, int) - Constructor for class rx .internal .operators . OperatorBufferWithSingleObservable
OperatorBufferWithSingleObservable(Observable<? extends TClosing>, int) - Constructor for class rx .internal .operators . OperatorBufferWithSingleObservable
OperatorBufferWithSize < T> - Class in rx.internal.operators: This operation takes values from the specified Observable source and stores them in all active chunks until the buffer contains a specified number of elements.
OperatorBufferWithSize(int, int) - Constructor for class rx .internal .operators . OperatorBufferWithSize
OperatorBufferWithStartEndObservable < T , TOpening , TClosing> - Class in rx.internal.operators: This operation takes values from the specified Observable source and stores them in the currently active chunks.
OperatorBufferWithStartEndObservable(Observable<? extends TOpening>, Func1<? super TOpening, ? extends Observable<? extends TClosing>>) - Constructor for class rx .internal .operators . OperatorBufferWithStartEndObservable
OperatorBufferWithTime < T> - Class in rx.internal.operators: This operation takes values from the specified Observable source and stores them in a buffer.
OperatorBufferWithTime(long, long, TimeUnit, int, Scheduler) - Constructor for class rx .internal .operators . OperatorBufferWithTime
OperatorCast < T , R> - Class in rx.internal.operators: Converts the elements of an observable sequence to the specified type.
OperatorCast(Class<R>) - Constructor for class rx .internal .operators . OperatorCast
OperatorConcat < T> - Class in rx.internal.operators: Returns an Observable that emits the items emitted by two or more Observables, one after the other.
OperatorDebounceWithSelector < T , U> - Class in rx.internal.operators: Delay the emission via another observable if no new source appears in the meantime.
OperatorDebounceWithSelector(Func1<? super T, ? extends Observable>) - Constructor for class rx .internal .operators . OperatorDebounceWithSelector
OperatorDebounceWithTime < T> - Class in rx.internal.operators: This operation filters out events which are published too quickly in succession.
OperatorDebounceWithTime(long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OperatorDebounceWithTime
OperatorDelay < T> - Class in rx.internal.operators: Delays the emission of onNext events by a given amount of time.
OperatorDelay(long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OperatorDelay
OperatorDelayWithSelector < T , V> - Class in rx.internal.operators: Delay the subscription and emission of the source items by a per-item observable that fires its first element.
OperatorDelayWithSelector(Observable<? extends T>, Func1<? super T, ? extends Observable<V>>) - Constructor for class rx .internal .operators . OperatorDelayWithSelector
OperatorDematerialize < T> - Class in rx.internal.operators: Reverses the effect of OperatorMaterialize by transforming the Notification objects emitted by a source Observable into the items or notifications they represent.
OperatorDistinct < T , U> - Class in rx.internal.operators: Returns an Observable that emits all distinct items emitted by the source.
OperatorDistinct(Func1<? super T, ? extends U>) - Constructor for class rx .internal .operators . OperatorDistinct
OperatorDistinctUntilChanged < T , U> - Class in rx.internal.operators: Returns an Observable that emits all sequentially distinct items emitted by the source.
OperatorDistinctUntilChanged(Func1<? super T, ? extends U>) - Constructor for class rx .internal .operators . OperatorDistinctUntilChanged
OperatorDoOnEach < T> - Class in rx.internal.operators: Converts the elements of an observable sequence to the specified type.
OperatorDoOnEach(Observer<? super T>) - Constructor for class rx .internal .operators . OperatorDoOnEach
OperatorDoOnRequest < T> - Class in rx.internal.operators: This operator modifies an Observable so a given action is invoked when the rx.Observable.Producer receives a request.
OperatorDoOnRequest(Action1<Long>) - Constructor for class rx .internal .operators . OperatorDoOnRequest
OperatorDoOnSubscribe < T> - Class in rx.internal.operators: This operator modifies an Observable so a given action is invoked when the Observable is subscribed.
OperatorDoOnSubscribe(Action0) - Constructor for class rx .internal .operators . OperatorDoOnSubscribe: Constructs an instance of the operator with the callback that gets invoked when the modified Observable is subscribed
OperatorDoOnUnsubscribe < T> - Class in rx.internal.operators: This operator modifies an Observable so a given action is invoked when the Observable is unsubscribed.
OperatorDoOnUnsubscribe(Action0) - Constructor for class rx .internal .operators . OperatorDoOnUnsubscribe: Constructs an instance of the operator with the callback that gets invoked when the modified Observable is unsubscribed
OperatorEagerConcatMap < T , R> - Class in rx.internal.operators
OperatorEagerConcatMap(Func1<? super T, ? extends Observable<? extends R>>, int) - Constructor for class rx .internal .operators . OperatorEagerConcatMap
OperatorElementAt < T> - Class in rx.internal.operators: Returns the element at a specified index in a sequence.
OperatorElementAt(int) - Constructor for class rx .internal .operators . OperatorElementAt
OperatorElementAt(int, T) - Constructor for class rx .internal .operators . OperatorElementAt
OperatorFilter < T> - Class in rx.internal.operators: Filters an Observable by discarding any items it emits that do not meet some test.
OperatorFilter(Func1<? super T, Boolean>) - Constructor for class rx .internal .operators . OperatorFilter
OperatorFinally < T> - Class in rx.internal.operators: Registers an action to be called after an Observable invokes onComplete or onError.
OperatorFinally(Action0) - Constructor for class rx .internal .operators . OperatorFinally
OperatorGroupBy < T , K , R> - Class in rx.internal.operators: Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as Observables, one Observable per group.
OperatorGroupBy(Func1<? super T, ? extends K>) - Constructor for class rx .internal .operators . OperatorGroupBy
OperatorGroupBy(Func1<? super T, ? extends K>, Func1<? super T, ? extends R>) - Constructor for class rx .internal .operators . OperatorGroupBy
OperatorIgnoreElements < T> - Class in rx.internal.operators
OperatorMap < T , R> - Class in rx.internal.operators: Applies a function of your choosing to every item emitted by an Observable, and emits the results of this transformation as a new Observable.
OperatorMap(Func1<? super T, ? extends R>) - Constructor for class rx .internal .operators . OperatorMap
OperatorMapNotification < T , R> - Class in rx.internal.operators: Applies a function of your choosing to every item emitted by an Observable, and emits the results of this transformation as a new Observable.
OperatorMapNotification(Func1<? super T, ? extends R>, Func1<? super Throwable, ? extends R>, Func0<? extends R>) - Constructor for class rx .internal .operators . OperatorMapNotification
OperatorMapPair < T , U , R> - Class in rx.internal.operators: An Observable.Operator that pairs up items emitted by a source Observable with the sequence of items emitted by the Observable that is derived from each item by means of a selector, and emits the results of this pairing.
OperatorMapPair(Func1<? super T, ? extends Observable<? extends U>>, Func2<? super T, ? super U, ? extends R>) - Constructor for class rx .internal .operators . OperatorMapPair
OperatorMaterialize < T> - Class in rx.internal.operators: Turns all of the notifications from an Observable into onNext emissions, and marks them with their original notification types within Notification objects.
OperatorMerge < T> - Class in rx.internal.operators: Flattens a list of Observables into one Observable, without any transformation.
OperatorMulticast < T , R> - Class in rx.internal.operators: Shares a single subscription to a source through a Subject.
OperatorMulticast(Observable<? extends T>, Func0<? extends Subject<? super T, ? extends R>>) - Constructor for class rx .internal .operators . OperatorMulticast
OperatorObserveOn < T> - Class in rx.internal.operators: Delivers events on the specified Scheduler asynchronously via an unbounded buffer.
OperatorObserveOn(Scheduler) - Constructor for class rx .internal .operators . OperatorObserveOn
OperatorOnBackpressureBlock < T> - Class in rx.internal.operators: Operator that blocks the producer thread in case a backpressure is needed.
OperatorOnBackpressureBlock(int) - Constructor for class rx .internal .operators . OperatorOnBackpressureBlock
OperatorOnBackpressureBuffer < T> - Class in rx.internal.operators
OperatorOnBackpressureBuffer(long) - Constructor for class rx .internal .operators . OperatorOnBackpressureBuffer
OperatorOnBackpressureBuffer(long, Action0) - Constructor for class rx .internal .operators . OperatorOnBackpressureBuffer
OperatorOnBackpressureDrop < T> - Class in rx.internal.operators
OperatorOnBackpressureDrop(Action1<? super T>) - Constructor for class rx .internal .operators . OperatorOnBackpressureDrop
OperatorOnBackpressureLatest < T> - Class in rx.internal.operators: An operator which drops all but the last received value in case the downstream doesn't request more.
OperatorOnBackpressureLatest() - Constructor for class rx .internal .operators . OperatorOnBackpressureLatest
OperatorOnErrorResumeNextViaFunction < T> - Class in rx.internal.operators: Instruct an Observable to pass control to another Observable (the return value of a function) rather than invoking onError if it encounters an error.
OperatorOnErrorResumeNextViaFunction(Func1<Throwable, ? extends Observable<? extends T>>) - Constructor for class rx .internal .operators . OperatorOnErrorResumeNextViaFunction
OperatorOnErrorResumeNextViaObservable < T> - Class in rx.internal.operators: Instruct an Observable to pass control to another Observable rather than invoking onError if it encounters an error.
OperatorOnErrorResumeNextViaObservable(Observable<? extends T>) - Constructor for class rx .internal .operators . OperatorOnErrorResumeNextViaObservable
OperatorOnErrorReturn < T> - Class in rx.internal.operators: Instruct an Observable to emit a particular item to its Observer's onNext method rather than invoking onError if it encounters an error.
OperatorOnErrorReturn(Func1<Throwable, ? extends T>) - Constructor for class rx .internal .operators . OperatorOnErrorReturn
OperatorOnExceptionResumeNextViaObservable < T> - Class in rx.internal.operators: Instruct an Observable to pass control to another Observable rather than invoking onError if it encounters an error of type Exception.
OperatorOnExceptionResumeNextViaObservable(Observable<? extends T>) - Constructor for class rx .internal .operators . OperatorOnExceptionResumeNextViaObservable
OperatorPublish < T> - Class in rx.internal.operators: A connectable observable which shares an underlying source and dispatches source values to subscribers in a backpressure-aware manner.
OperatorReplay < T> - Class in rx.internal.operators
OperatorRetryWithPredicate < T> - Class in rx.internal.operators
OperatorRetryWithPredicate(Func2<Integer, Throwable, Boolean>) - Constructor for class rx .internal .operators . OperatorRetryWithPredicate
OperatorSampleWithObservable < T , U> - Class in rx.internal.operators: Sample with the help of another observable.
OperatorSampleWithObservable(Observable) - Constructor for class rx .internal .operators . OperatorSampleWithObservable
OperatorSampleWithTime < T> - Class in rx.internal.operators: Returns an Observable that emits the results of sampling the items emitted by the source Observable at a specified time interval.
OperatorSampleWithTime(long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OperatorSampleWithTime
OperatorScan < R , T> - Class in rx.internal.operators: Returns an Observable that applies a function to the first item emitted by a source Observable, then feeds the result of that function along with the second item emitted by an Observable into the same function, and so on until all items have been emitted by the source Observable, emitting the result of each of these iterations.
OperatorScan(R, Func2<R, ? super T, R>) - Constructor for class rx .internal .operators . OperatorScan: Applies an accumulator function over an observable sequence and returns each intermediate result with the specified source and accumulator.
OperatorScan(Func0<R>, Func2<R, ? super T, R>) - Constructor for class rx .internal .operators . OperatorScan
OperatorScan(Func2<R, ? super T, R>) - Constructor for class rx .internal .operators . OperatorScan: Applies an accumulator function over an observable sequence and returns each intermediate result with the specified source and accumulator.
OperatorSequenceEqual - Class in rx.internal.operators: Returns an Observable that emits a single Boolean value that indicates whether two source Observables emit sequences of items that are equivalent to each other.
OperatorSerialize < T> - Class in rx.internal.operators
OperatorSingle < T> - Class in rx.internal.operators: If the Observable completes after emitting a single item that matches a predicate, return an Observable containing that item.
OperatorSingle(T) - Constructor for class rx .internal .operators . OperatorSingle
OperatorSkip < T> - Class in rx.internal.operators: Returns an Observable that skips the first num items emitted by the source Observable.
OperatorSkip(int) - Constructor for class rx .internal .operators . OperatorSkip
OperatorSkipLast < T> - Class in rx.internal.operators: Bypasses a specified number of elements at the end of an observable sequence.
OperatorSkipLast(int) - Constructor for class rx .internal .operators . OperatorSkipLast
OperatorSkipLastTimed < T> - Class in rx.internal.operators: Skip delivering values in the time window before the values.
OperatorSkipLastTimed(long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OperatorSkipLastTimed
OperatorSkipTimed < T> - Class in rx.internal.operators: Skips elements until a specified time elapses.
OperatorSkipTimed(long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OperatorSkipTimed
OperatorSkipUntil < T , U> - Class in rx.internal.operators: Skip elements from the source Observable until the secondary observable fires an element.
OperatorSkipUntil(Observable) - Constructor for class rx .internal .operators . OperatorSkipUntil
OperatorSkipWhile < T> - Class in rx.internal.operators: Skips any emitted source items as long as the specified condition holds true.
OperatorSkipWhile(Func2<? super T, Integer, Boolean>) - Constructor for class rx .internal .operators . OperatorSkipWhile
OperatorSubscribeOn < T> - Class in rx.internal.operators: Subscribes Observers on the specified Scheduler.
OperatorSubscribeOn(Scheduler) - Constructor for class rx .internal .operators . OperatorSubscribeOn
OperatorSwitch < T> - Class in rx.internal.operators: Transforms an Observable that emits Observables into a single Observable that emits the items emitted by the most recently published of those Observables.
OperatorSwitchIfEmpty < T> - Class in rx.internal.operators: If the Observable completes without emitting any items, subscribe to an alternate Observable.
OperatorSwitchIfEmpty(Observable<? extends T>) - Constructor for class rx .internal .operators . OperatorSwitchIfEmpty
OperatorTake < T> - Class in rx.internal.operators: An Observable that emits the first num items emitted by the source Observable.
OperatorTake(int) - Constructor for class rx .internal .operators . OperatorTake
OperatorTakeLast < T> - Class in rx.internal.operators: Returns an Observable that emits the at most the last count items emitted by the source Observable.
OperatorTakeLast(int) - Constructor for class rx .internal .operators . OperatorTakeLast
OperatorTakeLastOne < T> - Class in rx.internal.operators
OperatorTakeLastTimed < T> - Class in rx.internal.operators: Returns an Observable that emits the last count items emitted by the source Observable.
OperatorTakeLastTimed(long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OperatorTakeLastTimed
OperatorTakeLastTimed(int, long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OperatorTakeLastTimed
OperatorTakeTimed < T> - Class in rx.internal.operators: Takes values from the source until the specific time ellapses.
OperatorTakeTimed(long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OperatorTakeTimed
OperatorTakeUntil < T , E> - Class in rx.internal.operators: Returns an Observable that emits the items from the source Observable until another Observable emits an item.
OperatorTakeUntil(Observable<? extends E>) - Constructor for class rx .internal .operators . OperatorTakeUntil
OperatorTakeUntilPredicate < T> - Class in rx.internal.operators: Returns an Observable that emits items emitted by the source Observable until the provided predicate returns false
OperatorTakeUntilPredicate(Func1<? super T, Boolean>) - Constructor for class rx .internal .operators . OperatorTakeUntilPredicate
OperatorTakeWhile < T> - Class in rx.internal.operators: O Returns an Observable that emits items emitted by the source Observable as long as a specified condition is true.
OperatorTakeWhile(Func1<? super T, Boolean>) - Constructor for class rx .internal .operators . OperatorTakeWhile
OperatorTakeWhile(Func2<? super T, ? super Integer, Boolean>) - Constructor for class rx .internal .operators . OperatorTakeWhile
OperatorThrottleFirst < T> - Class in rx.internal.operators: Throttle by windowing a stream and returning the first value in each window.
OperatorThrottleFirst(long, TimeUnit, Scheduler) - Constructor for class rx .internal .operators . OperatorThrottleFirst
OperatorTimeInterval < T> - Class in rx.internal.operators: Records the time interval between consecutive elements in an observable sequence.
OperatorTimeInterval(Scheduler) - Constructor for class rx .internal .operators . OperatorTimeInterval
OperatorTimeout < T> - Class in rx.internal.operators: Applies a timeout policy for each element in the observable sequence, using the specified scheduler to run timeout timers.
OperatorTimeout(long, TimeUnit, Observable<? extends T>, Scheduler) - Constructor for class rx .internal .operators . OperatorTimeout
OperatorTimeoutWithSelector < T , U , V> - Class in rx.internal.operators: Returns an Observable that mirrors the source Observable.
OperatorTimeoutWithSelector(Func0<? extends Observable>, Func1<? super T, ? extends Observable<V>>, Observable<? extends T>) - Constructor for class rx .internal .operators . OperatorTimeoutWithSelector
OperatorTimestamp < T> - Class in rx.internal.operators: Wraps each item emitted by a source Observable in a Timestamped object.
OperatorTimestamp(Scheduler) - Constructor for class rx .internal .operators . OperatorTimestamp
OperatorToMap < T , K , V> - Class in rx.internal.operators: Maps the elements of the source observable into a java.util.Map instance and emits that once the source observable completes.
OperatorToMap(Func1<? super T, ? extends K>, Func1<? super T, ? extends V>) - Constructor for class rx .internal .operators . OperatorToMap: ToMap with key selector, value selector and default HashMap factory.
OperatorToMap(Func1<? super T, ? extends K>, Func1<? super T, ? extends V>, Func0<? extends Map<K, V>>) - Constructor for class rx .internal .operators . OperatorToMap: ToMap with key selector, value selector and custom Map factory.
OperatorToMap.DefaultToMapFactory < K , V> - Class in rx.internal.operators: The default map factory.
OperatorToMultimap < T , K , V> - Class in rx.internal.operators: Maps the elements of the source observable into a multimap (Map<K, Collection<V>>) where each key entry has a collection of the source's values.
OperatorToMultimap(Func1<? super T, ? extends K>, Func1<? super T, ? extends V>) - Constructor for class rx .internal .operators . OperatorToMultimap: ToMultimap with key selector, custom value selector, default HashMap factory and default ArrayList collection factory.
OperatorToMultimap(Func1<? super T, ? extends K>, Func1<? super T, ? extends V>, Func0<? extends Map<K, Collection<V>>>) - Constructor for class rx .internal .operators . OperatorToMultimap: ToMultimap with key selector, custom value selector, custom Map factory and default ArrayList collection factory.
OperatorToMultimap(Func1<? super T, ? extends K>, Func1<? super T, ? extends V>, Func0<? extends Map<K, Collection<V>>>, Func1<? super K, ? extends Collection<V>>) - Constructor for class rx .internal .operators . OperatorToMultimap: ToMultimap with key selector, custom value selector, custom Map factory and custom collection factory.
OperatorToMultimap.DefaultMultimapCollectionFactory < K , V> - Class in rx.internal.operators: The default collection factory for a key in the multimap returning an ArrayList independent of the key.
OperatorToMultimap.DefaultToMultimapFactory < K , V> - Class in rx.internal.operators: The default multimap factory returning a HashMap.
OperatorToObservableList < T> - Class in rx.internal.operators: Returns an Observable that emits a single item, a list composed of all the items emitted by the source Observable.
OperatorToObservableSortedList < T> - Class in rx.internal.operators: Return an Observable that emits the items emitted by the source Observable, in a sorted order (each item emitted by the Observable must implement Comparable with respect to all other items in the sequence, or you must pass in a sort function).
OperatorToObservableSortedList(int) - Constructor for class rx .internal .operators . OperatorToObservableSortedList
OperatorToObservableSortedList(Func2<? super T, ? super T, Integer>, int) - Constructor for class rx .internal .operators . OperatorToObservableSortedList
OperatorUnsubscribeOn < T> - Class in rx.internal.operators: Unsubscribes on the specified Scheduler.
OperatorUnsubscribeOn(Scheduler) - Constructor for class rx .internal .operators . OperatorUnsubscribeOn
OperatorWindowWithObservable < T , U> - Class in rx.internal.operators: Creates non-overlapping windows of items where each window is terminated by an event from a secondary observable and a new window is started immediately.
OperatorWindowWithObservable(Observable) - Constructor for class rx .internal .operators . OperatorWindowWithObservable
OperatorWindowWithObservableFactory < T , U> - Class in rx.internal.operators: Creates non-overlapping windows of items where each window is terminated by an event from a secondary observable and a new window is started immediately.
OperatorWindowWithObservableFactory(Func0<? extends Observable<? extends U>>) - Constructor for class rx .internal .operators . OperatorWindowWithObservableFactory
OperatorWindowWithSize < T> - Class in rx.internal.operators: Creates windows of values into the source sequence with skip frequency and size bounds.
OperatorWindowWithSize(int, int) - Constructor for class rx .internal .operators . OperatorWindowWithSize
OperatorWindowWithStartEndObservable < T , U , V> - Class in rx.internal.operators: Creates potentially overlapping windows of the source items where each window is started by a value emitted by an observable and closed when an associated Observable emits a value or completes.
OperatorWindowWithStartEndObservable(Observable<? extends U>, Func1<? super U, ? extends Observable<? extends V>>) - Constructor for class rx .internal .operators . OperatorWindowWithStartEndObservable
OperatorWindowWithTime < T> - Class in rx.internal.operators: Creates windows of values into the source sequence with timed window creation, length and size bounds.
OperatorWindowWithTime(long, long, TimeUnit, int, Scheduler) - Constructor for class rx .internal .operators . OperatorWindowWithTime
OperatorWithLatestFrom < T , U , R> - Class in rx.internal.operators: Combines values from two sources only when the main source emits.
OperatorWithLatestFrom(Observable<? extends U>, Func2<? super T, ? super U, ? extends R>) - Constructor for class rx .internal .operators . OperatorWithLatestFrom
OperatorZip < R> - Class in rx.internal.operators: Returns an Observable that emits the results of a function applied to sets of items emitted, in sequence, by two or more other Observables.
OperatorZip(FuncN<? extends R>) - Constructor for class rx .internal .operators . OperatorZip
OperatorZip(Func2) - Constructor for class rx .internal .operators . OperatorZip
OperatorZip(Func3) - Constructor for class rx .internal .operators . OperatorZip
OperatorZip(Func4) - Constructor for class rx .internal .operators . OperatorZip
OperatorZip(Func5) - Constructor for class rx .internal .operators . OperatorZip
OperatorZip(Func6) - Constructor for class rx .internal .operators . OperatorZip
OperatorZip(Func7) - Constructor for class rx .internal .operators . OperatorZip
OperatorZip(Func8) - Constructor for class rx .internal .operators . OperatorZip
OperatorZip(Func9) - Constructor for class rx .internal .operators . OperatorZip
OperatorZipIterable < T1 , T2 , R> - Class in rx.internal.operators
OperatorZipIterable(Iterable<? extends T2>, Func2<? super T1, ? super T2, ? extends R>) - Constructor for class rx .internal .operators . OperatorZipIterable

P

peek() - Method in class rx .internal .util .atomic . MpscLinkedAtomicQueue
peek() - Method in class rx .internal .util .atomic . SpscAtomicArrayQueue
peek() - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
peek() - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
peek() - Method in class rx .internal .util .atomic . SpscLinkedAtomicQueue
peek() - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
peek() - Method in interface rx .internal .util . BackpressureDrainManager.BackpressureQueueCallback: Override this method to peek for the next element, null meaning no next element available now.
peek() - Method in class rx .internal .util . RxRingBuffer
peek() - Method in class rx .internal .util . SynchronizedQueue
peek() - Method in class rx .internal .util .unsafe . MpmcArrayQueue
peek() - Method in class rx .internal .util .unsafe . MpscLinkedQueue
peek() - Method in class rx .internal .util .unsafe . SpmcArrayQueue
peek() - Method in class rx .internal .util .unsafe . SpscArrayQueue
peek() - Method in class rx .internal .util .unsafe . SpscLinkedQueue
peek() - Method in class rx .internal .util .unsafe . SpscUnboundedArrayQueue
phase() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState
phase(int) - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Sets a new phase value.
PlatformDependent - Class in rx.internal.util: Allow platform dependent logic such as checks for Android.
PlatformDependent() - Constructor for class rx .internal .util . PlatformDependent
poll() - Method in class rx .internal .util .atomic . MpscLinkedAtomicQueue
poll() - Method in class rx .internal .util .atomic . SpscAtomicArrayQueue
poll() - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
poll() - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
poll() - Method in class rx .internal .util .atomic . SpscLinkedAtomicQueue: IMPLEMENTATION NOTES:
Poll is allowed from a SINGLE thread.
Poll reads the next node from the consumerNode and: If it is null, the queue is empty.
poll() - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
poll() - Method in interface rx .internal .util . BackpressureDrainManager.BackpressureQueueCallback: Override this method to poll (consume) the next element, null meaning no next element available now.
poll() - Method in class rx .internal .util . RxRingBuffer
poll() - Method in class rx .internal .util . SynchronizedQueue
poll() - Method in class rx .internal .util .unsafe . MpmcArrayQueue
poll() - Method in class rx .internal .util .unsafe . MpscLinkedQueue
poll() - Method in class rx .internal .util .unsafe . SpmcArrayQueue
poll() - Method in class rx .internal .util .unsafe . SpscArrayQueue
poll() - Method in class rx .internal .util .unsafe . SpscLinkedQueue: IMPLEMENTATION NOTES:
Poll is allowed from a SINGLE thread.
Poll reads the next node from the consumerNode and: If it is null, the queue is empty.
poll() - Method in class rx .internal .util .unsafe . SpscUnboundedArrayQueue
Pow2 - Class in rx.internal.util.unsafe
printStackTrace() - Method in exception rx .exceptions . CompositeException: All of the following printStackTrace functionality is derived from JDK Throwable printStackTrace.
printStackTrace(PrintStream) - Method in exception rx .exceptions . CompositeException
printStackTrace(PrintWriter) - Method in exception rx .exceptions . CompositeException
produced(long) - Method in class rx .internal .producers . ProducerArbiter
Producer - Interface in rx
ProducerArbiter - Class in rx.internal.producers: Producer that allows changing an underlying producer atomically and correctly resume with the accumulated requests.
ProducerArbiter() - Constructor for class rx .internal .producers . ProducerArbiter
producerBuffer - Variable in class rx .internal .util .atomic . SpscLinkedArrayQueue
producerBuffer - Variable in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
producerIndex - Variable in class rx .internal .util .atomic . SpscLinkedArrayQueue
producerIndex - Variable in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
producerLookAhead - Variable in class rx .internal .util .atomic . SpscAtomicArrayQueue
producerLookAhead - Variable in class rx .internal .util .atomic . SpscLinkedArrayQueue
producerLookAhead - Variable in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
producerLookAheadStep - Variable in class rx .internal .util .atomic . SpscLinkedArrayQueue
producerLookAheadStep - Variable in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
producerMask - Variable in class rx .internal .util .atomic . SpscLinkedArrayQueue
producerMask - Variable in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
ProducerObserverArbiter < T> - Class in rx.internal.producers: Producer that serializes any event emission with requesting and producer changes.
ProducerObserverArbiter(Subscriber<? super T>) - Constructor for class rx .internal .producers . ProducerObserverArbiter
propagate(Throwable) - Static method in class rx .exceptions . Exceptions: Convenience method to throw a RuntimeException and Error directly or wrap any other exception type into a RuntimeException.
publish() - Method in class rx . Observable: Returns a ConnectableObservable, which is a variety of Observable that waits until its connect method is called before it begins emitting items to those Observers that have subscribed to it.
publish(Func1<? super Observable<T>, ? extends Observable<R>>) - Method in class rx . Observable: Returns an Observable that emits the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the underlying sequence.
PublishSubject < T> - Class in rx.subjects: Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.
PublishSubject(Observable.OnSubscribe<T>, SubjectSubscriptionManager<T>) - Constructor for class rx .subjects . PublishSubject
PURGE_FREQUENCY - Static variable in class rx .internal .schedulers . NewThreadWorker: The purge frequency in milliseconds.

Q

QueuedProducer < T> - Class in rx.internal.producers: Producer that holds an unbounded (or custom) queue, handles terminal events, enqueues values and relays them to a child subscriber on request.
QueuedProducer(Subscriber<? super T>) - Constructor for class rx .internal .producers . QueuedProducer: Constructs an instance with the target child subscriber and an Spsc Linked (Atomic) Queue as the queue implementation.
QueuedProducer(Subscriber<? super T>, Queue<Object>) - Constructor for class rx .internal .producers . QueuedProducer: Constructs an instance with the target child subscriber and a custom queue implementation
QueuedValueProducer < T> - Class in rx.internal.producers: Producer that holds an unbounded (or custom) queue to enqueue values and relays them to a child subscriber on request.
QueuedValueProducer(Subscriber<? super T>) - Constructor for class rx .internal .producers . QueuedValueProducer: Constructs an instance with the target child subscriber and an Spsc Linked (Atomic) Queue as the queue implementation.
QueuedValueProducer(Subscriber<? super T>, Queue<Object>) - Constructor for class rx .internal .producers . QueuedValueProducer: Constructs an instance with the target child subscriber and a custom queue implementation
QueueProgressIndicators - Interface in rx.internal.util.unsafe: This interface is provided for monitoring purposes only and is only available on queues where it is easy to provide it.

R

range(int, int) - Static method in class rx . Observable: Returns an Observable that emits a sequence of Integers within a specified range.
range(int, int, Scheduler) - Static method in class rx . Observable: Returns an Observable that emits a sequence of Integers within a specified range, on a specified Scheduler.
redo(Observable<T>, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>>, Scheduler) - Static method in class rx .internal .operators . OnSubscribeRedo
RedoFinite(long) - Constructor for class rx .internal .operators . OnSubscribeRedo.RedoFinite
reduce(Func2<T, T, T>) - Method in class rx . Observable: Returns an Observable that applies a specified accumulator function to the first item emitted by a source Observable, then feeds the result of that function along with the second item emitted by the source Observable into the same function, and so on until all items have been emitted by the source Observable, and emits the final result from the final call to your function as its sole item.
reduce(R, Func2<R, ? super T, R>) - Method in class rx . Observable: Returns an Observable that applies a specified accumulator function to the first item emitted by a source Observable and a specified seed value, then feeds the result of that function along with the second item emitted by an Observable into the same function, and so on until all items have been emitted by the source Observable, emitting the final result from the final call to your function as its sole item.
refCount() - Method in class rx .observables . ConnectableObservable: Returns an Observable that stays connected to this ConnectableObservable as long as there is at least one subscription to this ConnectableObservable.
RefCountSubscription - Class in rx.subscriptions: Keeps track of the sub-subscriptions and unsubscribes the underlying subscription once all sub-subscriptions have unsubscribed.
RefCountSubscription(Subscription) - Constructor for class rx .subscriptions . RefCountSubscription: Creates a RefCountSubscription by wrapping the given non-null Subscription.
registerErrorHandler(RxJavaErrorHandler) - Method in class rx .plugins . RxJavaPlugins: Registers an RxJavaErrorHandler implementation as a global override of any injected or default implementations.
registerExecutor(ScheduledThreadPoolExecutor) - Static method in class rx .internal .schedulers . NewThreadWorker: Registers the given executor service and starts the purge thread if not already started.
registerObservableExecutionHook(RxJavaObservableExecutionHook) - Method in class rx .plugins . RxJavaPlugins: Register an RxJavaObservableExecutionHook implementation as a global override of any injected or default implementations.
registerSchedulersHook(RxJavaSchedulersHook) - Method in class rx .plugins . RxJavaPlugins: Registers an RxJavaSchedulersHook implementation as a global override of any injected or default implementations.
release() - Method in class rx .internal .util . RxRingBuffer
releaseToPool() - Method in class rx .internal .util . IndexedRingBuffer: This resets the arrays, nulls out references and returns it to the pool.
remove() - Method in class rx .internal .operators . BlockingOperatorToIterator.SubscriberIterator
remove(Object) - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
remove() - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
remove(Object) - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
remove() - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
remove(Object) - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
remove() - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
remove(int) - Method in class rx .internal .util . IndexedRingBuffer
remove(Subscription) - Method in class rx .internal .util . SubscriptionList
remove(Object) - Method in class rx .internal .util . SynchronizedQueue
remove() - Method in class rx .internal .util . SynchronizedQueue
remove(Subscription) - Method in class rx .subscriptions . CompositeSubscription: Removes a Subscription from this CompositeSubscription, and unsubscribes the Subscription.
removeAll(Collection<?>) - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
removeAll(Collection<?>) - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
removeAll(Collection<?>) - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
removeAll(Collection<?>) - Method in class rx .internal .util . SynchronizedQueue
render(Object) - Method in class rx .plugins . RxJavaErrorHandler: Override this method to provide rendering for specific types other than primitive types and null.
repeat(Observable<T>) - Static method in class rx .internal .operators . OnSubscribeRedo
repeat(Observable<T>, Scheduler) - Static method in class rx .internal .operators . OnSubscribeRedo
repeat(Observable<T>, long) - Static method in class rx .internal .operators . OnSubscribeRedo
repeat(Observable<T>, long, Scheduler) - Static method in class rx .internal .operators . OnSubscribeRedo
repeat(Observable<T>, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>>) - Static method in class rx .internal .operators . OnSubscribeRedo
repeat(Observable<T>, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>>, Scheduler) - Static method in class rx .internal .operators . OnSubscribeRedo
repeat() - Method in class rx . Observable: Returns an Observable that repeats the sequence of items emitted by the source Observable indefinitely.
repeat(Scheduler) - Method in class rx . Observable: Returns an Observable that repeats the sequence of items emitted by the source Observable indefinitely, on a particular Scheduler.
repeat(long) - Method in class rx . Observable: Returns an Observable that repeats the sequence of items emitted by the source Observable at most count times.
repeat(long, Scheduler) - Method in class rx . Observable: Returns an Observable that repeats the sequence of items emitted by the source Observable at most count times, on a particular Scheduler.
repeatWhen(Func1<? super Observable<? extends Void>, ? extends Observable<?>>, Scheduler) - Method in class rx . Observable: Returns an Observable that emits the same values as the source Observable with the exception of an onCompleted.
repeatWhen(Func1<? super Observable<? extends Void>, ? extends Observable<?>>) - Method in class rx . Observable: Returns an Observable that emits the same values as the source Observable with the exception of an onCompleted.
replay() - Method in class rx . Observable: Returns a ConnectableObservable that shares a single subscription to the underlying Observable that will replay all of its items and notifications to any future Observer.
replay(Func1<? super Observable<T>, ? extends Observable<R>>) - Method in class rx . Observable: Returns an Observable that emits items that are the results of invoking a specified selector on the items emitted by a ConnectableObservable that shares a single subscription to the source Observable.
replay(Func1<? super Observable<T>, ? extends Observable<R>>, int) - Method in class rx . Observable: Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying bufferSize notifications.
replay(Func1<? super Observable<T>, ? extends Observable<R>>, int, long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying no more than bufferSize items that were emitted within a specified time window.
replay(Func1<? super Observable<T>, ? extends Observable<R>>, int, long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying no more than bufferSize items that were emitted within a specified time window.
replay(Func1<? super Observable<T>, ? extends Observable<R>>, int, Scheduler) - Method in class rx . Observable: Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying a maximum of bufferSize items.
replay(Func1<? super Observable<T>, ? extends Observable<R>>, long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying all items that were emitted within a specified time window.
replay(Func1<? super Observable<T>, ? extends Observable<R>>, long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying all items that were emitted within a specified time window.
replay(Func1<? super Observable<T>, ? extends Observable<R>>, Scheduler) - Method in class rx . Observable: Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable.
replay(int) - Method in class rx . Observable: Returns a ConnectableObservable that shares a single subscription to the source Observable that replays at most bufferSize items emitted by that Observable.
replay(int, long, TimeUnit) - Method in class rx . Observable: Returns a ConnectableObservable that shares a single subscription to the source Observable and replays at most bufferSize items that were emitted during a specified time window.
replay(int, long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns a ConnectableObservable that shares a single subscription to the source Observable and that replays a maximum of bufferSize items that are emitted within a specified time window.
replay(int, Scheduler) - Method in class rx . Observable: Returns a ConnectableObservable that shares a single subscription to the source Observable and replays at most bufferSize items emitted by that Observable.
replay(long, TimeUnit) - Method in class rx . Observable: Returns a ConnectableObservable that shares a single subscription to the source Observable and replays all items emitted by that Observable within a specified time window.
replay(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns a ConnectableObservable that shares a single subscription to the source Observable and replays all items emitted by that Observable within a specified time window.
replay(Scheduler) - Method in class rx . Observable: Returns a ConnectableObservable that shares a single subscription to the source Observable that will replay all of its items and notifications to any future Observer on the given Scheduler.
ReplaySubject < T> - Class in rx.subjects: Subject that buffers all items it observes and replays them to any Observer that subscribes.
request(long) - Method in class rx .internal .producers . ProducerArbiter
request(long) - Method in class rx .internal .producers . ProducerObserverArbiter
request(long) - Method in class rx .internal .producers . QueuedProducer
request(long) - Method in class rx .internal .producers . QueuedValueProducer
request(long) - Method in class rx .internal .producers . SingleDelayedProducer
request(long) - Method in class rx .internal .producers . SingleProducer
request(long) - Method in class rx .internal .util . BackpressureDrainManager
request(long) - Method in interface rx . Producer: Request a certain maximum number of items from this Producer.
request(long) - Method in class rx . Subscriber: Request a certain maximum number of emitted items from the Observable this Subscriber is subscribed to.
requestMore(long) - Method in class rx .observers . TestSubscriber: Allows calling the protected Subscriber.request(long) from unit tests.
resultSelector - Variable in class rx .internal .operators . OnSubscribeGroupJoin
retainAll(Collection<?>) - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
retainAll(Collection<?>) - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
retainAll(Collection<?>) - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
retainAll(Collection<?>) - Method in class rx .internal .util . SynchronizedQueue
retry(Observable<T>) - Static method in class rx .internal .operators . OnSubscribeRedo
retry(Observable<T>, long) - Static method in class rx .internal .operators . OnSubscribeRedo
retry(Observable<T>, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>>) - Static method in class rx .internal .operators . OnSubscribeRedo
retry(Observable<T>, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>>, Scheduler) - Static method in class rx .internal .operators . OnSubscribeRedo
retry() - Method in class rx . Observable: Returns an Observable that mirrors the source Observable, resubscribing to it if it calls onError (infinite retry count).
retry(long) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable, resubscribing to it if it calls onError up to a specified number of retries.
retry(Func2<Integer, Throwable, Boolean>) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable, resubscribing to it if it calls onError and the predicate returns true for that specific exception and retry count.
retryWhen(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>>) - Method in class rx . Observable: Returns an Observable that emits the same values as the source observable with the exception of an onError.
retryWhen(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>>, Scheduler) - Method in class rx . Observable: Returns an Observable that emits the same values as the source observable with the exception of an onError.
RetryWithPredicate(Func2<Integer, Throwable, Boolean>) - Constructor for class rx .internal .operators . OnSubscribeRedo.RetryWithPredicate
returnNull() - Static method in class rx .internal .util . UtilityFunctions: Returns a function that merely returns null, without side effects.
returnObject(T) - Method in class rx .internal .util . ObjectPool: Returns object back to the pool.
right - Variable in class rx .internal .operators . OnSubscribeGroupJoin
rightDuration - Variable in class rx .internal .operators . OnSubscribeGroupJoin
roundToPowerOfTwo(int) - Static method in class rx .internal .util .unsafe . Pow2: Find the next larger positive power of two value up from the given value.
run() - Method in class rx .internal .schedulers . ScheduledAction
rx - package rx: Rx Observables
rx.annotations - package rx.annotations
rx.exceptions - package rx.exceptions
rx.functions - package rx.functions
rx.internal.operators - package rx.internal.operators: Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.internal.producers - package rx.internal.producers
rx.internal.schedulers - package rx.internal.schedulers
rx.internal.util - package rx.internal.util
rx.internal.util.atomic - package rx.internal.util.atomic
rx.internal.util.unsafe - package rx.internal.util.unsafe
rx.observables - package rx.observables
rx.observers - package rx.observers
rx.plugins - package rx.plugins
rx.schedulers - package rx.schedulers: Rx Schedulers
rx.singles - package rx.singles
rx.subjects - package rx.subjects
rx.subscriptions - package rx.subscriptions
RxJavaErrorHandler - Class in rx.plugins: Abstract class for defining error handling logic in addition to the normal Observer.onError(Throwable) behavior.
RxJavaErrorHandler() - Constructor for class rx .plugins . RxJavaErrorHandler
RxJavaObservableExecutionHook - Class in rx.plugins: Abstract ExecutionHook with invocations at different lifecycle points of Observable execution with a default no-op implementation.
RxJavaObservableExecutionHook() - Constructor for class rx .plugins . RxJavaObservableExecutionHook
RxJavaPlugins - Class in rx.plugins: Registry for plugin implementations that allows global override and handles the retrieval of correct implementation based on order of precedence: plugin registered globally via register methods in this class plugin registered and retrieved using System.getProperty(String) (see get methods for property names) default implementation
RxJavaPluginUtils - Class in rx.internal.util
RxJavaPluginUtils() - Constructor for class rx .internal .util . RxJavaPluginUtils
RxJavaSchedulersHook - Class in rx.plugins: This plugin class provides 2 ways to customize Scheduler functionality 1.
RxJavaSchedulersHook() - Constructor for class rx .plugins . RxJavaSchedulersHook
RxRingBuffer - Class in rx.internal.util: This assumes Spsc or Spmc usage.
RxThreadFactory - Class in rx.internal.util
RxThreadFactory(String) - Constructor for class rx .internal .util . RxThreadFactory

S

SafeSubscriber < T> - Class in rx.observers: SafeSubscriber is a wrapper around Subscriber that ensures that the Subscriber complies with the Observable contract.
SafeSubscriber(Subscriber<? super T>) - Constructor for class rx .observers . SafeSubscriber
sample(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits the most recently emitted item (if any) emitted by the source Observable within periodic time intervals.
sample(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits the most recently emitted item (if any) emitted by the source Observable within periodic time intervals, where the intervals are defined on a particular Scheduler.
sample(Observable) - Method in class rx . Observable: Returns an Observable that, when the specified sampler Observable emits an item or completes, emits the most recently emitted item (if any) emitted by the source Observable since the previous emission from the sampler Observable.
scalarFlatMap(Func1<? super T, ? extends Observable<? extends R>>) - Method in class rx .internal .util . ScalarSynchronousObservable
scalarScheduleOn(Scheduler) - Method in class rx .internal .util . ScalarSynchronousObservable: Customized observeOn/subscribeOn implementation which emits the scalar value directly or with less overhead on the specified scheduler.
ScalarSynchronousObservable < T> - Class in rx.internal.util
ScalarSynchronousObservable(T) - Constructor for class rx .internal .util . ScalarSynchronousObservable
scan(Func2<T, T, T>) - Method in class rx . Observable: Returns an Observable that applies a specified accumulator function to the first item emitted by a source Observable, then feeds the result of that function along with the second item emitted by the source Observable into the same function, and so on until all items have been emitted by the source Observable, emitting the result of each of these iterations.
scan(R, Func2<R, ? super T, R>) - Method in class rx . Observable: Returns an Observable that applies a specified accumulator function to the first item emitted by a source Observable and a seed value, then feeds the result of that function along with the second item emitted by the source Observable into the same function, and so on until all items have been emitted by the source Observable, emitting the result of each of these iterations.
schedule(Action0) - Method in class rx .internal .schedulers . NewThreadWorker
schedule(Action0, long, TimeUnit) - Method in class rx .internal .schedulers . NewThreadWorker
schedule(Action0) - Method in class rx . Scheduler.Worker: Schedules an Action for execution.
schedule(Action0, long, TimeUnit) - Method in class rx . Scheduler.Worker: Schedules an Action for execution at some point in the future.
scheduleActual(Action0, long, TimeUnit) - Method in class rx .internal .schedulers . NewThreadWorker
scheduleActual(Action0, long, TimeUnit, CompositeSubscription) - Method in class rx .internal .schedulers . NewThreadWorker
scheduleActual(Action0, long, TimeUnit, SubscriptionList) - Method in class rx .internal .schedulers . NewThreadWorker
ScheduledAction - Class in rx.internal.schedulers: A Runnable that executes an Action0 and can be cancelled.
ScheduledAction(Action0) - Constructor for class rx .internal .schedulers . ScheduledAction
ScheduledAction(Action0, CompositeSubscription) - Constructor for class rx .internal .schedulers . ScheduledAction
ScheduledAction(Action0, SubscriptionList) - Constructor for class rx .internal .schedulers . ScheduledAction
scheduleDirect(Action0) - Method in class rx .internal .schedulers . EventLoopsScheduler: Schedules the action directly on one of the event loop workers without the additional infrastructure and checking.
schedulePeriodically(Action0, long, long, TimeUnit) - Method in class rx . Scheduler.Worker: Schedules a cancelable action to be executed periodically.
Scheduler - Class in rx: A Scheduler is an object that schedules units of work.
Scheduler() - Constructor for class rx . Scheduler
Scheduler.Worker - Class in rx: Sequential Scheduler for executing actions on a single thread or event loop.
SchedulerLifecycle - Interface in rx.internal.schedulers: Represents the capability of a Scheduler to be start or shut down its maintained threads.
Schedulers - Class in rx.schedulers: Static factory methods for creating Schedulers.
sequenceBuffer - Variable in class rx .internal .util .unsafe . ConcurrentSequencedCircularArrayQueue
sequenceEqual(Observable<? extends T>, Observable<? extends T>, Func2<? super T, ? super T, Boolean>) - Static method in class rx .internal .operators . OperatorSequenceEqual: Tests whether two Observable sequences are identical, emitting true if both sequences complete without differing, and false if the two sequences diverge at any point.
sequenceEqual(Observable<? extends T>, Observable<? extends T>) - Static method in class rx . Observable: Returns an Observable that emits a Boolean value that indicates whether two Observable sequences are the same by comparing the items emitted by each Observable pairwise.
sequenceEqual(Observable<? extends T>, Observable<? extends T>, Func2<? super T, ? super T, Boolean>) - Static method in class rx . Observable: Returns an Observable that emits a Boolean value that indicates whether two Observable sequences are the same by comparing the items emitted by each Observable pairwise based on the results of a specified equality function.
serialize() - Method in class rx . Observable: Forces an Observable's emissions and notifications to be serialized and for it to obey the Observable contract in other ways.
SerializedObserver < T> - Class in rx.observers: Enforces single-threaded, serialized, ordered execution of SerializedObserver.onNext(T), SerializedObserver.onCompleted(), and SerializedObserver.onError(java.lang.Throwable).
SerializedObserver(Observer<? super T>) - Constructor for class rx .observers . SerializedObserver
SerializedSubject < T , R> - Class in rx.subjects: Wraps a Subject so that it is safe to call its various on methods from different threads.
SerializedSubject(Subject<T, R>) - Constructor for class rx .subjects . SerializedSubject
SerializedSubscriber < T> - Class in rx.observers: Enforces single-threaded, serialized, ordered execution of SerializedSubscriber.onNext(T), SerializedSubscriber.onCompleted(), and SerializedSubscriber.onError(java.lang.Throwable).
SerializedSubscriber(Subscriber<? super T>) - Constructor for class rx .observers . SerializedSubscriber
SerializedSubscriber(Subscriber<? super T>, boolean) - Constructor for class rx .observers . SerializedSubscriber: Constructor for wrapping and serializing a subscriber optionally sharing the same underlying subscription list.
SerialSubscription - Class in rx.subscriptions: Represents a subscription whose underlying subscription can be swapped for another subscription which causes the previous underlying subscription to be unsubscribed.
SerialSubscription() - Constructor for class rx .subscriptions . SerialSubscription
set(Subscription) - Method in class rx .subscriptions . MultipleAssignmentSubscription: Sets the underlying subscription.
set(Subscription) - Method in class rx .subscriptions . SerialSubscription: Swaps out the old Subscription for the specified Subscription.
setProducer(Producer) - Method in class rx .internal .producers . ProducerArbiter
setProducer(Producer) - Method in class rx .internal .producers . ProducerObserverArbiter
setProducer(Producer) - Method in class rx . Subscriber: If other subscriber is set (by calling constructor Subscriber.Subscriber(Subscriber) or Subscriber.Subscriber(Subscriber, boolean)) then this method calls setProducer on the other subscriber.
setValue(T) - Method in class rx .internal .producers . SingleDelayedProducer
share() - Method in class rx . Observable: Returns a new Observable that multicasts (shares) the original Observable.
shutdown() - Method in class rx .internal .schedulers . EventLoopsScheduler
shutdown() - Method in class rx .internal .schedulers . GenericScheduledExecutorService
shutdown() - Method in interface rx .internal .schedulers . SchedulerLifecycle: Instructs the Scheduler instance to stop threads and stop accepting tasks on any outstanding Workers.
shutdown() - Method in class rx .internal .util . ObjectPool: Shutdown this pool.
shutdown() - Static method in class rx .schedulers . Schedulers: Shuts down those standard Schedulers which support the SchedulerLifecycle interface.
single() - Method in class rx . Observable: Returns an Observable that emits the single item emitted by the source Observable, if that Observable emits only a single item.
single(Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that emits the single item emitted by the source Observable that matches a specified predicate, if that Observable emits one such item.
single() - Method in class rx .observables . BlockingObservable: If this BlockingObservable completes after emitting a single item, return that item, otherwise throw a NoSuchElementException.
single(Func1<? super T, Boolean>) - Method in class rx .observables . BlockingObservable: If this BlockingObservable completes after emitting a single item that matches a given predicate, return that item, otherwise throw a NoSuchElementException.
Single < T> - Class in rx: The Single class implements the Reactive Pattern for a single value response.
Single(Single.OnSubscribe<T>) - Constructor for class rx . Single: Creates a Single with a Function to execute when it is subscribed to (executed).
Single.OnSubscribe < T> - Interface in rx: Invoked when Single.execute is called.
Single.Transformer < T , R> - Interface in rx: Transformer function used by Single.compose(rx.Single.Transformer<? super T, ? extends R>).
SingleDelayedProducer < T> - Class in rx.internal.producers: Producer that emits a single value and completes the child subscriber once that single value is set on it and the child requested items (maybe both asynchronously).
SingleDelayedProducer(Subscriber<? super T>) - Constructor for class rx .internal .producers . SingleDelayedProducer: Constructor, wraps the target child subscriber.
singleOrDefault(T) - Method in class rx . Observable: Returns an Observable that emits the single item emitted by the source Observable, if that Observable emits only a single item, or a default item if the source Observable emits no items.
singleOrDefault(T, Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that emits the single item emitted by the source Observable that matches a predicate, if that Observable emits only one such item, or a default item if the source Observable emits no such items.
singleOrDefault(T) - Method in class rx .observables . BlockingObservable: If this BlockingObservable completes after emitting a single item, return that item; if it emits more than one item, throw an IllegalArgumentException; if it emits no items, return a default value.
singleOrDefault(T, Func1<? super T, Boolean>) - Method in class rx .observables . BlockingObservable: If this BlockingObservable completes after emitting a single item that matches a predicate, return that item; if it emits more than one such item, throw an IllegalArgumentException; if it emits no items, return a default value.
SingleProducer < T> - Class in rx.internal.producers: A producer which emits a single value and completes the child on the first positive request.
SingleProducer(Subscriber<? super T>, T) - Constructor for class rx .internal .producers . SingleProducer: Constructs the producer with the given target child and value to be emitted.
SingleSubscriber < T> - Class in rx: Provides a mechanism for receiving push-based notifications.
SingleSubscriber() - Constructor for class rx . SingleSubscriber
size() - Method in class rx .internal .util .atomic . SpscAtomicArrayQueue
size() - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
size() - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
size() - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
size() - Method in class rx .internal .util . LinkedArrayList: Returns the total size of the list.
SIZE - Static variable in class rx .internal .util . RxRingBuffer
size() - Method in class rx .internal .util . SynchronizedQueue
size() - Method in class rx .internal .util .unsafe . MpmcArrayQueue
size() - Method in class rx .internal .util .unsafe . SpmcArrayQueue
size() - Method in class rx .internal .util .unsafe . SpscArrayQueue
size() - Method in class rx .internal .util .unsafe . SpscUnboundedArrayQueue
size() - Method in class rx .subjects . ReplaySubject: Returns the current number of items (non-terminal events) available for replay.
skip(int) - Method in class rx . Observable: Returns an Observable that skips the first count items emitted by the source Observable and emits the remainder.
skip(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that skips values emitted by the source Observable before a specified time window elapses.
skip(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that skips values emitted by the source Observable before a specified time window on a specified Scheduler elapses.
skipLast(int) - Method in class rx . Observable: Returns an Observable that drops a specified number of items from the end of the sequence emitted by the source Observable.
skipLast(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that drops items emitted by the source Observable during a specified time window before the source completes.
skipLast(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that drops items emitted by the source Observable during a specified time window (defined on a specified scheduler) before the source completes.
skipUntil(Observable) - Method in class rx . Observable: Returns an Observable that skips items emitted by the source Observable until a second Observable emits an item.
skipWhile(Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that skips all items emitted by the source Observable as long as a specified condition holds true, but emits all further source items as soon as the condition becomes false.
soElement(long, E) - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue: An ordered store(store + StoreStore barrier) of an element to a given offset
soElement(E[], long, E) - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue: An ordered store(store + StoreStore barrier) of an element to a given offset
soNext(LinkedQueueNode<E>) - Method in class rx .internal .util .atomic . LinkedQueueNode
soSequence(long[], long, long) - Method in class rx .internal .util .unsafe . ConcurrentSequencedCircularArrayQueue
SPARSE_SHIFT - Static variable in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue
spElement(long, E) - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue: A plain store (no ordering/fences) of an element to a given offset
spElement(E[], long, E) - Method in class rx .internal .util .unsafe . ConcurrentCircularArrayQueue: A plain store (no ordering/fences) of an element to a given offset
SPMC_POOL - Static variable in class rx .internal .util . RxRingBuffer
SpmcArrayQueue < E> - Class in rx.internal.util.unsafe
SpmcArrayQueue(int) - Constructor for class rx .internal .util .unsafe . SpmcArrayQueue
SPSC_POOL - Static variable in class rx .internal .util . RxRingBuffer
SpscArrayQueue < E> - Class in rx.internal.util.unsafe: A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
SpscArrayQueue(int) - Constructor for class rx .internal .util .unsafe . SpscArrayQueue
SpscAtomicArrayQueue < E> - Class in rx.internal.util.atomic: A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
SpscAtomicArrayQueue(int) - Constructor for class rx .internal .util .atomic . SpscAtomicArrayQueue
SpscExactAtomicArrayQueue < T> - Class in rx.internal.util.atomic: A single-producer single-consumer bounded queue with exact capacity tracking.
SpscExactAtomicArrayQueue(int) - Constructor for class rx .internal .util .atomic . SpscExactAtomicArrayQueue
SpscLinkedArrayQueue < T> - Class in rx.internal.util.atomic: A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.
SpscLinkedArrayQueue(int) - Constructor for class rx .internal .util .atomic . SpscLinkedArrayQueue
SpscLinkedAtomicQueue < E> - Class in rx.internal.util.atomic: This is a weakened version of the MPSC algorithm as presented on 1024 Cores by D.
SpscLinkedAtomicQueue() - Constructor for class rx .internal .util .atomic . SpscLinkedAtomicQueue
SpscLinkedQueue < E> - Class in rx.internal.util.unsafe: This is a weakened version of the MPSC algorithm as presented on 1024 Cores by D.
SpscLinkedQueue() - Constructor for class rx .internal .util .unsafe . SpscLinkedQueue
SpscUnboundedArrayQueue < E> - Class in rx.internal.util.unsafe
SpscUnboundedArrayQueue(int) - Constructor for class rx .internal .util .unsafe . SpscUnboundedArrayQueue
SpscUnboundedAtomicArrayQueue < T> - Class in rx.internal.util.atomic: A single-producer single-consumer queue with unbounded capacity.
SpscUnboundedAtomicArrayQueue(int) - Constructor for class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
spValue(E) - Method in class rx .internal .util .atomic . LinkedQueueNode
start() - Method in class rx .internal .schedulers . EventLoopsScheduler
start() - Method in class rx .internal .schedulers . GenericScheduledExecutorService
start() - Method in interface rx .internal .schedulers . SchedulerLifecycle: Allows the Scheduler instance to start threads and accept tasks on them.
start() - Method in class rx .internal .util . ObjectPool
startWith(Observable<T>) - Method in class rx . Observable: Returns an Observable that emits the items in a specified Observable before it begins to emit items emitted by the source Observable.
startWith(Iterable<T>) - Method in class rx . Observable: Returns an Observable that emits the items in a specified Iterable before it begins to emit items emitted by the source Observable.
startWith(T) - Method in class rx . Observable: Returns an Observable that emits a specified item before it begins to emit items emitted by the source Observable.
startWith(T, T) - Method in class rx . Observable: Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.
startWith(T, T, T) - Method in class rx . Observable: Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.
startWith(T, T, T, T) - Method in class rx . Observable: Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.
startWith(T, T, T, T, T) - Method in class rx . Observable: Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.
startWith(T, T, T, T, T, T) - Method in class rx . Observable: Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.
startWith(T, T, T, T, T, T, T) - Method in class rx . Observable: Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.
startWith(T, T, T, T, T, T, T, T) - Method in class rx . Observable: Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.
startWith(T, T, T, T, T, T, T, T, T) - Method in class rx . Observable: Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.
state() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState
stop() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Signals that there won't be any further events.
stopRequested() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState
Subject < T , R> - Class in rx.subjects: Represents an object that is both an Observable and an Observer.
Subject(Observable.OnSubscribe<R>) - Constructor for class rx .subjects . Subject
subscribe() - Method in class rx . Observable: Subscribes to an Observable and ignores onNext and onCompleted emissions.
subscribe(Action1<? super T>) - Method in class rx . Observable: Subscribes to an Observable and provides a callback to handle the items it emits.
subscribe(Action1<? super T>, Action1<Throwable>) - Method in class rx . Observable: Subscribes to an Observable and provides callbacks to handle the items it emits and any error notification it issues.
subscribe(Action1<? super T>, Action1<Throwable>, Action0) - Method in class rx . Observable: Subscribes to an Observable and provides callbacks to handle the items it emits and any error or completion notification it issues.
subscribe(Observer<? super T>) - Method in class rx . Observable: Subscribes to an Observable and provides an Observer that implements functions to handle the items the Observable emits and any error or completion notification it issues.
subscribe(Subscriber<? super T>) - Method in class rx . Observable: Subscribes to an Observable and provides a Subscriber that implements functions to handle the items the Observable emits and any error or completion notification it issues.
subscribe() - Method in class rx .observables . BlockingObservable: Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
subscribe(Observer<? super T>) - Method in class rx .observables . BlockingObservable: Subscribes to the source and calls back the Observer methods on the current thread.
subscribe(Subscriber<? super T>) - Method in class rx .observables . BlockingObservable: Subscribes to the source and calls the Subscriber methods on the current thread.
subscribe(Action1<? super T>) - Method in class rx .observables . BlockingObservable: Subscribes to the source and calls the given action on the current thread and rethrows any exception wrapped into OnErrorNotImplementedException.
subscribe(Action1<? super T>, Action1<? super Throwable>) - Method in class rx .observables . BlockingObservable: Subscribes to the source and calls the given actions on the current thread.
subscribe(Action1<? super T>, Action1<? super Throwable>, Action0) - Method in class rx .observables . BlockingObservable: Subscribes to the source and calls the given actions on the current thread.
subscribe() - Method in class rx . Single: Subscribes to a Single but ignore its emission or notification.
subscribe(Action1<? super T>) - Method in class rx . Single: Subscribes to a Single and provides a callback to handle the item it emits.
subscribe(Action1<? super T>, Action1<Throwable>) - Method in class rx . Single: Subscribes to a Single and provides callbacks to handle the item it emits or any error notification it issues.
subscribe(Subscriber<? super T>) - Method in class rx . Single: Subscribes to a Single and provides a Subscriber that implements functions to handle the item the Single emits or any error notification it issues.
subscribe(SingleSubscriber<? super T>) - Method in class rx . Single: Subscribes to a Single and provides a SingleSubscriber that implements functions to handle the item the Single emits or any error notification it issues.
subscribeOn(Scheduler) - Method in class rx . Observable: Asynchronously subscribes Observers to this Observable on the specified Scheduler.
subscribeOn(Scheduler) - Method in class rx . Single: Asynchronously subscribes subscribers to this Single on the specified Scheduler.
Subscriber < T> - Class in rx: Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.
Subscriber() - Constructor for class rx . Subscriber
Subscriber(Subscriber<?>) - Constructor for class rx . Subscriber: Construct a Subscriber by using another Subscriber for backpressure and for holding the subscription list (when this.add(sub) is called this will in fact call subscriber.add(sub)).
Subscriber(Subscriber<?>, boolean) - Constructor for class rx . Subscriber: Construct a Subscriber by using another Subscriber for backpressure and optionally for holding the subscription list (if shareSubscriptions is true then when this.add(sub) is called this will in fact call subscriber.add(sub)).
SubscriberIterator() - Constructor for class rx .internal .operators . BlockingOperatorToIterator.SubscriberIterator
Subscribers - Class in rx.observers: Helper methods and utilities for creating and working with Subscriber objects.
Subscription - Interface in rx: Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.
SubscriptionList - Class in rx.internal.util: Subscription that represents a group of Subscriptions that are unsubscribed together.
SubscriptionList() - Constructor for class rx .internal .util . SubscriptionList
SubscriptionList(Subscription...) - Constructor for class rx .internal .util . SubscriptionList
SubscriptionList(Subscription) - Constructor for class rx .internal .util . SubscriptionList
Subscriptions - Class in rx.subscriptions: Helper methods and utilities for creating and working with Subscription objects
switchIfEmpty(Observable<? extends T>) - Method in class rx . Observable: Returns an Observable that emits the items emitted by the source Observable or the items of an alternate Observable if the source Observable is empty.
switchMap(Func1<? super T, ? extends Observable<? extends R>>) - Method in class rx . Observable: Returns a new Observable by applying a function that you supply to each item emitted by the source Observable that returns an Observable, and then emitting the items emitted by the most recently emitted of these Observables.
switchOnNext(Observable<? extends Observable<? extends T>>) - Static method in class rx . Observable: Converts an Observable that emits Observables into an Observable that emits the items emitted by the most recently emitted of those Observables.
SynchronizedQueue < T> - Class in rx.internal.util: Intended for use when the `sun.misc.Unsafe` implementations can't be used.
SynchronizedQueue() - Constructor for class rx .internal .util . SynchronizedQueue
SynchronizedQueue(int) - Constructor for class rx .internal .util . SynchronizedQueue
SynchronizedSubscription - Class in rx.internal.util
SynchronizedSubscription(Subscription) - Constructor for class rx .internal .util . SynchronizedSubscription
SyncOnSubscribe < S , T> - Class in rx.observables: A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
SyncOnSubscribe() - Constructor for class rx .observables . SyncOnSubscribe

T

tail() - Method in class rx .internal .util . LinkedArrayList: Returns the tail buffer segment or null if the list is empty.
take(int) - Method in class rx . Observable: Returns an Observable that emits only the first count items emitted by the source Observable.
take(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits those items emitted by source Observable before a specified time runs out.
take(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits those items emitted by source Observable before a specified time (on a specified Scheduler) runs out.
takeFirst(Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that emits only the very first item emitted by the source Observable that satisfies a specified condition.
takeLast(int) - Method in class rx . Observable: Returns an Observable that emits at most the last count items emitted by the source Observable.
takeLast(int, long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits at most a specified number of items from the source Observable that were emitted in a specified window of time before the Observable completed.
takeLast(int, long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits at most a specified number of items from the source Observable that were emitted in a specified window of time before the Observable completed, where the timing information is provided by a given Scheduler.
takeLast(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits the items from the source Observable that were emitted in a specified window of time before the Observable completed.
takeLast(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits the items from the source Observable that were emitted in a specified window of time before the Observable completed, where the timing information is provided by a specified Scheduler.
takeLastBuffer(int) - Method in class rx . Observable: Returns an Observable that emits a single List containing at most the last count elements emitted by the source Observable.
takeLastBuffer(int, long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits a single List containing at most count items from the source Observable that were emitted during a specified window of time before the source Observable completed.
takeLastBuffer(int, long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits a single List containing at most count items from the source Observable that were emitted during a specified window of time (on a specified Scheduler) before the source Observable completed.
takeLastBuffer(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits a single List containing those items from the source Observable that were emitted during a specified window of time before the source Observable completed.
takeLastBuffer(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits a single List containing those items from the source Observable that were emitted during a specified window of time before the source Observable completed, where the timing information is provided by the given Scheduler.
takeUntil(Observable<? extends E>) - Method in class rx . Observable: Returns an Observable that emits the items emitted by the source Observable until a second Observable emits an item.
takeUntil(Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that emits items emitted by the source Observable, checks the specified predicate for each item, and then completes if the condition is satisfied.
takeWhile(Func1<? super T, Boolean>) - Method in class rx . Observable: Returns an Observable that emits items emitted by the source Observable so long as each item satisfied a specified condition, and then completes as soon as this condition is not satisfied.
terminalState - Variable in class rx .internal .util . RxRingBuffer: We store the terminal state separately so it doesn't count against the size.
terminate() - Method in class rx .internal .util . BackpressureDrainManager: Move into a terminal state.
terminate(Throwable) - Method in class rx .internal .util . BackpressureDrainManager: Move into a terminal state with an exception.
terminate() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Terminates the state immediately and calls AbstractOnSubscribe.onTerminated(S) with the custom state.
terminateAndDrain() - Method in class rx .internal .util . BackpressureDrainManager: Move into a terminal state and drain.
terminateAndDrain(Throwable) - Method in class rx .internal .util . BackpressureDrainManager: Move into a terminal state with an exception and drain.
terminated - Variable in class rx .internal .util . BackpressureDrainManager: Indicates a terminal state.
test() - Static method in class rx .schedulers . Schedulers: Creates and returns a TestScheduler, which is useful for debugging.
TestObserver < T> - Class in rx.observers: Observer usable for unit testing to perform assertions, inspect received events or wrap a mocked Observer.
TestObserver(Observer<T>) - Constructor for class rx .observers . TestObserver
TestObserver() - Constructor for class rx .observers . TestObserver
TestScheduler - Class in rx.schedulers: The TestScheduler is useful for debugging.
TestScheduler() - Constructor for class rx .schedulers . TestScheduler
TestSubject < T> - Class in rx.subjects: A variety of Subject that is useful for testing purposes.
TestSubject(Observable.OnSubscribe<T>, SubjectSubscriptionManager<T>, TestScheduler) - Constructor for class rx .subjects . TestSubject
TestSubscriber < T> - Class in rx.observers: A TestSubscriber is a variety of Subscriber that you can use for unit testing, to perform assertions, inspect received events, or wrap a mocked Subscriber.
TestSubscriber(long) - Constructor for class rx .observers . TestSubscriber: Constructs a TestSubscriber with the initial request to be requested from upstream.
TestSubscriber(Observer<T>, long) - Constructor for class rx .observers . TestSubscriber: Constructs a TestSubscriber with the initial request to be requested from upstream and a delegate Observer to wrap.
TestSubscriber(Subscriber<T>) - Constructor for class rx .observers . TestSubscriber
TestSubscriber(Observer<T>) - Constructor for class rx .observers . TestSubscriber
TestSubscriber() - Constructor for class rx .observers . TestSubscriber
throttleFirst(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits only the first item emitted by the source Observable during sequential time windows of a specified duration.
throttleFirst(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits only the first item emitted by the source Observable during sequential time windows of a specified duration, where the windows are managed by a specified Scheduler.
throttleLast(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits only the last item emitted by the source Observable during sequential time windows of a specified duration.
throttleLast(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits only the last item emitted by the source Observable during sequential time windows of a specified duration, where the duration is governed by a specified Scheduler.
throttleWithTimeout(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that only emits those items emitted by the source Observable that are not followed by another emitted item within a specified time window.
throttleWithTimeout(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that only emits those items emitted by the source Observable that are not followed by another emitted item within a specified time window, where the time window is governed by a specified Scheduler.
throwIfAny(List<? extends Throwable>) - Static method in class rx .exceptions . Exceptions: Throws a single or multiple exceptions contained in the collection, wrapping it into CompositeException if necessary.
throwIfFatal(Throwable) - Static method in class rx .exceptions . Exceptions: Throws a particular Throwable only if it belongs to a set of "fatal" error varieties.
throwOrReport(Throwable, Observer<?>, Object) - Static method in class rx .exceptions . Exceptions: Forwards a fatal exception or reports it along with the value caused it to the given Observer.
throwOrReport(Throwable, Observer<?>) - Static method in class rx .exceptions . Exceptions: Forwards a fatal exception or reports it to the given Observer.
timeInterval() - Method in class rx . Observable: Returns an Observable that emits records of the time interval between consecutive items emitted by the source Observable.
timeInterval(Scheduler) - Method in class rx . Observable: Returns an Observable that emits records of the time interval between consecutive items emitted by the source Observable, where this interval is computed on a specified Scheduler.
TimeInterval < T> - Class in rx.schedulers: A TimeInterval represents an item emitted by an Observable along with the amount of time that elapsed either since the emission of the previous item or (if there was no previous item) since the Observable was first subscribed to.
TimeInterval(long, T) - Constructor for class rx .schedulers . TimeInterval: Creates a TimeInterval object.
timeout(Func0<? extends Observable>, Func1<? super T, ? extends Observable<V>>) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable, but notifies observers of a TimeoutException if either the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows defined by other Observables.
timeout(Func0<? extends Observable>, Func1<? super T, ? extends Observable<V>>, Observable<? extends T>) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable, but switches to a fallback Observable if either the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows defined by other Observables.
timeout(Func1<? super T, ? extends Observable<V>>) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable, but notifies observers of a TimeoutException if an item emitted by the source Observable doesn't arrive within a window of time after the emission of the previous item, where that period of time is measured by an Observable that is a function of the previous item.
timeout(Func1<? super T, ? extends Observable<V>>, Observable<? extends T>) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable, but that switches to a fallback Observable if an item emitted by the source Observable doesn't arrive within a window of time after the emission of the previous item, where that period of time is measured by an Observable that is a function of the previous item.
timeout(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted item.
timeout(long, TimeUnit, Observable<? extends T>) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted item.
timeout(long, TimeUnit, Observable<? extends T>, Scheduler) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted item using a specified Scheduler.
timeout(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted item, where this policy is governed on a specified Scheduler.
timeout(long, TimeUnit) - Method in class rx . Single: Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item.
timeout(long, TimeUnit, Scheduler) - Method in class rx . Single: Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item, where this policy is governed on a specified Scheduler.
timeout(long, TimeUnit, Single<? extends T>) - Method in class rx . Single: Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item.
timeout(long, TimeUnit, Single<? extends T>, Scheduler) - Method in class rx . Single: Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item, using a specified Scheduler.
timer(long, long, TimeUnit) - Static method in class rx . Observable: Deprecated.
use Observable.interval(long, long, TimeUnit) instead
timer(long, long, TimeUnit, Scheduler) - Static method in class rx . Observable: Deprecated.
use Observable.interval(long, long, TimeUnit, Scheduler) instead
timer(long, TimeUnit) - Static method in class rx . Observable: Returns an Observable that emits one item after a specified delay, and then completes.
timer(long, TimeUnit, Scheduler) - Static method in class rx . Observable: Returns an Observable that emits one item after a specified delay, on a specified Scheduler, and then completes.
timestamp() - Method in class rx . Observable: Returns an Observable that emits each item emitted by the source Observable, wrapped in a Timestamped object.
timestamp(Scheduler) - Method in class rx . Observable: Returns an Observable that emits each item emitted by the source Observable, wrapped in a Timestamped object whose timestamps are provided by a specified Scheduler.
Timestamped < T> - Class in rx.schedulers: Composite class that takes a value and a timestamp and wraps them.
Timestamped(long, T) - Constructor for class rx .schedulers . Timestamped
toArray() - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
toArray(E[]) - Method in class rx .internal .util .atomic . SpscExactAtomicArrayQueue
toArray() - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
toArray(E[]) - Method in class rx .internal .util .atomic . SpscLinkedArrayQueue
toArray() - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
toArray(E[]) - Method in class rx .internal .util .atomic . SpscUnboundedAtomicArrayQueue
toArray() - Method in class rx .internal .util . SynchronizedQueue
toArray(R[]) - Method in class rx .internal .util . SynchronizedQueue
toBlocking() - Method in class rx . Observable: Converts an Observable into a BlockingObservable (an Observable with blocking operators).
toBlocking() - Method in class rx . Single: Converts a Single into a BlockingSingle (a Single with blocking operators).
toFunc(Action0) - Static method in class rx .functions . Actions: Converts an Action0 to a function that calls the action and returns null.
toFunc(Action1<T1>) - Static method in class rx .functions . Actions: Converts an Action1 to a function that calls the action and returns null.
toFunc(Action2<T1, T2>) - Static method in class rx .functions . Actions: Converts an Action2 to a function that calls the action and returns null.
toFunc(Action3<T1, T2, T3>) - Static method in class rx .functions . Actions: Converts an Action3 to a function that calls the action and returns null.
toFunc(Action4<T1, T2, T3, T4>) - Static method in class rx .functions . Actions: Converts an Action4 to a function that calls the action and returns null.
toFunc(Action5<T1, T2, T3, T4, T5>) - Static method in class rx .functions . Actions: Converts an Action5 to a function that calls the action and returns null.
toFunc(Action6<T1, T2, T3, T4, T5, T6>) - Static method in class rx .functions . Actions: Converts an Action6 to a function that calls the action and returns null.
toFunc(Action7<T1, T2, T3, T4, T5, T6, T7>) - Static method in class rx .functions . Actions: Converts an Action7 to a function that calls the action and returns null.
toFunc(Action8<T1, T2, T3, T4, T5, T6, T7, T8>) - Static method in class rx .functions . Actions: Converts an Action8 to a function that calls the action and returns null.
toFunc(Action9<T1, T2, T3, T4, T5, T6, T7, T8, T9>) - Static method in class rx .functions . Actions: Converts an Action9 to a function that calls the action and returns null.
toFunc(ActionN) - Static method in class rx .functions . Actions: Converts an ActionN to a function that calls the action and returns null.
toFunc(Action0, R) - Static method in class rx .functions . Actions: Converts an Action0 to a function that calls the action and returns a specified value.
toFunc(Action1<T1>, R) - Static method in class rx .functions . Actions: Converts an Action1 to a function that calls the action and returns a specified value.
toFunc(Action2<T1, T2>, R) - Static method in class rx .functions . Actions: Converts an Action2 to a function that calls the action and returns a specified value.
toFunc(Action3<T1, T2, T3>, R) - Static method in class rx .functions . Actions: Converts an Action3 to a function that calls the action and returns a specified value.
toFunc(Action4<T1, T2, T3, T4>, R) - Static method in class rx .functions . Actions: Converts an Action4 to a function that calls the action and returns a specified value.
toFunc(Action5<T1, T2, T3, T4, T5>, R) - Static method in class rx .functions . Actions: Converts an Action5 to a function that calls the action and returns a specified value.
toFunc(Action6<T1, T2, T3, T4, T5, T6>, R) - Static method in class rx .functions . Actions: Converts an Action6 to a function that calls the action and returns a specified value.
toFunc(Action7<T1, T2, T3, T4, T5, T6, T7>, R) - Static method in class rx .functions . Actions: Converts an Action7 to a function that calls the action and returns a specified value.
toFunc(Action8<T1, T2, T3, T4, T5, T6, T7, T8>, R) - Static method in class rx .functions . Actions: Converts an Action8 to a function that calls the action and returns a specified value.
toFunc(Action9<T1, T2, T3, T4, T5, T6, T7, T8, T9>, R) - Static method in class rx .functions . Actions: Converts an Action9 to a function that calls the action and returns a specified value.
toFunc(ActionN, R) - Static method in class rx .functions . Actions: Converts an ActionN to a function that calls the action and returns a specified value.
toFuture(Observable<? extends T>) - Static method in class rx .internal .operators . BlockingOperatorToFuture: Returns a Future that expects a single item from the observable.
toFuture() - Method in class rx .observables . BlockingObservable: Returns a Future representing the single value emitted by this BlockingObservable.
toFuture() - Method in class rx .singles . BlockingSingle: Returns a Future representing the value emitted by this BlockingSingle.
toIterable() - Method in class rx .observables . BlockingObservable: Converts this BlockingObservable into an Iterable.
toIterator(Observable<? extends T>) - Static method in class rx .internal .operators . BlockingOperatorToIterator: Returns an iterator that iterates all values of the observable.
toList() - Method in class rx . Observable: Returns an Observable that emits a single item, a list composed of all the items emitted by the source Observable.
toMap(Func1<? super T, ? extends K>) - Method in class rx . Observable: Returns an Observable that emits a single HashMap containing all items emitted by the source Observable, mapped by the keys returned by a specified keySelector function.
toMap(Func1<? super T, ? extends K>, Func1<? super T, ? extends V>) - Method in class rx . Observable: Returns an Observable that emits a single HashMap containing values corresponding to items emitted by the source Observable, mapped by the keys returned by a specified keySelector function.
toMap(Func1<? super T, ? extends K>, Func1<? super T, ? extends V>, Func0<? extends Map<K, V>>) - Method in class rx . Observable: Returns an Observable that emits a single Map, returned by a specified mapFactory function, that contains keys and values extracted from the items emitted by the source Observable.
toMultimap(Func1<? super T, ? extends K>) - Method in class rx . Observable: Returns an Observable that emits a single HashMap that contains an ArrayList of items emitted by the source Observable keyed by a specified keySelector function.
toMultimap(Func1<? super T, ? extends K>, Func1<? super T, ? extends V>) - Method in class rx . Observable: Returns an Observable that emits a single HashMap that contains an ArrayList of values extracted by a specified valueSelector function from items emitted by the source Observable, keyed by a specified keySelector function.
toMultimap(Func1<? super T, ? extends K>, Func1<? super T, ? extends V>, Func0<? extends Map<K, Collection<V>>>) - Method in class rx . Observable: Returns an Observable that emits a single Map, returned by a specified mapFactory function, that contains an ArrayList of values, extracted by a specified valueSelector function from items emitted by the source Observable and keyed by the keySelector function.
toMultimap(Func1<? super T, ? extends K>, Func1<? super T, ? extends V>, Func0<? extends Map<K, Collection<V>>>, Func1<? super K, ? extends Collection<V>>) - Method in class rx . Observable: Returns an Observable that emits a single Map, returned by a specified mapFactory function, that contains a custom collection of values, extracted by a specified valueSelector function from items emitted by the source Observable, and keyed by the keySelector function.
toObservable() - Method in class rx .observables . AbstractOnSubscribe: Convenience method to create an Observable from this implemented instance.
toObservable() - Method in class rx . Single: Converts this Single into an Observable.
toObservableFuture(Future<? extends T>) - Static method in class rx .internal .operators . OnSubscribeToObservableFuture
toObservableFuture(Future<? extends T>, long, TimeUnit) - Static method in class rx .internal .operators . OnSubscribeToObservableFuture
toPredicate2(Func1<? super T, Boolean>) - Static method in class rx .internal .operators . OperatorSkipWhile: Convert to Func2 type predicate.
toSerialized() - Method in class rx .subjects . Subject: Wraps a Subject so that it is safe to call its various on methods from different threads.
toSingle() - Method in class rx . Observable: Returns a Single that emits the single item emitted by the source Observable, if that Observable emits only a single item.
toSortedList() - Method in class rx . Observable: Returns an Observable that emits a list that contains the items emitted by the source Observable, in a sorted order.
toSortedList(Func2<? super T, ? super T, Integer>) - Method in class rx . Observable: Returns an Observable that emits a list that contains the items emitted by the source Observable, in a sorted order based on a specified comparison function.
toSortedList(int) - Method in class rx . Observable: Returns an Observable that emits a list that contains the items emitted by the source Observable, in a sorted order.
toSortedList(Func2<? super T, ? super T, Integer>, int) - Method in class rx . Observable: Returns an Observable that emits a list that contains the items emitted by the source Observable, in a sorted order based on a specified comparison function.
toString() - Method in class rx .internal .util . LinkedArrayList
toString() - Method in class rx .internal .util . SynchronizedQueue
toString() - Method in class rx . Notification
toString() - Method in class rx .schedulers . TimeInterval
toString() - Method in class rx .schedulers . Timestamped
trampoline() - Static method in class rx .schedulers . Schedulers: Creates and returns a Scheduler that queues work on the current thread to be executed after the current work completes.
TrampolineScheduler - Class in rx.schedulers: Schedules work on the current thread but does not execute immediately.
triggerActions() - Method in class rx .schedulers . TestScheduler: Triggers any actions that have not yet been triggered and that are scheduled to be triggered at or before this Scheduler's present time.
tryEnableCancelPolicy(ScheduledExecutorService) - Static method in class rx .internal .schedulers . NewThreadWorker: Tries to enable the Java 7+ setRemoveOnCancelPolicy.

U

UnicastSubject < T> - Class in rx.internal.operators: A Subject variant which buffers events until a single Subscriber arrives and replays them to it and potentially switches to direct delivery once the Subscriber caught up and requested an unlimited amount.
UNSAFE - Static variable in class rx .internal .util .unsafe . UnsafeAccess
UnsafeAccess - Class in rx.internal.util.unsafe: All use of this class MUST first check that UnsafeAccess.isUnsafeAvailable() == true otherwise NPEs will happen in environments without "suc.misc.Unsafe" such as Android.
unsafeSubscribe(Subscriber<? super T>) - Method in class rx . Observable: Subscribes to an Observable and invokes Observable.OnSubscribe function without any contract protection, error handling, unsubscribe, or execution hooks.
unsafeSubscribe(Subscriber<? super T>) - Method in class rx . Single: Subscribes to a Single and invokes the Single.OnSubscribe function without any contract protection, error handling, unsubscribe, or execution hooks.
unsubscribe() - Method in class rx .internal .schedulers . NewThreadWorker
unsubscribe() - Method in class rx .internal .schedulers . ScheduledAction
unsubscribe() - Method in class rx .internal .util . IndexedRingBuffer
unsubscribe() - Method in class rx .internal .util . RxRingBuffer
unsubscribe() - Method in class rx .internal .util . SubscriptionList: Unsubscribe from all of the subscriptions in the list, which stops the receipt of notifications on the associated Subscriber.
unsubscribe() - Method in class rx .internal .util . SynchronizedSubscription
unsubscribe() - Method in class rx . SingleSubscriber
unsubscribe() - Method in class rx . Subscriber
unsubscribe() - Method in interface rx . Subscription: Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.
unsubscribe() - Method in class rx .subscriptions . BooleanSubscription
unsubscribe() - Method in class rx .subscriptions . CompositeSubscription: Unsubscribes itself and all inner subscriptions.
unsubscribe() - Method in class rx .subscriptions . MultipleAssignmentSubscription
unsubscribe() - Method in class rx .subscriptions . RefCountSubscription
unsubscribe() - Method in class rx .subscriptions . SerialSubscription
unsubscribed() - Static method in class rx .subscriptions . Subscriptions: Returns a Subscription to which unsubscribe does nothing, as it is already unsubscribed.
UnsubscribeFailedException - Exception in rx.exceptions: Represents an exception used to re-throw errors thrown from Subscriber.unsubscribe().
UnsubscribeFailedException(Throwable) - Constructor for exception rx .exceptions . UnsubscribeFailedException: Wraps the Throwable before it is to be re-thrown as an OnErrorFailedException.
UnsubscribeFailedException(String, Throwable) - Constructor for exception rx .exceptions . UnsubscribeFailedException: Customizes the Throwable with a custom message and wraps it before it is to be re-thrown as an UnsubscribeFailedException.
unsubscribeOn(Scheduler) - Method in class rx . Observable: Modifies the source Observable so that subscribers will unsubscribe from it on a specified Scheduler.
use() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Request the state to be used by onNext or returns false if the downstream has unsubscribed.
using(Func0<Resource>, Func1<? super Resource, ? extends Observable<? extends T>>, Action1<? super Resource>) - Static method in class rx . Observable: Constructs an Observable that creates a dependent resource object which is disposed of on unsubscription.
using(Func0<Resource>, Func1<? super Resource, ? extends Observable<? extends T>>, Action1<? super Resource>, boolean) - Static method in class rx . Observable: Constructs an Observable that creates a dependent resource object which is disposed of just before termination if you have set disposeEagerly to true and unsubscription does not occur before termination.
UtilityFunctions - Class in rx.internal.util: Utility functions for internal use that we don't want part of the public API.
UtilityFunctions() - Constructor for class rx .internal .util . UtilityFunctions

V

value() - Method in class rx .singles . BlockingSingle: Returns the item emitted by this BlockingSingle.
valueOf(String) - Static method in enum rx . Notification.Kind: Returns the enum constant of this type with the specified name.
values() - Static method in enum rx . Notification.Kind: Returns an array containing the constants of this enum type, in the order they are declared.
verify() - Method in class rx .observables . AbstractOnSubscribe.SubscriptionState: Verify if the next() generated an event or requested a stop.

W

window(Func0<? extends Observable<? extends TClosing>>) - Method in class rx . Observable: Returns an Observable that emits windows of items it collects from the source Observable.
window(int) - Method in class rx . Observable: Returns an Observable that emits windows of items it collects from the source Observable.
window(int, int) - Method in class rx . Observable: Returns an Observable that emits windows of items it collects from the source Observable.
window(long, long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits windows of items it collects from the source Observable.
window(long, long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits windows of items it collects from the source Observable.
window(long, long, TimeUnit, int, Scheduler) - Method in class rx . Observable: Returns an Observable that emits windows of items it collects from the source Observable.
window(long, TimeUnit) - Method in class rx . Observable: Returns an Observable that emits windows of items it collects from the source Observable.
window(long, TimeUnit, int) - Method in class rx . Observable: Returns an Observable that emits windows of items it collects from the source Observable.
window(long, TimeUnit, int, Scheduler) - Method in class rx . Observable: Returns an Observable that emits windows of items it collects from the source Observable.
window(long, TimeUnit, Scheduler) - Method in class rx . Observable: Returns an Observable that emits windows of items it collects from the source Observable.
window(Observable<? extends TOpening>, Func1<? super TOpening, ? extends Observable<? extends TClosing>>) - Method in class rx . Observable: Returns an Observable that emits windows of items it collects from the source Observable.
window(Observable) - Method in class rx . Observable: Returns an Observable that emits non-overlapping windows of items it collects from the source Observable where the boundary of each window is determined by the items emitted from a specified boundary-governing Observable.
withLatestFrom(Observable<? extends U>, Func2<? super T, ? super U, ? extends R>) - Method in class rx . Observable: Merges the specified Observable into this Observable sequence by using the resultSelector function only when the source Observable (this instance) emits an item.
Worker() - Constructor for class rx . Scheduler.Worker
wrap(Subscriber<? super T>) - Static method in class rx .observers . Subscribers: Returns a new Subscriber that passes all events to subscriber, has backpressure controlled by subscriber and uses the subscription list of subscriber when Subscriber.add(rx.Subscription) is called.

X

xchgProducerNode(LinkedQueueNode<E>) - Method in class rx .internal .util .unsafe . MpscLinkedQueue

Z

zip(Iterable<? extends Observable<?>>, FuncN<? extends R>) - Static method in class rx . Observable: Returns an Observable that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by an Iterable of other Observables.
zip(Observable<? extends Observable<?>>, FuncN<? extends R>) - Static method in class rx . Observable: Returns an Observable that emits the results of a specified combiner function applied to combinations of n items emitted, in sequence, by the n Observables emitted by a specified Observable.
zip(Observable<? extends T1>, Observable<? extends T2>, Func2<? super T1, ? super T2, ? extends R>) - Static method in class rx . Observable: Returns an Observable that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two other Observables.
zip(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Func3<? super T1, ? super T2, ? super T3, ? extends R>) - Static method in class rx . Observable: Returns an Observable that emits the results of a specified combiner function applied to combinations of three items emitted, in sequence, by three other Observables.
zip(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Func4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>) - Static method in class rx . Observable: Returns an Observable that emits the results of a specified combiner function applied to combinations of four items emitted, in sequence, by four other Observables.
zip(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Observable<? extends T5>, Func5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>) - Static method in class rx . Observable: Returns an Observable that emits the results of a specified combiner function applied to combinations of five items emitted, in sequence, by five other Observables.
zip(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Observable<? extends T5>, Observable<? extends T6>, Func6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>) - Static method in class rx . Observable: Returns an Observable that emits the results of a specified combiner function applied to combinations of six items emitted, in sequence, by six other Observables.
zip(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Observable<? extends T5>, Observable<? extends T6>, Observable<? extends T7>, Func7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>) - Static method in class rx . Observable: Returns an Observable that emits the results of a specified combiner function applied to combinations of seven items emitted, in sequence, by seven other Observables.
zip(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Observable<? extends T5>, Observable<? extends T6>, Observable<? extends T7>, Observable<? extends T8>, Func8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>) - Static method in class rx . Observable: Returns an Observable that emits the results of a specified combiner function applied to combinations of eight items emitted, in sequence, by eight other Observables.
zip(Observable<? extends T1>, Observable<? extends T2>, Observable<? extends T3>, Observable<? extends T4>, Observable<? extends T5>, Observable<? extends T6>, Observable<? extends T7>, Observable<? extends T8>, Observable<? extends T9>, Func9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>) - Static method in class rx . Observable: Returns an Observable that emits the results of a specified combiner function applied to combinations of nine items emitted, in sequence, by nine other Observables.
zip(Single<? extends T1>, Single<? extends T2>, Func2<? super T1, ? super T2, ? extends R>) - Static method in class rx . Single: Returns a Single that emits the results of a specified combiner function applied to two items emitted by two other Singles.
zip(Single<? extends T1>, Single<? extends T2>, Single<? extends T3>, Func3<? super T1, ? super T2, ? super T3, ? extends R>) - Static method in class rx . Single: Returns a Single that emits the results of a specified combiner function applied to three items emitted by three other Singles.
zip(Single<? extends T1>, Single<? extends T2>, Single<? extends T3>, Single<? extends T4>, Func4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>) - Static method in class rx . Single: Returns an Observable that emits the results of a specified combiner function applied to four items emitted by four other Singles.
zip(Single<? extends T1>, Single<? extends T2>, Single<? extends T3>, Single<? extends T4>, Single<? extends T5>, Func5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>) - Static method in class rx . Single: Returns an Observable that emits the results of a specified combiner function applied to five items emitted by five other Singles.
zip(Single<? extends T1>, Single<? extends T2>, Single<? extends T3>, Single<? extends T4>, Single<? extends T5>, Single<? extends T6>, Func6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>) - Static method in class rx . Single: Returns an Observable that emits the results of a specified combiner function applied to six items emitted by six other Singles.
zip(Single<? extends T1>, Single<? extends T2>, Single<? extends T3>, Single<? extends T4>, Single<? extends T5>, Single<? extends T6>, Single<? extends T7>, Func7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>) - Static method in class rx . Single: Returns an Observable that emits the results of a specified combiner function applied to seven items emitted by seven other Singles.
zip(Single<? extends T1>, Single<? extends T2>, Single<? extends T3>, Single<? extends T4>, Single<? extends T5>, Single<? extends T6>, Single<? extends T7>, Single<? extends T8>, Func8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>) - Static method in class rx . Single: Returns an Observable that emits the results of a specified combiner function applied to eight items emitted by eight other Singles.
zip(Single<? extends T1>, Single<? extends T2>, Single<? extends T3>, Single<? extends T4>, Single<? extends T5>, Single<? extends T6>, Single<? extends T7>, Single<? extends T8>, Single<? extends T9>, Func9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>) - Static method in class rx . Single: Returns an Observable that emits the results of a specified combiner function applied to nine items emitted by nine other Singles.
zipWith(Iterable<? extends T2>, Func2<? super T, ? super T2, ? extends R>) - Method in class rx . Observable: Returns an Observable that emits items that are the result of applying a specified function to pairs of values, one each from the source Observable and a specified Iterable sequence.
zipWith(Observable<? extends T2>, Func2<? super T, ? super T2, ? extends R>) - Method in class rx . Observable: Returns an Observable that emits items that are the result of applying a specified function to pairs of values, one each from the source Observable and another specified Observable.
zipWith(Single<? extends T2>, Func2<? super T, ? super T2, ? extends R>) - Method in class rx . Single: Returns a Single that emits the result of applying a specified function to the pair of items emitted by the source Single and another specified Single.

_

_onError(Throwable) - Method in class rx .observers . SafeSubscriber: The logic for onError without the isFinished check so it can be called from within onCompleted.

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