Package io.servicetalk.concurrent.api

Interface BufferStrategy.Accumulator<T,B>

Type Parameters:
T - Type of items added to this BufferStrategy.Accumulator.
B - Type of item created when an accumulation is finished.
Enclosing interface:
BufferStrategy<T,BC extends BufferStrategy.Accumulator<T,B>,B>
public static interface BufferStrategy.Accumulator<T,B>
An intermediate mutable object that holds items till it is finished.

None of the methods on an instance of an BufferStrategy.Accumulator will be invoked concurrently and no other method will be called after finish() returns.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    accumulate(T item)
    Adds the passed item to this BufferStrategy.Accumulator.
    B
    finish()
    Finishes accumulation and returns the accumulated value.

  • Method Details

    • accumulate

      void accumulate(@Nullable T item)
      Adds the passed item to this BufferStrategy.Accumulator.
      Parameters:
      item - to add to this BufferStrategy.Accumulator.

    • finish

      B finish()
      Finishes accumulation and returns the accumulated value.
      Returns:
      Accumulated value.