Highland.js和缓冲区(或队列)

Question

因此，我有下面的代码来模拟这个问题：

const H = require('highland');
const Promise = require('bluebird');

let i = 0
const stream = H(function(push, next) {
  console.log('read', i)
  push(null, i)
  i++;
  Promise.delay(100).then(() => next())
})


stream
  .flatMap(function(x) {
    console.log('start writing', x)
    return H(Promise.delay(2000, 'y').tap(() => console.log('finish writing', x)))
  })
  .done()

它会产生如下输出：

read 0
start writing 0
finish writing 0
read 1
start writing 1

问题:我希望有一个一定大小的缓冲区，我将在其中堆叠来自生产者的数据。因此，使用大小为1的缓冲区，输出应该如下所示：

read 0
start writing 0
read 1
finish writing 0
start writing 1
read 2

因此，如果“生产者”是“忙”的，我想缓冲来自生产者的值。在高地上做这样的事情是可能的吗？

Answer 1

不是的。这是不可能的(不是通过承诺，然而是的-通过回调)，他们确实在this longish issue thread中声明了这一点

这是我决定写scramjet的原因之一。

一个像你这样的简单案例：

let i = 0;
const stream = new (require("scramjet").DataStream)({read() { this.push(i++); })

stream.map(
    (x) => Promise.delay(2000, 'y').tap(() => console.log('finish writing', x))
).accumulate(
    () => 0
).then(
    () => console.log("done")
)

它就像你想要的那样工作。:)

Answer 2

答案就在my arcticle中

这里的想法-缓冲是流api的一部分。高地只是操纵溪流