Package rx.internal.operators
Class OnSubscribeRedo<T>
java.lang.Object
rx.internal.operators.OnSubscribeRedo<T>
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super T>>
,Function
,Observable.OnSubscribe<T>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final class
static final class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Func1
<? super Observable<? extends Notification<?>>, ? extends Observable<?>> (package private) static final Func1
<Observable<? extends Notification<?>>, Observable<?>> private final Scheduler
(package private) final Observable
<T> (package private) final boolean
(package private) final boolean
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
OnSubscribeRedo
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> f, boolean stopOnComplete, boolean stopOnError, Scheduler scheduler) -
Method Summary
Modifier and TypeMethodDescriptionvoid
call
(Subscriber<? super T> child) static <T> Observable
<T> redo
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<T> repeat
(Observable<T> source) static <T> Observable
<T> repeat
(Observable<T> source, long count) static <T> Observable
<T> repeat
(Observable<T> source, long count, Scheduler scheduler) static <T> Observable
<T> repeat
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) static <T> Observable
<T> repeat
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<T> repeat
(Observable<T> source, Scheduler scheduler) static <T> Observable
<T> retry
(Observable<T> source) static <T> Observable
<T> retry
(Observable<T> source, long count) static <T> Observable
<T> retry
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) static <T> Observable
<T> retry
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler)
-
Field Details
-
source
-
controlHandlerFunction
private final Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> controlHandlerFunction -
stopOnComplete
final boolean stopOnComplete -
stopOnError
final boolean stopOnError -
scheduler
-
REDO_INFINITE
-
-
Constructor Details
-
OnSubscribeRedo
private OnSubscribeRedo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> f, boolean stopOnComplete, boolean stopOnError, Scheduler scheduler)
-
-
Method Details
-
retry
-
retry
-
retry
public static <T> Observable<T> retry(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) -
retry
public static <T> Observable<T> retry(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) -
repeat
-
repeat
-
repeat
-
repeat
-
repeat
public static <T> Observable<T> repeat(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) -
repeat
public static <T> Observable<T> repeat(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) -
redo
public static <T> Observable<T> redo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) -
call
-