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 java.lang.Object implements Func1<Observable<? extends Notification<?>>,Observable<?>>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) Func1<? super Observable<? extends java.lang.Void>,? extends Observable<?>>
notificationHandler
-
Constructor Summary
Constructors Constructor Description RepeatNotificationDematerializer(Func1<? super Observable<? extends java.lang.Void>,? extends Observable<?>> notificationHandler)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Observable<?>
call(Observable<? extends Notification<?>> notifications)
-
-
-
Field Detail
-
notificationHandler
final Func1<? super Observable<? extends java.lang.Void>,? extends Observable<?>> notificationHandler
-
-
Constructor Detail
-
RepeatNotificationDematerializer
public RepeatNotificationDematerializer(Func1<? super Observable<? extends java.lang.Void>,? extends Observable<?>> notificationHandler)
-
-
Method Detail
-
call
public Observable<?> call(Observable<? extends Notification<?>> notifications)
- Specified by:
call
in interfaceFunc1<Observable<? extends Notification<?>>,Observable<?>>
-
-