In Akka 2.5 Source.queue doesn’t allow for concurrent offers.
With Akka 2.6 this is now possible when maxConcurrentOffers is specified.
Source.queue(bufferSize, overflowStrategy,maxConcurrentOffers)
Cheers,
Enno.
2 Likes