Added call to nextTick in TaskQueue to make sure queue is handled async.

artifacthealth · Apr 4, 2018 · 5bfb0a9 · 5bfb0a9
1 parent bba143a
commit 5bfb0a9
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,7 +1,7 @@
 {
   "name": "hydrate-mongodb",
   "description": "An Object Document Mapper (ODM) for MongoDB.",
-  "version": "2.0.2",
+  "version": "2.0.3",
   "author": {
     "name": "Artifact Health, LLC",
     "url": "http://www.artifacthealth.com"

diff --git a/src/taskQueue.ts b/src/taskQueue.ts
@@ -71,6 +71,7 @@ export class TaskQueue extends EventEmitter {
         else {
             // this is the first task so initialize the queue and start processing
             this._head = this._tail = task;
+            // make sure calls to _process are async
             process.nextTick(() => this._process());
         }
     }
@@ -144,7 +145,8 @@ export class TaskQueue extends EventEmitter {
             }
 
             if(this._head) {
-                this._process();
+                // make sure calls to _process are async
+                process.nextTick(() => this._process());
             }
 
         }

diff --git a/tests/driver/mockCursor.ts b/tests/driver/mockCursor.ts
@@ -110,7 +110,7 @@ export class MockCursor extends Readable implements mongodb.Cursor {
     next(): Promise<any>;
     next(callback: mongodb.MongoCallback<any>): void;
     next(callback?: any): any {
-
+        callback();
     }
 
     project(value: Object): mongodb.Cursor<any> {