Comparing version 0.7.10 to 0.7.11
16
index.js
var mongodb = require('mongodb'); | ||
var thunky = require('thunky'); | ||
var util = require('util'); | ||
var EventEmitter = require('events').EventEmitter; | ||
var Readable = require('stream').Readable || require('readable-stream'); | ||
@@ -39,3 +41,3 @@ | ||
Cursor.prototype.__proto__ = Readable.prototype; | ||
util.inherits(Cursor, Readable); | ||
@@ -58,2 +60,6 @@ Cursor.prototype.toArray = function() { | ||
Cursor.prototype.explain = function() { | ||
this._apply(DRIVER_CURSOR_PROTO.explain, arguments); | ||
}; | ||
Cursor.prototype.limit = function() { | ||
@@ -234,5 +240,8 @@ return this._config(DRIVER_CURSOR_PROTO.limit, arguments); | ||
var Database = function(ondb) { | ||
EventEmitter.call(this); | ||
this._get = ondb; | ||
}; | ||
util.inherits(Database, EventEmitter); | ||
Database.prototype.runCommand = function(opts, callback) { | ||
@@ -277,2 +286,7 @@ callback = callback || noop; | ||
that.client = db; | ||
db.on('error', function(err) { | ||
process.nextTick(function() { | ||
that.emit('error', err); | ||
}); | ||
}); | ||
callback(null, db); | ||
@@ -279,0 +293,0 @@ }); |
@@ -9,3 +9,3 @@ { | ||
], | ||
"version": "0.7.10", | ||
"version": "0.7.11", | ||
"repository": "git://github.com/gett/mongojs.git", | ||
@@ -12,0 +12,0 @@ "contributors": [ |
21976
23
576