ActorConsumer
actor
ActorProducer
actor
actor
stream
akka
root
append
Duct Flow Duct Flow
apply
FlowMaterializer ActorConsumer WatermarkRequestStrategy ActorProducer Log Duct Flow
aroundPostRestart
ActorConsumer ActorProducer
aroundPostStop
ActorConsumer ActorProducer
aroundPreRestart
ActorConsumer ActorProducer
aroundPreStart
ActorConsumer
aroundReceive
ActorConsumer ActorProducer