const Eventual = require('./lib/eventual.js'); const Benchmark = require('../../lib/utils/benchmark'); function makeid() { var text = ""; var possible = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789"; for( var i=0; i < 5; i++ ) text += possible.charAt(Math.floor(Math.random() * possible.length)); return text; } var events = new Eventual(); var cevt= events.createContext(); var ctx2 = events.createContext(); function stressEvents() { // 1 million var ncount = 1000000; console.log("Adding",ncount,"events"); for(var i = 0;i { console.log("evt: " , evt); console.log("Args: " + a,b,c); }); } // Second context console.log("Adding events to second context"); for(var i = 0;i { }); }; } stressEvents(); ctx2.on('c1:ping',() => { console.log("Pong from ctx2"); }); var pingbm = new Benchmark(); var pctx = events.createContext(); pctx .on('c1:ping',() => { console.log("Pong: " + pingbm.mark(), "Contexts:",events._events.ctx.length); }) var test = 0; setInterval(() => { pingbm.start(); console.log("Sending ping"); pctx.broadcast('c1:ping'); if( test > 5) { cevt.destroy(); ctx2.destroy(); } test++; },1000);