import akka.actor._
import akka.stream._
import akka.stream.scaladsl.{Keep, Sink, Source}

import scala.concurrent.{Await, Future}
import scala.concurrent.duration._
import scala.concurrent.ExecutionContext.Implicits.global

implicit val system = ActorSystem("System")
implicit val materializer = ActorMaterializer()


// remote service mock
def remoteServiceResult(i: Int) = Future(i)

// Типа результат локального асинхронного чего-то там как List[Future[Int]]
val fList: Seq[Future[Int]] = (1 to 10).map { i =>  Future(i) }.toList

// Дожидаемся  результата
val syncLocalResult: Seq[Int] = Await.result(Future.sequence(fList),10 seconds)

// Стримом окучиваем удаленный сервис с ограничением 2 запроса/сек
val remoteServiceAsyncResult: Future[Seq[Int]] = 
  Source
    .fromIterator(() => syncLocalResult.toIterator)
    .throttle(2, 1 second) // Ограничить скорость 2 запроса/сек
    .map{ i =>
      // Тут на свое усмотрение работаем с запросом к сервису (в данном случае синхронно, чтобы на выходе стрима было Future[Seq[Int]])
      // Хотя можно отложить ожидание на потом и получить Future[Seq[Future[Int]]]
      Await.result(remoteServiceResult(i), 10 seconds)
    }
    .toMat(Sink.collection)(Keep.right).run()

 

с ограничением 2 запроса/сек