jrtechs-vis/test/eventbus.js

// test vis.EventBus

var assert = require('assert'),
    vis = require('../vis');

var bus = new vis.EventBus();

var received = [];

var id1 = '1';
bus.on('message', function (event, data, source) {
    received.push({
        event: event,
        data: data,
        source: source
    });
}, id1);

var id2 = '2';
bus.emit('message', {text: 'hello world'}, id2);
bus.on('chat:*', function (event, data, source) {
    received.push({
        event: event,
        data: data,
        source: source
    });
});

bus.emit('chat:1', null, id2);
bus.emit('chat:2', {text: 'hello world'}, id1);

// verify if the messages are received
assert.deepEqual(received, [
    {event: 'message', data: {text: 'hello world'}, source: id2},
    {event: 'chat:1', data: null, source: id2},
    {event: 'chat:2', data: {text: 'hello world'}, source: id1}
]);