Package rx.internal.util
Class InternalObservableUtils.RetryNotificationDematerializer
java.lang.Object
rx.internal.util.InternalObservableUtils.RetryNotificationDematerializer
- All Implemented Interfaces:
Func1<Observable<? extends Notification<?>>,
,Observable<?>> Function
- Enclosing class:
InternalObservableUtils
static final class InternalObservableUtils.RetryNotificationDematerializer
extends Object
implements Func1<Observable<? extends Notification<?>>,Observable<?>>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Func1
<? super Observable<? extends Throwable>, ? extends Observable<?>> -
Constructor Summary
ConstructorsConstructorDescriptionRetryNotificationDematerializer
(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>> notificationHandler) -
Method Summary
Modifier and TypeMethodDescriptionObservable
<?> call
(Observable<? extends Notification<?>> notifications)
-
Field Details
-
notificationHandler
-
-
Constructor Details
-
RetryNotificationDematerializer
public RetryNotificationDematerializer(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>> notificationHandler)
-
-
Method Details
-
call
- Specified by:
call
in interfaceFunc1<Observable<? extends Notification<?>>,
Observable<?>>
-