Merge pull request #1001 from scramjetorg/fix/faster-health

Immediately send loadCheck to cmp when available

Author: patuwwy

packages/host/src/lib/cpm-connector.ts

@@ -255,8 +255,6 @@ export class CPMConnector extends TypedEmitter<Events> {
 
         this.logger.info(`${EOL}${EOL}\t\x1b[33m${this.config.id} connected to ${this.cpmId}\x1b[0m${EOL} `);
 
-        await this.setLoadCheckMessageSender();
-
         StringStream.from(duplex.input as Readable)
             .JSONParse()
             .map(async (message: EncodedControlMessage) => {
@@ -299,6 +297,8 @@ export class CPMConnector extends TypedEmitter<Events> {
         this.communicationStream = new StringStream().JSONStringify().resume();
         this.communicationStream.pipe(duplex.output);
 
+        await this.setLoadCheckMessageSender();
+
         this.communicationStream.on("pause", () => {
             this.logger.warn("Communication stream paused");
         });