scala-akka-streams-concurrent-requests

scala-akka-streams-concurrent-requests.scala

Source(List("/", "/docs"))
  .map(theUri => HttpRequest(uri = theUri))
  .via(Http().outgoingConnection("akka.io").async)
  .mapAsyncUnordered(2)(r => r.entity.toStrict(2 seconds))
  .map(e => e.data.utf8String)
  .fold(List[String]())(_ :+ _)
  .runWith(Sink.head)
  .onComplete(logger.info("{}", _))


//other
Http().singleRequest(HttpRequest(uri = "http://akka.io")).flatMap { response1 =>
  Http().singleRequest(HttpRequest(uri = "http://scala-lang.org")).flatMap { response2 =>
    response1.entity.toStrict(1 second).flatMap { entity1 =>
      response2.entity.toStrict(1 second).map { entity2 =>
        entity1.data.utf8String + entity2.data.utf8String
      }
    }
  }
}.onComplete(result => logger.info("{}", result))