Class ReducingStreamNotifications<T>

All Implemented Interfaces:
AccumulationFacility<T,T>, AccumulationFacility.HomotypicAccumulation<T>, NotificationAccumulator<Consumer<? super T>,T,T>

final class ReducingStreamNotifications<T> extends AbstractReducingStreamNotifications<T>
  • Field Details

  • Constructor Details

    • ReducingStreamNotifications

      ReducingStreamNotifications(BinaryOperator<T> reduction)
  • Method Details

    • reduce

      public T reduce(T accum, T value)