wait until all events has been sent to the main process - refs webdri…

…verio/webdriverio#1713

lib/adapter.js

@@ -119,6 +119,7 @@ class JasmineAdapter {
             this.jrunner.execute()
         })
         await executeHooksWithArgs(this.config.after, [result, this.capabilities, this.specs])
+        await this.reporter.waitUntilSettled()
         return result
     }
 

lib/reporter.js

@@ -5,6 +5,9 @@ class JasmineReporter {
         this._specs = specs
         this._parent = []
         this._failedCount = 0
+
+        this.sentMessages = 0 // number of messages sent to the parent
+        this.receivedMessages = 0 // number of messages received by the parent
     }
 
     suiteStarted (suite = {}) {
@@ -70,13 +73,27 @@ class JasmineReporter {
         }
 
         message.runner[this._cid] = this._capabilities
-        this.send(message)
+        this.sentMessages++
+        this.send(message, null, {}, () => ++this.receivedMessages)
     }
 
     send (...args) {
         process.send.apply(process, args)
     }
 
+    /**
+     * wait until all messages were sent to parent
+     */
+    waitUntilSettled () {
+        return new Promise((resolve) => {
+            const interval = setInterval(() => {
+                if (this.sentMessages !== this.receivedMessages) return
+                clearInterval(interval)
+                resolve()
+            }, 100)
+        })
+    }
+
     getFailedCount () {
         return this._failedCount
     }

test/reporter.spec.js

@@ -97,6 +97,28 @@ describe('jasmine reporter', () => {
         })
     })
 
+    it('should wait until all events were sent', () => {
+        const start = (new Date()).getTime()
+
+        reporter.specStarted()
+        reporter.specDone({
+            status: 'passed',
+            description: 'my test',
+            id: 4
+        })
+
+        setTimeout(() => {
+            send.args[0][3]()
+            send.args[1][3]()
+            send.args[2][3]()
+        }, 500)
+
+        return reporter.waitUntilSettled().then(() => {
+            const end = (new Date()).getTime();
+            (end - start).should.be.greaterThan(500)
+        })
+    })
+
     describe('provides a fail counter', () => {
         it('should have right fail count at the end', () => {
             reporter.getFailedCount().should.be.exactly(2)