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 R
finish()
ReducerState<T,R>
update(java.lang.Object batch)
-
-
-
Method Detail
-
finish
R finish()
-
update
ReducerState<T,R> update(java.lang.Object batch)
-
-