Make Worker.whenForeignPropertiesReceived return promise

.eslintrc

@@ -18,6 +18,6 @@
     "mocha": true
   },
   "parserOptions": {
-    "ecmaVersion": 6
+    "ecmaVersion": 2017
   }
 }

lib/worker.js

@@ -88,19 +88,14 @@ class Worker extends ClusterProcess {
         this.emit('foreign properties received');
     }
 
-    /**
-     * @param {Function} fn
-     */
-    static whenForeignPropertiesReceived(fn) {
-        return /** @this {Worker} */function() {
+    whenForeignPropertiesReceived() {
+        return new Promise(resolve => {
             if (this._foreignPropertiesReceived) {
-                setImmediate(fn.bind(this));
+                resolve();
             } else {
-                this.once('foreign properties received', fn.bind(this));
+                this.once('foreign properties received', resolve);
             }
-
-            return this;
-        };
+        });
     }
 
     /**
@@ -153,18 +148,20 @@ class Worker extends ClusterProcess {
  * @public
  */
 Worker.prototype.run = Worker.whenInitialized(
-    Worker.whenForeignPropertiesReceived(function() {
+    async function() {
+        await this.whenForeignPropertiesReceived();
+
         const workerBase = this.config.resolve('app');
 
         require(workerBase);
         this.emit('loaded', workerBase);
 
-        if ( ! this.config.get('control.triggerReadyStateManually', false)) {
+        if (!this.config.get('control.triggerReadyStateManually', false)) {
             setImmediate(this.ready.bind(this));
         }
 
         return this;
-    }));
+    });
 
 /**
  * Call Master method via RPC

test/func/test/restart_queue.js

@@ -31,6 +31,7 @@ describe('restart queue', () => {
         const expected = [
             'restarting',
             'exit 1',
+            'run 1',
             'dead 1',
             'exit 1',
             'exit 2',