Highland.js如何實現背壓？

Question

Highland.js究竟是如何實施反壓的？我對此很好奇。

Answer 1

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

看起來消費者詢問他們消耗來檢查任何其他消費者可能有每隔一段時間流。如果其中任何消費者處於paused狀態，則父流也會暫停。