Top Inners Fields Constructors Methods
rx.internal.operators

public final Class OperatorRetryWithPredicate<T>

extends Object
implements Observable.Operator<T, Observable<T>>
Class Inheritance
All Implemented Interfaces
rx.Observable.Operator, rx.functions.Func1, rx.functions.Function
Imports
java.util.concurrent.atomic.AtomicInteger, rx.*, rx.functions.*, rx.internal.producers.ProducerArbiter, rx.schedulers.Schedulers, rx.subscriptions.SerialSubscription

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
OperatorRetryWithPredicate.SourceSubscriber<T>

Field Summary

Modifier and TypeField and Description
pack-priv final Func2<Integer, Throwable, Boolean>
predicate

Constructor Summary

AccessConstructor and Description
public
OperatorRetryWithPredicate(Func2<Integer, Throwable, Boolean> predicate)

Method Summary

Modifier and TypeMethod and Description
public Subscriber<? super Observable<T>>
call(final Subscriber<? super T> child)

Implements rx.functions.Func1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

predicateback to summary
pack-priv final Func2<Integer, Throwable, Boolean> predicate

Constructor Detail

OperatorRetryWithPredicateback to summary
public OperatorRetryWithPredicate(Func2<Integer, Throwable, Boolean> predicate)

Method Detail

callback to summary
public Subscriber<? super Observable<T>> call(final Subscriber<? super T> child)

Implements rx.functions.Func1.call.

Annotations
@Override
rx.internal.operators back to summary

pack-priv final Class OperatorRetryWithPredicate.SourceSubscriber<T>

extends Subscriber<Observable<T>>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final AtomicInteger
attempts

pack-priv final Subscriber<? super T>
child

pack-priv final Scheduler.Worker
inner

pack-priv final ProducerArbiter
pa

pack-priv final Func2<Integer, Throwable, Boolean>
predicate

pack-priv final SerialSubscription
serialSubscription

Constructor Summary

AccessConstructor and Description
public
SourceSubscriber(Subscriber<? super T> child, final Func2<Integer, Throwable, Boolean> predicate, Scheduler.Worker inner, SerialSubscription serialSubscription, ProducerArbiter pa)

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(final Observable<T>
the item emitted by the Observable
o)

Implements rx.Observer.onNext.

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

Field Detail

attemptsback to summary
pack-priv final AtomicInteger attempts
childback to summary
pack-priv final Subscriber<? super T> child
innerback to summary
pack-priv final Scheduler.Worker inner
paback to summary
pack-priv final ProducerArbiter pa
predicateback to summary
pack-priv final Func2<Integer, Throwable, Boolean> predicate
serialSubscriptionback to summary
pack-priv final SerialSubscription serialSubscription

Constructor Detail

SourceSubscriberback to summary
public SourceSubscriber(Subscriber<? super T> child, final Func2<Integer, Throwable, Boolean> predicate, Scheduler.Worker inner, SerialSubscription serialSubscription, ProducerArbiter pa)

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(final Observable<T> o)

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
o:Observable<T>

the item emitted by the Observable

Annotations
@Override