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