Highland.js 是如何实现背压的？

Question

Highland.js 究竟是如何实现背压的？我很好奇这个。

Answer 1

https://github.com/caolan/highland/blob/2.6.0/lib/index.js#L808

看起来消费者要求他们正在消费的流检查它可能经常拥有的任何其他消费者。如果这些消费者中的任何一个处于 paused 状态，则父流也会暂停。