From b7c55980a1ed767a5d0169c651d2c758a8829751 Mon Sep 17 00:00:00 2001 From: sbansla <104902068+sbansla@users.noreply.github.com> Date: Thu, 10 Aug 2023 13:48:20 +0530 Subject: [PATCH] fix: fix unhandledRejection (#952) * fix: unhandledRejection --- src/base/Version.ts | 53 +++++++++++++++++++++++---------------------- 1 file changed, 27 insertions(+), 26 deletions(-) diff --git a/src/base/Version.ts b/src/base/Version.ts index c8b1593a00..9874c2bb22 100644 --- a/src/base/Version.ts +++ b/src/base/Version.ts @@ -311,32 +311,33 @@ export default class Version { return; } - promise.then((page: any) => { - try { - page.instances.forEach(function (instance: any) { - if ( - done || - (typeof params.limit !== "undefined" && - currentResource >= params.limit) - ) { - done = true; - return false; - } - currentResource++; - callback?.(instance, onComplete); - }); - } catch (e) { - return onComplete(e); - } - - if (!done) { - currentPage++; - fetchNextPage(page.nextPage.bind(page)); - } else { - onComplete(); - } - }); - promise.catch(onComplete); + promise + .then((page: any) => { + try { + page.instances.forEach(function (instance: any) { + if ( + done || + (typeof params.limit !== "undefined" && + currentResource >= params.limit) + ) { + done = true; + return false; + } + currentResource++; + callback?.(instance, onComplete); + }); + } catch (e) { + return onComplete(e); + } + + if (!done) { + currentPage++; + fetchNextPage(page.nextPage.bind(page)); + } else { + onComplete(); + } + }) + .catch(onComplete); } return new Promise((resolve, reject) => {