deprecated Source.actorRef function removed

pjfanning · pjfanning · commit 33f81763137b · 2025-09-16T02:02:46.000+01:00
readability

import

temp compile workaround

Update ConnectionTestApp.scala

Update ConnectionTestApp.scala
diff --git a/http-tests/src/test/scala/org/apache/pekko/http/scaladsl/server/ConnectionTestApp.scala b/http-tests/src/test/scala/org/apache/pekko/http/scaladsl/server/ConnectionTestApp.scala
@@ -42,10 +42,11 @@ object ConnectionTestApp {
 
   val clientFlow = Http().superPool[Int]()
 
-  val sourceActor = {
+  val sourceQueue = {
     // Our superPool expects (HttpRequest, Int) as input
     val source =
-      Source.actorRef[(HttpRequest, Int)](10000, OverflowStrategy.dropNew).buffer(20000, OverflowStrategy.fail)
+      Source.queue[(HttpRequest, Int)](10000)
+        .buffer(20000, OverflowStrategy.fail)
     val sink = Sink.foreach[(Try[HttpResponse], Int)] {
       case (resp, id) => handleResponse(resp, id)
     }
@@ -54,7 +55,7 @@ object ConnectionTestApp {
   }
 
   def sendPoolFlow(uri: Uri, id: Int): Unit = {
-    sourceActor ! ((buildRequest(uri), id))
+    sourceQueue.offer((buildRequest(uri), id))
   }
 
   def sendPoolFuture(uri: Uri, id: Int): Unit = {

Original file line number	Diff line number	Diff line change
`@@ -42,10 +42,11 @@ object ConnectionTestApp {`
`42`	`42`
`43`	`43`	`val clientFlow = Http().superPool[Int]()`
`44`	`44`
`45`		`- val sourceActor = {`
	`45`	`+ val sourceQueue = {`
`46`	`46`	`// Our superPool expects (HttpRequest, Int) as input`
`47`	`47`	`val source =`
`48`		`- Source.actorRef[(HttpRequest, Int)](10000, OverflowStrategy.dropNew).buffer(20000, OverflowStrategy.fail)`
	`48`	`+ Source.queue[(HttpRequest, Int)](10000)`
	`49`	`+ .buffer(20000, OverflowStrategy.fail)`
`49`	`50`	`val sink = Sink.foreach[(Try[HttpResponse], Int)] {`
`50`	`51`	`case (resp, id) => handleResponse(resp, id)`
`51`	`52`	`}`
`@@ -54,7 +55,7 @@ object ConnectionTestApp {`
`54`	`55`	`}`
`55`	`56`
`56`	`57`	`def sendPoolFlow(uri: Uri, id: Int): Unit = {`
`57`		`- sourceActor ! ((buildRequest(uri), id))`
	`58`	`+ sourceQueue.offer((buildRequest(uri), id))`
`58`	`59`	`}`
`59`	`60`
`60`	`61`	`def sendPoolFuture(uri: Uri, id: Int): Unit = {`