Package akka.stream.impl

Class MutableReducerState<T,​R>

  • All Implemented Interfaces:
    ReducerState<T,​R>
    public final class MutableReducerState<T,​R>
extends java.lang.Object
implements ReducerState<T,​R>
    INTERNAL API

    Helper class to be able to express reduce as a fold for parallel collector

    • Constructor Summary

      Constructors 
      Constructor Description
      MutableReducerState​(java.util.stream.Collector<T,​java.lang.Object,​R> collector, java.util.function.BinaryOperator<java.lang.Object> combiner, java.lang.Object reduced)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.stream.Collector<T,​java.lang.Object,​R> collector()  
      java.util.function.BinaryOperator<java.lang.Object> combiner()  
      R finish()  
      java.lang.Object reduced()  
      void reduced_$eq​(java.lang.Object x$1)  
      ReducerState<T,​R> update​(java.lang.Object batch)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • MutableReducerState

        public MutableReducerState​(java.util.stream.Collector<T,​java.lang.Object,​R> collector,
                           java.util.function.BinaryOperator<java.lang.Object> combiner,
                           java.lang.Object reduced)

    • Method Detail

      • collector

        public java.util.stream.Collector<T,​java.lang.Object,​R> collector()

      • combiner

        public java.util.function.BinaryOperator<java.lang.Object> combiner()

      • reduced

        public java.lang.Object reduced()

      • reduced_$eq

        public void reduced_$eq​(java.lang.Object x$1)