/
erioxis
/
web-nodejs
Обзор
Документация
Войти
/
erioxis
/
web-nodejs
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
backend/node_modules/thread-stream/test/post-message.test.js
24 строки
684 B
erioxis
lab11fix
15 дек 2025, 23:21
15 дек 2025, 23:21
70dc7ba
Код
Авторство
О чём код?
'use strict' const { test } = require('tap') const { join } = require('path') const { once } = require('events') const { MessageChannel } = require('worker_threads') const ThreadStream = require('..') test('message events emitted on the stream are posted to the worker', async function (t) { t.plan(1) const { port1, port2 } = new MessageChannel() const stream = new ThreadStream({ filename: join(__dirname, 'on-message.js'), sync: false }) t.teardown(() => { stream.end() }) stream.emit('message', { text: 'hello', takeThisPortPlease: port1 }, [port1]) const [confirmation] = await once(port2, 'message') t.equal(confirmation, 'received: hello') })