gistfile1.txt

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.Http.HostConnectionPool
import akka.http.scaladsl.model.{HttpRequest, HttpResponse}
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{Flow, Sink, Source}

import scala.util.{Failure, Success, Try}

object Main {
    def main(args: Array[String]): Unit = {
      implicit val system = ActorSystem()
      implicit val materializer = ActorMaterializer()
      implicit val ec = system.dispatcher

      val poolClientFlow: Flow[(HttpRequest, Int), (Try[HttpResponse], Int), HostConnectionPool] =
        Http().cachedHostConnectionPoolHttps[Int]("www.scala-lang.org", 443, Http().defaultClientHttpsContext)


      val requests = List.fill(100)(HttpRequest(uri = "/")).zipWithIndex
      val source = Source(requests)

      val responses = source
        .via(poolClientFlow)
        .map { r =>
          println("Single response: " + r)
          r._1.map(_.discardEntityBytes())
          r
        }
        .map(r => (Failure(MyException("hardcoded exception")), r._2))
        .runWith(Sink.seq)

      responses.onComplete {
        case Success(res) =>
          println("Completed all with success: " + res)
        case Failure(ex) =>
          println("Failure: " + ex)
      }
    }
}

case class MyException(msg: String) extends Exception(msg)