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 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