Package org.reactfx

Class LimitedInvocationSubscriber<T>

java.lang.Object

org.reactfx.LimitedInvocationSubscriber<T>

All Implemented Interfaces:

Consumer<T>

class LimitedInvocationSubscriber<T>
extends Object
implements Consumer<T>

Field Summary

Fields

Modifier and Type	Field	Description
private int	remainingInvocations
private final Consumer<? super T>	subscriber
private Subscription	subscription

Constructor Summary

Constructors

Constructor	Description
LimitedInvocationSubscriber(int limit, Consumer<? super T> subscriber)

Method Summary

Modifier and Type	Method	Description
void	accept(T t)
(package private) Subscription	subscribeTo(EventStream<? extends T> stream)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Consumer

andThen

Field Details

subscriber

private final Consumer<? super T> subscriber

remainingInvocations

private int remainingInvocations

subscription

private Subscription subscription

Constructor Details

LimitedInvocationSubscriber

LimitedInvocationSubscriber(int limit,
 Consumer<? super T> subscriber)

Method Details

subscribeTo

Subscription subscribeTo(EventStream<? extends T> stream)

accept

public void accept(T t)

Specified by:

accept in interface Consumer<T>