Пользовательский поток чтения - this.pu sh всегда возвращает false

Question

У меня есть следующая реализация настраиваемого потока чтения:

class MyRead extends stream.Readable {
  constructor() {
    super({ objectMode: true });
  }

  i = 0;
  async _read(size: number) {
    console.log(`Pushing`, this.push({key:this.i++}));
  }
}

После однократного достижения highWaterMark this.push всегда возвращает false. Это правильное поведение?

Я хочу извлекать данные из источника бесконечно, а sh они передаются по конвейеру потоков. Как мне узнать, когда остановить источник?