diff --git a/lib/collection.js b/lib/collection.js index 9d2be62..f6239da 100644 --- a/lib/collection.js +++ b/lib/collection.js @@ -81,8 +81,9 @@ Collection.prototype.insert = function (docOrDocs, cb) { for (var i = 0; i < docs.length; i++) { if (!docs[i]._id) docs[i]._id = oid() } - server.insert(self._fullColName(), docs, writeOpts, function (err) { + server.insert(self._fullColName(), docs, writeOpts, function (err, res) { if (err) return cb(err) + if (res && res.result && res.result.writeErrors && res.result.writeErrors.length > 0) return cb(res.result.writeErrors[0]) cb(null, docOrDocs) }) })