Top Description Inners Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeTimeoutSelectorWithFallback<T, U, V>

extends Object
implements Observable.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the input and output value type
<U>
the value type of the first timeout Observable
<V>
the value type of the item-based timeout Observable
Imports
java.util.concurrent.TimeoutException, java.util.concurrent.atomic.AtomicLong, rx.*, rx.exceptions.Exceptions, rx.functions.Func1, rx.internal.operators.OnSubscribeTimeoutTimedWithFallback.FallbackSubscriber, rx.internal.producers.ProducerArbiter, rx.internal.subscriptions.SequentialSubscription, rx.plugins.RxJavaHooks

Switches to the fallback Observable if: the first upstream item doesn't arrive before the first timeout Observable signals an item or completes; or the Observable generated from the previous upstream item signals its item or completes before the upstream signals the next item of its own.
Since
1.3.3

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class

Field Summary

Modifier and TypeField and Description
pack-priv final Observable<? extends T>
pack-priv final Observable<U>
pack-priv final Func1<? super T, ? extends Observable<V>>
pack-priv final Observable<T>

Constructor Summary

AccessConstructor and Description
public
OnSubscribeTimeoutSelectorWithFallback(Observable<T> source, Observable<U> firstTimeoutIndicator, Func1<? super T, ? extends Observable<V>> itemTimeoutIndicator, Observable<? extends T> fallback)

Method Summary

Modifier and TypeMethod and Description
public void
call(Subscriber<? super T> t)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

fallbackback to summary
pack-priv final Observable<? extends T> fallback
firstTimeoutIndicatorback to summary
pack-priv final Observable<U> firstTimeoutIndicator
itemTimeoutIndicatorback to summary
pack-priv final Func1<? super T, ? extends Observable<V>> itemTimeoutIndicator
sourceback to summary
pack-priv final Observable<T> source

Constructor Detail

OnSubscribeTimeoutSelectorWithFallbackback to summary
public OnSubscribeTimeoutSelectorWithFallback(Observable<T> source, Observable<U> firstTimeoutIndicator, Func1<? super T, ? extends Observable<V>> itemTimeoutIndicator, Observable<? extends T> fallback)

Method Detail

callback to summary
public void call(Subscriber<? super T> t)

Implements rx.functions.Action1.call.

Annotations
@Override
rx.internal.operators back to summary

pack-priv final Class OnSubscribeTimeoutSelectorWithFallback.TimeoutMainSubscriber<T>

extends Subscriber<T>
Class Inheritance

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class

Field Summary

Modifier and TypeField and Description
pack-priv final Subscriber<? super T>
pack-priv final ProducerArbiter
pack-priv long
pack-priv final Observable<? extends T>
pack-priv final AtomicLong
pack-priv final Func1<? super T, ? extends Observable<?>>
pack-priv final SequentialSubscription
pack-priv final SequentialSubscription

Constructor Summary

AccessConstructor and Description
pack-priv
TimeoutMainSubscriber(Subscriber<? super T> actual, Func1<? super T, ? extends Observable<?>> itemTimeoutIndicator, Observable<? extends T> fallback)

Method Summary

Modifier and TypeMethod and Description
public void
onCompleted()

Implements rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.
public void
onError(Throwable
the exception encountered by the Observable
e
)

Implements rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.
public void
onNext(T
the item emitted by the Observable
t
)

Implements rx.Observer.onNext.

Provides the Observer with a new item to observe.
pack-priv void
onTimeout(long idx)

pack-priv void
onTimeoutError(long idx, Throwable ex)

public void
setProducer(Producer
producer to be used by this subscriber or the other subscriber (or recursively its other subscriber) to make requests from
p
)

Overrides rx.Subscriber.setProducer.

If other subscriber is set (by calling constructor Subscriber(Subscriber) or Subscriber(Subscriber, boolean)) then this method calls setProducer on the other subscriber.
pack-priv void
startFirst(Observable<?> firstTimeoutIndicator)

Inherited from rx.Subscriber:
addisUnsubscribedonStartrequestunsubscribe

Field Detail

actualback to summary
pack-priv final Subscriber<? super T> actual
arbiterback to summary
pack-priv final ProducerArbiter arbiter
consumedback to summary
pack-priv long consumed
fallbackback to summary
pack-priv final Observable<? extends T> fallback
indexback to summary
pack-priv final AtomicLong index
itemTimeoutIndicatorback to summary
pack-priv final Func1<? super T, ? extends Observable<?>> itemTimeoutIndicator
taskback to summary
pack-priv final SequentialSubscription task
upstreamback to summary
pack-priv final SequentialSubscription upstream

Constructor Detail

TimeoutMainSubscriberback to summary
pack-priv TimeoutMainSubscriber(Subscriber<? super T> actual, Func1<? super T, ? extends Observable<?>> itemTimeoutIndicator, Observable<? extends T> fallback)

Method Detail

onCompletedback to summary
public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters
e:Throwable

the exception encountered by the Observable

Annotations
@Override
onNextback to summary
public void onNext(T t)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters
t:T

the item emitted by the Observable

Annotations
@Override
onTimeoutback to summary
pack-priv void onTimeout(long idx)
onTimeoutErrorback to summary
pack-priv void onTimeoutError(long idx, Throwable ex)
setProducerback to summary
public void setProducer(Producer p)

Overrides rx.Subscriber.setProducer.

Doc from rx.Subscriber.setProducer.

If other subscriber is set (by calling constructor Subscriber(Subscriber) or Subscriber(Subscriber, boolean)) then this method calls setProducer on the other subscriber. If the other subscriber is not set and no requests have been made to this subscriber then p.request(Long.MAX_VALUE) is called. If the other subscriber is not set and some requests have been made to this subscriber then p.request(n) is called where n is the accumulated requests to this subscriber.

Parameters
p:Producer

producer to be used by this subscriber or the other subscriber (or recursively its other subscriber) to make requests from

Annotations
@Override
startFirstback to summary
pack-priv void startFirst(Observable<?> firstTimeoutIndicator)
rx.internal.operators back to summary

pack-priv final Class OnSubscribeTimeoutSelectorWithFallback.TimeoutMainSubscriber.TimeoutConsumer

extends Subscriber<Object>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv boolean
pack-priv final long

Constructor Summary

AccessConstructor and Description
pack-priv
TimeoutConsumer(long idx)

Method Summary

Modifier and TypeMethod and Description
public void
onCompleted()

Implements rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.
public void
onError(Throwable
the exception encountered by the Observable
e
)

Implements rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.
public void
onNext(Object
the item emitted by the Observable
t
)

Implements rx.Observer.onNext.

Provides the Observer with a new item to observe.
Inherited from rx.Subscriber:
addisUnsubscribedonStartrequestsetProducerunsubscribe

Field Detail

doneback to summary
pack-priv boolean done
idxback to summary
pack-priv final long idx

Constructor Detail

TimeoutConsumerback to summary
pack-priv TimeoutConsumer(long idx)

Method Detail

onCompletedback to summary
public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters
e:Throwable

the exception encountered by the Observable

Annotations
@Override
onNextback to summary
public void onNext(Object t)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters
t:Object

the item emitted by the Observable

Annotations
@Override