Hi,
I am trying to debug some code that stalls while calling akka-http (using a
connection pool), without any akka-http timeouts kicking in.
(the problem being intermittent).
The obvious problem would be `response.discardEntityBytes()` being
forgotten, but I (think I) consume the entityBytes
(
nWith(Sink.ignore)
val systemTerminatedFuture = sourceProcessed.flatMap { _ =>
Http().shutdownAllConnectionPools().flatMap { _ =>
materializer.shutdown()
system.terminate()
}
}
Await.result(systemTerminatedFuture, Duration.Inf)
}
On Tuesday, 8 November 2016 11:2
*Simplest code to reproduce:*
class StreamOmplusEvents {
implicit val system = ActorSystem()
implicit val materializer = ActorMaterializer()
implicit val timeout = Timeout(10.seconds)
import system.dispatcher
val request = HttpRequest(
uri = "https://httpstatuses.com/200";
)
