Result of map and mapAsync(1) in Akka Stream

Viewed 1506

My code which uses mapAync(1) doesn't work what I want it to do. But when I changed the mapAsync(1) to map by using Await.result, it works. So I have a question. Does the following (A) Use map and (B) use mapAsync(1) yield the same result at anytime?

// (A) Use map
someSource
 .map{r => 
   val future = makeFuture(r) // returns the same future if r is the same
   Await.result(future, Duration.Inf)
 }

// (B) Use mapAsync(1)
someSource
 .mapAsync(1){r =>
   val future = makeFuture(r) // returns the same future if r is the same
   future
}

Actually, I want to paste my real code, but it is too long to paste and has some dependencies of my original stages.

2 Answers
Related