From d3b14c761f4f170364029b7ab496da3bf77b4ea4 Mon Sep 17 00:00:00 2001 From: Umair Nadeem Date: Mon, 6 Jul 2020 00:54:36 -0700 Subject: [PATCH 1/2] Avoid waiting for termination signal upon start-up --- packages/serverless-offline-kinesis/src/index.js | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/packages/serverless-offline-kinesis/src/index.js b/packages/serverless-offline-kinesis/src/index.js index ae1b57fe..bc46d2da 100644 --- a/packages/serverless-offline-kinesis/src/index.js +++ b/packages/serverless-offline-kinesis/src/index.js @@ -75,8 +75,7 @@ class ServerlessOfflineKinesis { async _startWithExplicitEnd() { await this.start(); - await this.ready(); - this.end(); + this.ready().then(this.end) } async end(skipExit) { From 193ed343fbda803dd995f295331e48ba4fa079cb Mon Sep 17 00:00:00 2001 From: Umair Nadeem Date: Mon, 6 Jul 2020 22:27:04 -0700 Subject: [PATCH 2/2] Style and lint fix --- packages/serverless-offline-kinesis/src/index.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/serverless-offline-kinesis/src/index.js b/packages/serverless-offline-kinesis/src/index.js index bc46d2da..8a5c1777 100644 --- a/packages/serverless-offline-kinesis/src/index.js +++ b/packages/serverless-offline-kinesis/src/index.js @@ -75,7 +75,7 @@ class ServerlessOfflineKinesis { async _startWithExplicitEnd() { await this.start(); - this.ready().then(this.end) + this.ready().then(this.end).catch(() => null); } async end(skipExit) {