Top Inners Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeRedo<T>

extends Object
implements Observable.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Static Imports
rx.Observable.unsafeCreate

Nested and Inner Type Summary

Modifier and TypeClass and Description
public static class
OnSubscribeRedo.RedoFinite

public static class
OnSubscribeRedo.RetryWithPredicate

Field Summary

Modifier and TypeField and Description
private final Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>>
controlHandlerFunction

pack-priv static final Func1<Observable<? extends Notification<?>>, Observable<?>>
REDO_INFINITE

private final Scheduler
scheduler

pack-priv final Observable<T>
source

pack-priv final boolean
stopOnComplete

pack-priv final boolean
stopOnError

Constructor Summary

AccessConstructor and Description
private
OnSubscribeRedo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> f, boolean stopOnComplete, boolean stopOnError, Scheduler scheduler)

Method Summary

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

Implements rx.functions.Action1.call.

public static <T> Observable<T>
redo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler)

public static <T> Observable<T>
repeat(Observable<T> source)

public static <T> Observable<T>
repeat(Observable<T> source, Scheduler scheduler)

public static <T> Observable<T>
repeat(Observable<T> source, final long count)

public static <T> Observable<T>
repeat(Observable<T> source, final long count, Scheduler scheduler)

public static <T> Observable<T>
repeat(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler)

public static <T> Observable<T>
repeat(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler)

public static <T> Observable<T>
retry(Observable<T> source)

public static <T> Observable<T>
retry(Observable<T> source, final long count)

public static <T> Observable<T>
retry(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler)

public static <T> Observable<T>
retry(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

controlHandlerFunctionback to summary
private final Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> controlHandlerFunction
REDO_INFINITEback to summary
pack-priv static final Func1<Observable<? extends Notification<?>>, Observable<?>> REDO_INFINITE
schedulerback to summary
private final Scheduler scheduler
sourceback to summary
pack-priv final Observable<T> source
stopOnCompleteback to summary
pack-priv final boolean stopOnComplete
stopOnErrorback to summary
pack-priv final boolean stopOnError

Constructor Detail

OnSubscribeRedoback to summary
private OnSubscribeRedo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> f, boolean stopOnComplete, boolean stopOnError, Scheduler scheduler)

Method Detail

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

Implements rx.functions.Action1.call.

Annotations
@Override
redoback to summary
public static <T> Observable<T> redo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler)
repeatback to summary
public static <T> Observable<T> repeat(Observable<T> source)
repeatback to summary
public static <T> Observable<T> repeat(Observable<T> source, Scheduler scheduler)
repeatback to summary
public static <T> Observable<T> repeat(Observable<T> source, final long count)
repeatback to summary
public static <T> Observable<T> repeat(Observable<T> source, final long count, Scheduler scheduler)
repeatback to summary
public static <T> Observable<T> repeat(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler)
repeatback to summary
public static <T> Observable<T> repeat(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler)
retryback to summary
public static <T> Observable<T> retry(Observable<T> source)
retryback to summary
public static <T> Observable<T> retry(Observable<T> source, final long count)
retryback to summary
public static <T> Observable<T> retry(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler)
retryback to summary
public static <T> Observable<T> retry(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler)
rx.internal.operators back to summary

public final Class OnSubscribeRedo.RedoFinite

extends Object
implements Func1<Observable<? extends Notification<?>>, Observable<?>>
Class Inheritance
All Implemented Interfaces
rx.functions.Func1, rx.functions.Function

Field Summary

Modifier and TypeField and Description
pack-priv final long
count

Constructor Summary

AccessConstructor and Description
public
RedoFinite(long count)

Method Summary

Modifier and TypeMethod and Description
public Observable<?>
call(Observable<? extends Notification<?>> ts)

Implements rx.functions.Func1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

countback to summary
pack-priv final long count

Constructor Detail

RedoFiniteback to summary
public RedoFinite(long count)

Method Detail

callback to summary
public Observable<?> call(Observable<? extends Notification<?>> ts)

Implements rx.functions.Func1.call.

Annotations
@Override
rx.internal.operators back to summary

public final Class OnSubscribeRedo.RetryWithPredicate

extends Object
implements Func1<Observable<? extends Notification<?>>, Observable<? extends Notification<?>>>
Class Inheritance
All Implemented Interfaces
rx.functions.Func1, rx.functions.Function

Field Summary

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

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
public Observable<? extends Notification<?>>
call(Observable<? extends Notification<?>> ts)

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

RetryWithPredicateback to summary
public RetryWithPredicate(Func2<Integer, Throwable, Boolean> predicate)

Method Detail

callback to summary
public Observable<? extends Notification<?>> call(Observable<? extends Notification<?>> ts)

Implements rx.functions.Func1.call.

Annotations
@Override