Rxjs: bufferTime minBufferSize

[dooreelko]

Hello.
I think it can be also very helpful to have a minBufferSize parameter that will prevent the buffer from emitting if there are not enough source values to emit so that the pipeline will not need to check if there's actually something to process. Currently an empty array is emitted.

To emulate current behaviour the default is 0.
A value of X will mean "emit after delay only if buffer's has at least X elements, otherwise emit immediately after one is available".

What do you think?

[msc117]

Running into the same issue. I have an event stream where I want to catch a timed buffer after the first emitted value rather than endless empty buffers being emitted.

Edit: I was able to do this with bufferToggle
@durilka https://github.com/btroncone/learn-rxjs/blob/master/operators/transformation/buffertoggle.md
The tricky part was figuring out to use throttleTime on the openings Observable

      this.source.bufferToggle(this.source.throttleTime(200), () => Observable.timer(200))
         .subscribe(buffered => {
            ...
         });

[zlepper]

This just bit me in the butt. I had expected buffer to only emit when there actually was new values (Like normal observables), and not whenever the timer ticked. But a minBufferSize could definitely fix that.

[NathanBraslavski]

another simple fix would be to filter empty events:

.pipe(
    bufferTime(200),
    filter(buffer => buffer.length > 0),
    ...
)

But I agree that it should be supported by the library in a more efficient way