From 63218515dc0d425581451ee5a6b90a74bc70138c Mon Sep 17 00:00:00 2001 From: Lenz Weber-Tronic Date: Fri, 4 Apr 2025 15:09:14 +0200 Subject: [PATCH] fix `async` subscriber --- src/link.js | 32 +++++++++++++++++--------------- 1 file changed, 17 insertions(+), 15 deletions(-) diff --git a/src/link.js b/src/link.js index 075e67bf..edf618cd 100644 --- a/src/link.js +++ b/src/link.js @@ -10,21 +10,23 @@ function delay(wait) { } const staticDataLink = new ApolloLink((operation) => { - return new Observable(async (observer) => { - const { query, operationName, variables } = operation; - await delay(300); - try { - const result = await graphql({ - schema, - source: print(query), - variableValues: variables, - operationName, - }); - observer.next(result); - observer.complete(); - } catch (err) { - observer.error(err); - } + return new Observable((observer) => { + Promise.then(async () => { + const { query, operationName, variables } = operation; + await delay(300); + try { + const result = await graphql({ + schema, + source: print(query), + variableValues: variables, + operationName, + }); + observer.next(result); + observer.complete(); + } catch (err) { + observer.error(err); + } + }); }); });