MessageBus

PubSub library for WebWorkers

Install

$ npm install
$ gulp dist

Usage Example

main.js

var worker = new Worker('worker.js'),
    bus    = MessageBus.create(worker);

bus.on('pong', function (payload) {
  console.log(payload.foo);
});

bus.emit('ping');

worker.js

importScripts('MessageBus.js');

var bus = MessageBus.create(self);

bus.on('ping', function () {
  bus.emit('pong', { foo: 'Hello World' });
});

SharedWorker Example

events.ts

enum Events { PONG, PING }

main.ts

var worker = new SharedWorker('worker.js'),
    bus    = MessageBus.create(worker.port);

worker.port.start();

bus.on(Events.PONG, function (payload) {
  console.log(payload.foo);
});

bus.emit(Events.PING);

worker.ts

importScripts('MessageBus.js', 'events.js');

onconnect = function (event) {
  var port = events.port[0],
      bus = MessageBus.create(port);

  port.start();

  bus.on(Events.PING, function () {
    bus.emit(Events.PONG, { foo: 'Hello World' });
  });
};