java.lang.Object
org.nuxeo.lib.stream.pattern.consumer.internals.BatchState

public class BatchState extends Object
Keep state of a batch according to a batch policy.
Since:
9.1
  • Field Details

    • policy

      protected final BatchPolicy policy
    • counter

      protected int counter
    • endMs

      protected long endMs
  • Constructor Details

  • Method Details

    • start

      public void start()
    • inc

      public BatchState.State inc()
    • force

      public void force()
    • last

      public void last()
    • getState

      public BatchState.State getState()
    • getSize

      public int getSize()