implement stream append backpressure with Enumerable.reduce/3

NFIBrokerage / spear

A sharp EventStoreDB v20+ client backed by Mint :yum:

https://hex.pm/packages/spear

Apache License 2.0

87 stars 14 forks source link

implement stream append backpressure with Enumerable.reduce/3 #3

Closed the-mikedavis closed 3 years ago

the-mikedavis commented 3 years ago

closes #1

uses continuations (t:Enumerable.continuation/0) to suspend a stream temporarily while our little client here waits for the server to give us more WINDOW_UPDATE frames (the HTTP2 client->server request backpressure mechanism)