+str #15173 Add user support for actor consumer endpoint

* with full control over back pressure * and pluggable request strategy
2014-05-16 17:08:44 +02:00 · 2014-05-16 17:08:44 +02:00 · 902e6ee6f8
commit 902e6ee6f8
parent f1a483929b
8 changed files with 577 additions and 44 deletions
--- a/akka-stream/src/main/scala/akka/stream/impl/StreamOfStreamProcessors.scala
+++ b/akka-stream/src/main/scala/akka/stream/impl/StreamOfStreamProcessors.scala
@ -7,6 +7,7 @@ import akka.stream.MaterializerSettings
 import akka.actor.{ Actor, Terminated, ActorRef }
 import org.reactivestreams.spi.{ Subscriber, Subscription }
 import org.reactivestreams.api.Producer
+import akka.stream.actor.ActorConsumer.{ OnNext, OnError, OnComplete, OnSubscribe }

 /**
 * INTERNAL API