No description

Roland Kuhn 9298e720ed !str reorganize and implement consume() ... StreamImpl.scala grew too big, so I split it up into producer, consumer, processor, messages and processor generator files. Also unified the way processors and consumers are created (ActorConsumer.props, ActorProcessor.props). Implement toFuture based on transformRecover and consume.		2014-04-16 17:10:57 +02:00
akka-stream/src	!str reorganize and implement consume()	2014-04-16 17:10:57 +02:00