socketstream/socketstream

View on GitHub
lib/publish/transports/internal.js

Summary

Maintainability
A
0 mins
Test Coverage
// Publish Event - Internal EventEmitter Transport
'use strict';

var EventEmitter2, emitter;

EventEmitter2 = require('eventemitter2').EventEmitter2;

emitter = new EventEmitter2();

module.exports = function() {
  return {
    listen: function(cb) {
      return emitter.on('event', cb);
    },
    send: function(obj) {
      return emitter.emit('event', obj);
    }
  };
};