$ npm install mqemitter-p2p --save

var fs = require('fs')
var path = require('path')
var schema = fs.readFileSync(path.join(__dirname, 'test.proto'))
var p2p = require('./')
var memdb = require('memdb')
var assert = require('assert')
 
var a = p2p({
  db: memdb(),
  schema: schema
})
 
var b = p2p({
  db: memdb(),
  schema: schema
})
 
var msg = {
  topic: 'hello',
  payload: null
}
 
a.listen(9001, 'localhost', function (err) {
  assert(!err)
  b.connect(9001, 'localhost', function (err) {
    assert(!err)
  })
})
 
a.emit(msg)
b.on('hello', function (received, cb) {
  console.log(received)
  cb()
  assert.deepEqual(received, msg, 'msg matches')
  a.close(function (err) {
    assert(!err)
    b.close(function (err) {
      assert(!err)
      console.log('closed successfully')
    })
  })
})

• matteo.collina published 2015-05-03T07:02:20.528Z
• 0.1.0 is the latest release
• github.com/mcollina/mqemitter-p2p
• ISC ®

Collaborators list

• 

Stats

• 0 downloads in the last day
• 1 download in the last week
• 6 downloads in the last month
• Have an issue? File it. on GitHub
• on GitHub

Try it out

• Test mqemitter-p2p in your browser.

Keywords

mqemitter, p2p, mqtt, event, emitter

Dependencies (10)

faucet, hyperemitter, memdb, mqemitter, pre-commit, protocol-buffers, standard, tape, through2, fastseries