Concurrent clients with fs2-http

concurrent-fs2-http.scala

// source of uris, may be for example file, or another http server, db ...
val sourceOfUris: Stream[F, Uri] = ??? 

// max requests to process in parallel 
val maxConcurrent: Int = ???

val responses : Stream[F, Stream[F, HttpResponse[F]]] = 
  http.client[Task]().flatMap { client =>
    sourceOfUris map { uri => client.request(HttpRequest.get[F](uri))}
  }

val sourceOfBodys: Stream[F, String] = 
  concurrent.join(maxConcurrent)(response map { _ flatMap { resp => 
    resp.bodyAsString  // but you could consume here bytes, stream, etc... see the doc
  }})