Package akka.stream.impl
Interface ReducerState<T,R>
-
- All Known Implementing Classes:
FirstReducerState,MutableReducerState
public interface ReducerState<T,R>INTERNAL APIHelper class to be able to express reduce as a fold for parallel collector without accidentally sharing state between materializations
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Rfinish()ReducerState<T,R>update(java.lang.Object batch)
-
-
-
Method Detail
-
finish
R finish()
-
update
ReducerState<T,R> update(java.lang.Object batch)
-
-