Завершить доступный для записи поток

Я использую gulp для обработки, минимизации и объединения моих файлов css (и js тоже). Но я не хочу сразу писать файл. Я хочу проверить, не равна ли сумма md5 обработанного содержимого сумме md5 существующей версии связанного файла, и писать только в этом случае.

Вместо того, чтобы сразу писать файл, я пытаюсь получить его как строку из процесса.

Но конструкция не работает.

const Stream = require('stream');
const writableStream = new Stream.Writable({ objectMode: true });

var file = "";

writableStream._write = (chunk, encoding, next) => {
    file += chunk.contents.toString();
    next();
}

let bundlePipe = gulp.src([...vendorLinks.map(e => path.resolve(htmlPath + e)), ...resourceLinks.map(e => path.resolve(htmlPath + e))], { sourcemaps: true })
    .pipe(postcss([cssnext, cssnano]))
    .pipe(concat("style.bundle.min.css"))
    .pipe(writableStream);
    //.pipe(gulp.dest(path.resolve(paths["html/static/css"]))); 


bundlePipe.on("end", () => {
    // It never goes there!
    console.info("get file contents", file); 
}

Кажется, writableStream, который я создаю, не знает, что все данные уже переданы ему, и никогда не выдает сигнал завершения.

Что я могу сделать, чтобы writableStream закрылся после того, как получил все данные из канала?

Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.
Концепция локализации и ее применение в приложениях React ⚡️
Концепция локализации и ее применение в приложениях React ⚡️
Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...
Улучшение производительности загрузки с помощью Google Tag Manager и атрибута Defer
Улучшение производительности загрузки с помощью Google Tag Manager и атрибута Defer
В настоящее время производительность загрузки веб-сайта имеет решающее значение не только для удобства пользователей, но и для ранжирования в...
Безумие обратных вызовов в javascript [JS]
Безумие обратных вызовов в javascript [JS]
Здравствуйте! Юный падаван 🚀. Присоединяйся ко мне, чтобы разобраться в одной из самых запутанных концепций, когда вы начинаете изучать мир...
Система управления парковками с использованием HTML, CSS и JavaScript
Система управления парковками с использованием HTML, CSS и JavaScript
Веб-сайт по управлению парковками был создан с использованием HTML, CSS и JavaScript. Это простой сайт, ничего вычурного. Основная цель -...
JavaScript Вопросы с множественным выбором и ответы
JavaScript Вопросы с множественным выбором и ответы
Если вы ищете платформу, которая предоставляет вам бесплатный тест JavaScript MCQ (Multiple Choice Questions With Answers) для оценки ваших знаний,...
1
0
617
1

Ответы 1

Потоки с возможностью записи не генерируют end, только потоки с возможностью чтения генерируют такого рода события.

Эквивалентом доступного для записи потока является finish. Вы можете найти подробности об этом событии в документация Node.js.

Причина, по которой доступные для чтения и записи потоки имеют разные события, сигнализирующие об их завершении/завершении, заключается в том, что существуют также гибридные потоки (такие как DuplexStream), которые состоят из одновременно читаемого и записываемого потоков, и, следовательно, вам нужно уметь различать один и другой тип события.

Почему тогда gulp.dest(path.resolve(paths["html/static/css"])) завершается нормально, а writableStream - нет? Нужно ли мне как-то обрабатывать конечное событие входящего читаемого потока в моем writableStream, чтобы завершить его?

Thelambofgoat 11.02.2019 13:34

Я немного изменил вопрос из-за предоставленной вами информации

Thelambofgoat 11.02.2019 13:35

Другие вопросы по теме