Описание тега node-streams
Вопросы, связанные с потоками Node.js и операциями ввода-вывода.
1
ответ
Как правильно справиться с обратным давлением во время `Transform#flush`
Как правильно справляться с обратным давлением в рамках реализации Transform _flush метод? Другими словами, если .push() при промывке возвращает false, существуют ли какие-либо механизмы для правильной обработки обратного давления из нисходящего пот…
02 янв '19 в 01:09
1
ответ
"Писать после завершения": как имитировать глоток с watchify?
Следующая задача Gulp делает почти то, что я хочу. const gulp = require('gulp'); const browserify = require('browserify'); const vinylStream = require('vinyl-source-stream'); const vinylBuffer = require('vinyl-buffer'); const watchify = require('wat…
25 авг '18 в 22:16
1
ответ
Процесс Node.js завершается без ошибок (используя потоки)
Я пишу лямбда-функцию, которая получает список текстовых файлов на S3, объединяет их вместе, а затем архивирует полученный файл. По какой-то причине, функция запускается в середине процесса, без ошибок. Полезная нагрузка, отправляемая в функцию Lamb…
20 ноя '18 в 01:39
1
ответ
Как отправить событие в родительский поток gulp-tap
Я настраиваю gulpfile для объединения нескольких файлов JavaScript в несколько пакетов во время разработки. Так как я хочу наблюдать за этим процессом, а не завершать его, если в одном из файлов есть ошибка (синтаксис или что-то еще), мне нужно прав…
02 фев '17 в 16:37
2
ответа
Как передать имя файла следующему действию в конвейере Gulp с помощью gulp-tap?
У меня есть задача Gulp, которая берет файл HTML и встроенные стили, взятые из файла CSS, используя gulp-inline-css. Оригинальная версия моей задачи использовала один и тот же файл CSS для каждого файла HTML. Теперь я хотел бы, чтобы задача выбрала …
13 июн '17 в 00:46
0
ответов
node.js Потоковый ответ на AWS
У меня есть простой веб-сервис node.js в AWS (EC2): async generate(ctx) { ctx.body = await this.pdfGenerator.generate(ctx.request.body) let documentName = Date.now() ctx.set({ 'Content-Disposition': `attachment; filename=${documentName}.pdf`, 'Conte…
07 мар '18 в 02:41
0
ответов
Немедленно отбросить непрочитанные данные из потокового потока?
У меня есть следующие настройки: Входной поток (MP3-поток IceCast) Node.JS сокет от сервера connection Перезвоните Выходные потоки (любая комбинация, включая ни одной) HTTP-ответ от Express WritableStream создан с использованием fs.createWriteStream…
06 мар '18 в 21:44
0
ответов
Как создать несколько потоков из одного потока в узле?
У меня есть данные 1 мкл, поступающие от внешнего API WebSocket, и я пытаюсь сгенерировать из них потоки 5 м 15 м 30 м 1 ч 1 д и 1 Вт. Мой текущий TransformStream может конвертировать 1 м на один из вышеупомянутых таймфреймов Как мне это сделать one…
24 ноя '18 в 04:34
0
ответов
Плохая производительность на комбинации потоков
Я хочу передать результаты запроса PostgreSQL клиенту через веб-сокет. Данные извлекаются из базы данных с использованием pg-обещания и pg-query-stream. Для потоковой передачи данных через веб-сокет я использую socket.io-stream. По отдельности все к…
10 апр '17 в 17:43
1
ответ
Сохраняет ли write() (без обратного вызова) порядок в потоках записи node.js?
У меня есть программа node.js, в которой я использую поток для записи информации на SFTP-сервер. Как то так (упрощенная версия): var conn = new SSHClient(); process.nextTick(function (){ conn.on('ready', function () { conn.sftp(function (error, sftp…
16 апр '18 в 20:10
0
ответов
Node-Serialport: невозможно обработать входящие данные с помощью RxJS Observable при применении тайм-аута
В настоящее время я работаю над проектом NodeJS, используя serialport модуль в сочетании с RxJS Observables. Предполагаемый "поток" / вариант использования выглядит следующим образом: название последовательного порта portName отправляется через посл…
05 янв '19 в 18:23
0
ответов
Обработка ошибок с реагированием SSR renderToNodeStream
Я пытаюсь выяснить, как правильно обрабатывать ошибки с реагирующими потоками. Допустим, есть ошибка внутри <App />, Каков наилучший способ отловить ошибку? Кажется, что блок catch не перехватывает ошибку, так как он ничего не записывает, когд…
08 янв '19 в 04:20
0
ответов
Тайм-аут функции Firebase при передаче потока клиенту
На сервере я хочу преобразовать HTML в PDF, передать его обратно клиенту и затем загрузить файл. Изолированный - не использующий Firebase Hosting или Functions - у меня есть простой Node/Express Server со следующей конечной точкой POST (с использова…
02 фев '19 в 01:49
2
ответа
Добавить JSON в файл, используя потоки узлов
Исходя из того, что я прочитал здесь, я использую fs.createWriteStream записать JSON в файл. Я обрабатываю данные порциями по 50. Итак, в начале скрипта я открываю свой strea и затем использую функцию для его передачи вместе с некоторым JSON, которы…
05 фев '19 в 18:52
0
ответов
Установите правильный размер буфера для аудиопотока PCM в node.js
Я хочу микшировать живые аудиоданные PCM, где новые аудиопотоки могут быть созданы в любое время, а существующие могут закрыться в любое время. Ни один поток не синхронизируется, они просто начинаются всегда и заканчиваются всегда. Предполагается, ч…
11 фев '19 в 20:25
1
ответ
Как передать несколько ReadableStreams в один WriteStream?
Я имею дело с лимитом брандмауэра, где я могу только POST 10 МБ одновременно. Для обработки больших загрузок я хотел бы использовать что-то вроде http://www.resumablejs.com/, записать несколько фрагментов на диск и в конце рекомбинировать их. Я сейч…
01 фев '19 в 19:38
0
ответов
Ошибка при чтении файла. Превышен максимальный размер стека вызовов при попытке создать элемент с мангустом в потоке
Я пытаюсь записать в БД, читая из большого файла CSV в потоке, но все, что я получаю, это ошибка "Превышен максимальный размер стека вызовов". И всегда после 12969 строки. Если я не сохраняю в БД, все в порядке. Мой пример кода: const s = fs.createR…
06 фев '17 в 05:49
2
ответа
Node.js преобразует поток файлов и записывает в тот же файл, в результате получается пустой файл
Я пытаюсь изменить некоторые файлы, используя потоки файлов узла и пользовательские функции преобразования. Это функция преобразования: const TransformStream = function() { Transform.call(this, {objectMode: true}); }; util.inherits(TransformStream, …
23 дек '16 в 12:10
1
ответ
Как читать из одного потока и писать сразу в несколько?
Предположим, у меня есть readable поток, например request(URL), И я хочу написать свой ответ на диске через fs.createWriteStream() и обвязка с просьбой. Но в то же время я хочу вычислить контрольную сумму загружаемых данных через crypto.createHash()…
02 апр '17 в 16:59
0
ответов
Как правильно построить фрейм-декодер TCP в nodejs
Я пытаюсь найти простой, модульный и идиоматический способ анализа текстового протокола для потоков TCP. Скажем, протокол выглядит так:"[begin][length][blah][blah]...[blah][end][begin]...[end][begin]...[end]" Я хотел бы правильно использовать потоки…
17 апр '17 в 21:14