For those that are interested in libraries like these, OCaml has an implementation that written by Jane Street called Pipes[0]. It&#x27;s been around for years, helps trade billions of dollars a day, is written in a language that actually has parametric polymorphism, and a configurable notion of &quot;pushback&quot;. I&#x27;ve written about it before[1].<p>[0]: <a href="https:&#x2F;&#x2F;ocaml.janestreet.com&#x2F;ocaml-core&#x2F;111.28.00&#x2F;doc&#x2F;async_kernel&#x2F;#Pipe" rel="nofollow">https:&#x2F;&#x2F;ocaml.janestreet.com&#x2F;ocaml-core&#x2F;111.28.00&#x2F;doc&#x2F;async_...</a><p>[1]: <a href="https:&#x2F;&#x2F;news.ycombinator.com&#x2F;threads?id=seliopou&amp;next=9809300" rel="nofollow">https:&#x2F;&#x2F;news.ycombinator.com&#x2F;threads?id=seliopou&amp;next=980930...</a>