经实测 buffer 第一个 500毫秒不会发出500毫秒时刻的值

[weiwang94]

我使用 angular 6.0.3, rxjs 使用 6.2.2 版本,按照你们的方法使用 buffer, 得出不一样的输出,代码如下

    let scissor = interval(500)
    let emitter = interval(100)
    // 会生成 10 个 值
    let timeTake = take(10)
    let emitterTake = timeTake(emitter)

    let rxBuffer =  buffer(scissor)
    let stream$ = rxBuffer(emitterTake)
    stream$.subscribe(d => {
        // 500 毫秒后 生成 [ 0, 1, 2, 3]
        // 再过 500 毫秒后 生成 [4, 5, 6, 7，8]
        console.log('d', d)
    })

``

[weiwang94]

对不起没看到 你写的 rxjs 5 版本

    let scissor = interval(500)
    let stream$ = interval(100).pipe(take(10), tap(i => console.log('i', i)),buffer(scissor))

    stream$.subscribe(d => {
        // 500 毫秒后 生成 [ 0, 1, 2, 3]
        // 再过 500 毫秒后 生成 [4, 5, 6, 7，8]
        console.log('d', d)
    })

这是我的调试代码, 发现第一个 500毫秒确实没有发出第 5 个值

[SangKa]

版本的不一致性可能会带来诸如此类的问题。
近日将此仓库同步至最新版本 (#6 )，届时可以再用 RxJS 6 尝试。