Skip to content

Error on complete when using .bufferTime().take() and supplying a maxBufferSize #1944

@sbm007

Description

@sbm007

RxJS version:
[email protected]

Code to reproduce:
jsbin example

Rx.Observable.interval(100)
  .bufferTime(1000, null, 5)
  .take(5)
  .subscribe(console.log.bind(console.log));

Expected behavior:
Stream should complete without any errors.

Actual behavior:
Throws a TypeError on complete:

Uncaught TypeError: Cannot read property 'push' of null
    BufferTimeSubscriber.openContext @ Rx.js:6288
    BufferTimeSubscriber.onBufferFull @ Rx.js:6280
    BufferTimeSubscriber._next @ Rx.js:6256
    Subscriber.next @ Rx.js:1301

Additional information:

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions