fix(core): update
This commit is contained in:
@@ -14,7 +14,7 @@ export class StreamIntake<T> extends plugins.stream.Readable {
|
||||
_read(size: number): void {
|
||||
// console.log('get next');
|
||||
const pushChunk = (): void => {
|
||||
if (this.chunkStore.length > 0) {
|
||||
while (this.chunkStore.length > 0) {
|
||||
// If push returns false, then we should stop reading
|
||||
if (!this.push(this.chunkStore.shift())) {
|
||||
return;
|
||||
|
||||
Reference in New Issue
Block a user