Top Fields Constructors Methods

org.reactfx

pack-priv Class LimitedInvocationSubscriber<T>

Class Inheritance

extends Object
implements Consumer<T>

java.lang.Object
org.reactfx.LimitedInvocationSubscriber

All Implemented Interfaces

java.util.function.Consumer

Imports

java.util.function.Consumer

Field Summary

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

Constructor Summary

Access	Constructor and Description
pack-priv	LimitedInvocationSubscriber(int limit, Consumer<? super T> subscriber)

Method Summary

Modifier and Type	Method and Description
public void	accept(T t) Implements java.util.function.Consumer.accept. Performs this operation on the given argument.
pack-priv Subscription	subscribeTo(EventStream<? extends T> stream)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

remainingInvocations	back to summary
private int remainingInvocations

subscriber	back to summary
private final Consumer<? super T> subscriber

subscription	back to summary
private Subscription subscription

Constructor Detail

LimitedInvocationSubscriber	back to summary
pack-priv LimitedInvocationSubscriber(int limit, Consumer<? super T> subscriber)

Method Detail

accept

back to summary

public void accept(T t)

Implements java.util.function.Consumer.accept.

Doc from java.util.function.Consumer.accept.

Performs this operation on the given argument.

Annotations

@Override

subscribeTo	back to summary
pack-priv Subscription subscribeTo(EventStream<? extends T> stream)