/
githubmirror
/
pm2
Обзор
Документация
Войти
/
githubmirror
/
pm2
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
modules/pm2-axon/test/test.socket.rebind.js
43 строки
751 B
Unitech
v7 refactor
08 фев 2026, 17:04
08 фев 2026, 17:04
04fad96
Код
Авторство
О чём код?
var ss = require('../') , should = require('should') , assert = require('assert'); var push = ss.socket('push') , pull = ss.socket('pull'); // basic 1-1 push/pull var msgs = [] , n = 0; push.bind(4000); pull.connect(4000); var id = setInterval(function(){ push.send(String(n++)); }, 2); pull.on('message', function(msg){ msgs.push(msg.toString()); switch (msgs.length) { case 10: push.close(); push.once('close', function(){ setTimeout(function(){ push.bind(4000); }, 50); }); break; case 300: for (var i = 0; i < 299; ++i) { msgs[i].should.equal(i.toString()); } clearInterval(id); push.close(); pull.close(); break; } });