We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1202fa6 commit ba3607fCopy full SHA for ba3607f
http-tests/src/test/scala/org/apache/pekko/http/scaladsl/server/ConnectionTestApp.scala
@@ -53,7 +53,7 @@ object ConnectionTestApp {
53
},
54
{ case Status.Failure(cause) => cause },
55
10000,
56
- OverflowStrategy.dropNew)
+ OverflowStrategy.fail) // TODO find a better way, was dropNew but that is removed in Pekko 2.0
57
.buffer(20000, OverflowStrategy.fail)
58
val sink = Sink.foreach[(Try[HttpResponse], Int)] {
59
case (resp, id) => handleResponse(resp, id)
0 commit comments