OnSubscribeRedo

java.lang.Object
- rx.internal.operators.OnSubscribeRedo<T>

All Implemented Interfaces:

Action, Action1<Subscriber<? super T>>, Function, Observable.OnSubscribe<T>
```
public final class OnSubscribeRedo<T>
extends Object
implements Observable.OnSubscribe<T>
```

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
`static class`	`OnSubscribeRedo.RedoFinite`
`static class`	`OnSubscribeRedo.RetryWithPredicate`

Method Summary

All Methods

Static Methods

Instance Methods

Concrete Methods
Modifier and Type	Method and Description
`void`	`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, 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, long count)`
`static <T> Observable<T>`	`repeat(Observable<T> source, long count, 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, 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)`
`static <T> Observable<T>`	`retry(Observable<T> source, long count)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

retry

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

retry

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

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

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

repeat

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

repeat

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

repeat

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

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

public void call(Subscriber<? super T> child)

Class OnSubscribeRedo<T>

Nested Class Summary

Nested Classes

Method Summary

Methods inherited from class java.lang.Object

Method Detail

retry

retry

retry

retry

repeat

repeat

repeat

repeat

repeat

repeat

redo

call