deprecated Source.actorRef function removed

readability

import

Author: pjfanning

http-tests/src/test/scala/org/apache/pekko/http/scaladsl/server/ConnectionTestApp.scala

@@ -18,7 +18,7 @@ import pekko.actor._
 import pekko.http.scaladsl.Http
 import pekko.http.scaladsl.model.{ HttpRequest, HttpResponse, Uri }
 import pekko.stream.scaladsl.{ Flow, Sink, Source }
-import pekko.stream.OverflowStrategy
+import pekko.stream.{ CompletionStrategy, OverflowStrategy }
 import com.typesafe.config.{ Config, ConfigFactory }
 
 import scala.concurrent.Future
@@ -45,7 +45,16 @@ object ConnectionTestApp {
   val sourceActor = {
     // Our superPool expects (HttpRequest, Int) as input
     val source =
-      Source.actorRef[(HttpRequest, Int)](10000, OverflowStrategy.dropNew).buffer(20000, OverflowStrategy.fail)
+      Source.actorRef[(HttpRequest, Int)](
+        {
+          case Status.Success(s: CompletionStrategy) => s
+          case Status.Success(_)                     => CompletionStrategy.Draining
+          case Status.Success                        => CompletionStrategy.Draining
+        },
+        { case Status.Failure(cause) => cause },
+        10000,
+        OverflowStrategy.dropNew)
+        .buffer(20000, OverflowStrategy.fail)
     val sink = Sink.foreach[(Try[HttpResponse], Int)] {
       case (resp, id) => handleResponse(resp, id)
     }