Akka HTTP:如何让流Http().superPool()在遇到错误的网址时不抛出异常？

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.http.scaladsl.server.Directives._
import akka.stream.ActorMaterializer
import akka.stream.scaladsl._

implicit val system = ActorSystem()
implicit val materializer = ActorMaterializer()
implicit val executionContext = system.dispatcher

val urls = List("https://example.com", "https://invalid-url", "https://example.org")

val requestFlow = Flow[String].map(url => (HttpRequest(uri = url), url))
val responseFlow = Flow[(Try[HttpResponse], String)].map {
  case (Success(response), url) =>
    // 处理成功的响应
    response.discardEntityBytes()
    s"Request to $url succeeded"
  case (Failure(ex), url) =>
    // 处理失败的响应
    s"Request to $url failed: ${ex.getMessage}"
}

val resultFuture = Source(urls)
  .via(requestFlow)
  .mapAsync(4) { case (request, _) => Http().superPool().singleRequest(request) }
  .zip(Source(urls))
  .via(responseFlow)
  .runWith(Sink.foreach(println))

resultFuture.onComplete(_ => system.terminate())