diff --git a/integration/regtest-node.js b/integration/regtest-node.js index dff7a4df..932b1483 100644 --- a/integration/regtest-node.js +++ b/integration/regtest-node.js @@ -219,4 +219,23 @@ describe('Node Functionality', function() { node.services.bitcoind.isMainChain(invalidatedBlockHash).should.equal(false); setImmediate(done); }); + + describe('Bus Functionality', function() { + it('subscribes and unsubscribes to an event on the bus', function(done) { + var bus = node.openBus(); + var block; + bus.subscribe('db/block'); + bus.on('block', function(data) { + bus.unsubscribe('db/block'); + data.should.be.equal(block); + done(); + }); + client.generate(1, function(err, response) { + if (err) { + throw err; + } + block = response.result[0]; + }); + }); + }); }); diff --git a/lib/node.js b/lib/node.js index 908f0978..3061610c 100644 --- a/lib/node.js +++ b/lib/node.js @@ -41,8 +41,6 @@ function Node(config) { util.inherits(Node, EventEmitter); -util.inherits(Node, EventEmitter); - Node.prototype._setNetwork = function(config) { if (config.network === 'testnet') { this.network = Networks.get('testnet');