/
erioxis
/
web-nodejs
Обзор
Документация
Войти
/
erioxis
/
web-nodejs
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
backend/node_modules/thread-stream/test/end.test.js
61 строка
1 KB
erioxis
lab11fix
15 дек 2025, 23:21
15 дек 2025, 23:21
70dc7ba
Код
Авторство
О чём код?
'use strict' const { test } = require('tap') const { join } = require('path') const { readFile } = require('fs') const { file } = require('./helper') const ThreadStream = require('..') test('destroy support', function (t) { t.plan(7) const dest = file() const stream = new ThreadStream({ filename: join(__dirname, 'to-file-on-destroy.js'), workerData: { dest }, sync: true }) stream.on('close', () => { t.notOk(stream.writable) t.pass('close emitted') }) t.ok(stream.write('hello world\n')) t.ok(stream.write('something else\n')) t.ok(stream.writable) stream.end() readFile(dest, 'utf8', (err, data) => { t.error(err) t.equal(data, 'hello world\nsomething else\n') }) }) test('synchronous _final support', function (t) { t.plan(7) const dest = file() const stream = new ThreadStream({ filename: join(__dirname, 'to-file-on-final.js'), workerData: { dest }, sync: true }) stream.on('close', () => { t.notOk(stream.writable) t.pass('close emitted') }) t.ok(stream.write('hello world\n')) t.ok(stream.write('something else\n')) t.ok(stream.writable) stream.end() readFile(dest, 'utf8', (err, data) => { t.error(err) t.equal(data, 'hello world\nsomething else\n') }) })