Package org.reactfx

Class LimitedInvocationSubscriber<T>

  • All Implemented Interfaces:
    java.util.function.Consumer<T>

    class LimitedInvocationSubscriber<T>
    extends java.lang.Object
    implements java.util.function.Consumer<T>
    • Field Detail

      • subscriber

        private final java.util.function.Consumer<? super T> subscriber
      • remainingInvocations

        private int remainingInvocations
    • Constructor Detail

      • LimitedInvocationSubscriber

        LimitedInvocationSubscriber​(int limit,
                                    java.util.function.Consumer<? super T> subscriber)
    • Method Detail

      • accept

        public void accept​(T t)
        Specified by:
        accept in interface java.util.function.Consumer<T>