Как вручную завершить поток, созданный таблицей # createReadStream ()?

Question

Я хочу обработать данные из таблицы BigTable в потоке, но завершить поток рано. Я использую этот код для Node.js (слегка измененный https://github.com/googleapis/nodejs-bigtable/blob/master/samples/document-snippets/table.js#L215):

const stream = new BigTable({projectId, keyFilename})
  .instance(instanceId)
  .table(tableName)
  .createReadStream();
stream.on('data', () => {
  stream.end();
});
stream.on('end', () => {
  console.log('end');
  stream.destroy();
});
stream.on('close', () => {
  console.log('close');
});

Вывод:

end
close

Но процесс еще не закончен. Итак, я считаю, что некоторые ресурсы не закрыты. Как мне остановить поток и закрыть соответствующие ресурсы?

Answer 1

Похоже, что это может быть ошибка в клиентской библиотеке. Я повторно опубликовал ваш вопрос в формате github: https://github.com/googleapis/nodejs-bigtable/issues/506