From 1a6f3184000c9d184df1bb923d32b8d979f6223e Mon Sep 17 00:00:00 2001 From: Florian Bouillon Date: Fri, 31 Jul 2020 10:53:26 +0200 Subject: [PATCH] Added error throwing Signed-off-by: Florian Bouillon --- packages/queue/Queue.ts | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/packages/queue/Queue.ts b/packages/queue/Queue.ts index 6f2d751..40ba21e 100644 --- a/packages/queue/Queue.ts +++ b/packages/queue/Queue.ts @@ -1,6 +1,7 @@ export default class Queue { private queue = 0 private isPaused = false + private throwError?: Error public constructor( private maxQueueLength = 5, @@ -27,13 +28,17 @@ export default class Queue { promise .then(() => { this.updateCurrentQueueLength(this.queue-1) - }).catch(() => { + }).catch((e) => { this.updateCurrentQueueLength(this.queue-1) + this.throwError = e }) } public async waitEnd() { while (this.queue !== 0) { + if (this.throwError) { + throw this.throwError + } await new Promise((res) => setTimeout(res, this.timeToWait)) } }