node.js-stream

Я хочу передать данные из потока amazon kinesis в журнал s3 или журнал bunyan. Пример работает с потоком записи файла или stdout. Как я буду имплицировать свой собственный записываемый поток? //this works var file = fs.createWriteStream('my.log') kinesisSource.pipe(file) Это не работает, говоря, что у не...

мне нужно запустить две команды подряд, которые должны считывать данные из одного потока. После передачи потока в другой буфер очищается, поэтому я не могу снова читать данные из этого потока, поэтому это не работает: var spawn = require('child_process').spawn; var fs = require('fs'); var request = require('...

Как я могу преобразовать узел.JS буфер в читаемый поток после использования интерфейса stream2 ? Я уже нашел этот ответ и модуль stream-buffers, но этот модуль основан на интерфейсе stream1....