Class Functions.BoundedConsumer

  • All Implemented Interfaces:
    Consumer<org.reactivestreams.Subscription>
    Enclosing class:
    Functions

    public static class Functions.BoundedConsumer
    extends java.lang.Object
    implements Consumer<org.reactivestreams.Subscription>
    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) int bufferSize  
    • Constructor Summary

      Constructors 
      Constructor Description
      BoundedConsumer​(int bufferSize)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void accept​(org.reactivestreams.Subscription s)
      Consume the given value.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • bufferSize

        final int bufferSize
    • Constructor Detail

      • BoundedConsumer

        BoundedConsumer​(int bufferSize)
    • Method Detail

      • accept

        public void accept​(org.reactivestreams.Subscription s)
        Description copied from interface: Consumer
        Consume the given value.
        Specified by:
        accept in interface Consumer<org.reactivestreams.Subscription>
        Parameters:
        s - the value