Package akka.stream.impl
Interface CollectorState<T,R>
-
- All Known Implementing Classes:
FirstCollectorState,MutableCollectorState
public interface CollectorState<T,R>INTERNAL APIHelper class to be able to express collection as a fold using mutable data without accidentally sharing state between materializations
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.lang.Objectaccumulated()Rfinish()CollectorState<T,R>update(T elem)
-
-
-
Method Detail
-
accumulated
java.lang.Object accumulated()
-
finish
R finish()
-
update
CollectorState<T,R> update(T elem)
-
-