Package org.reactfx
Class LimitedInvocationSubscriber<T>
- java.lang.Object
-
- org.reactfx.LimitedInvocationSubscriber<T>
-
- All Implemented Interfaces:
java.util.function.Consumer<T>
class LimitedInvocationSubscriber<T> extends java.lang.Object implements java.util.function.Consumer<T>
-
-
Field Summary
Fields Modifier and Type Field Description private int
remainingInvocations
private java.util.function.Consumer<? super T>
subscriber
private Subscription
subscription
-
Constructor Summary
Constructors Constructor Description LimitedInvocationSubscriber(int limit, java.util.function.Consumer<? super T> subscriber)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
accept(T t)
(package private) Subscription
subscribeTo(EventStream<? extends T> stream)
-
-
-
Field Detail
-
subscriber
private final java.util.function.Consumer<? super T> subscriber
-
remainingInvocations
private int remainingInvocations
-
subscription
private Subscription subscription
-
-
Constructor Detail
-
LimitedInvocationSubscriber
LimitedInvocationSubscriber(int limit, java.util.function.Consumer<? super T> subscriber)
-
-
Method Detail
-
subscribeTo
Subscription subscribeTo(EventStream<? extends T> stream)
-
-