4 ms·
Sure it's demand based, but how is it implemented? How is the demand communicated between the processes?
by lpgauth 10y ago
Sure it's demand based, but how is it implemented? How is the demand communicated between the processes?
- querulous 10y agoi believe it's similar to window updates in http2. consumers send an async message to producers with a count of messages they are willing to accept and it's up to producers to not exceed the count
- josevalim 10y agoI am on my phone (sorry) but the documentation for the GenStage module has a section on the message protocol between consumers and producers. GenStage is simply one implementation of this message protocol.