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