Pipeling works, needs testing

lib/datastore.js

@@ -337,7 +337,12 @@ Datastore.prototype._persistNewState = function (newDocs, cb) {
   });
 };
 Datastore.prototype.persistNewState = function (newDocs, cb) {
-  this._persistNewState(newDocs, cb);
+  if (this.pipeline) {
+    this.persistenceExecutor.push({ this: this, fn: this._persistNewState, arguments: [newDocs] });
+    cb ();   // Return right away with no error
+  } else {
+    this._persistNewState(newDocs, cb);
+  }
 };