CODEWITHSUNDEEP
scalaakkaakka-stream
cool breeze
cool breeze

Reputation: 4811

Does akka streams use a work pulling model under the covers?

How does akka streams work under the covers?

It is essentially a work pulling (http://www.michaelpollmeier.com/akka-work-pulling-pattern) but maybe have multiple steps to the work pulling mechanism?

Can someone point me to the source code where I can get an idea how it does this, or is it too complex underneath the covers? :)

Upvotes: 0

Views: 670

Answers (1)

lutzh
lutzh

Reputation: 4965

Akka Streams implements Reactive Streams. The idea is that you have "backpressure" in your stream, so the consumer can signal its demand to the producer. This results in "dynamic push-pull":

If the consumer is slower than the producer, it's "pull".

If the producer is slower than the consumer, it's "push".

See http://www.slideshare.net/rolandkuhn/reactive-streams for more information.

Upvotes: 1

Related Questions