fix: added check for observer (#736)

Co-authored-by: Šimon Kvasnička <kvasnicka.simon@gmail.com>
awslabs · Nov 16, 2022 · 758a55e · 758a55e
1 parent 59be088
commit 758a55e
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/packages/aws-appsync-subscription-link/src/realtime-subscription-handshake-link.ts b/packages/aws-appsync-subscription-link/src/realtime-subscription-handshake-link.ts
@@ -764,7 +764,19 @@ export class AppSyncRealTimeSubscriptionHandshakeLink extends ApolloLink {
       });
       clearTimeout(startAckTimeoutId);
 
-      observer.complete();
+      if (observer) {
+        observer.error({
+          errors: [
+            {
+              ...new GraphQLError(`Connection failed: ${JSON.stringify(payload)}`)
+            }
+          ]
+        });
+        observer.complete();
+      } else {
+        logger(`observer not found for id: ${id}`);
+      }
+
       if (typeof subscriptionFailedCallback === "function") {
         subscriptionFailedCallback();
       }