fix(data): port over Angular fix from master (#733)

awslabs · Oct 7, 2022 · 0a38f28 · 0a38f28
1 parent 0f547be
commit 0a38f28
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/packages/aws-appsync-subscription-link/package.json b/packages/aws-appsync-subscription-link/package.json
@@ -25,7 +25,8 @@
     "apollo-link-retry": "2.2.7",
     "aws-appsync-auth-link": "^2.0.8",
     "debug": "2.6.9",
-    "url": "^0.11.0"
+    "url": "^0.11.0",
+    "zen-observable-ts": "^1.2.5"
   },
   "devDependencies": {
     "@redux-offline/redux-offline": "2.5.2-native.0",

diff --git a/packages/aws-appsync-subscription-link/src/subscription-handshake-link.ts b/packages/aws-appsync-subscription-link/src/subscription-handshake-link.ts
@@ -3,6 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 import { ApolloLink, Observable, Operation, FetchResult } from "apollo-link";
+import * as ZenObservable from 'zen-observable-ts';
 
 import { rootLogger } from "./utils";
 import * as Paho from './vendor/paho-mqtt';
@@ -51,7 +52,7 @@ export class SubscriptionHandshakeLink extends ApolloLink {
         this.subsInfoContextKey = subsInfoContextKey;
     }
 
-    request(operation: Operation) {
+    request(operation: Operation): Observable<FetchResult> | null  {
         const {
             [this.subsInfoContextKey]: subsInfo,
             controlMessages: { [CONTROL_EVENTS_KEY]: controlEvents } = { [CONTROL_EVENTS_KEY]: undefined }

diff --git a/packages/aws-appsync-subscription-link/src/types/index.ts b/packages/aws-appsync-subscription-link/src/types/index.ts
@@ -1,4 +1,5 @@
 import { AuthOptions } from "aws-appsync-auth-link";
+import * as ZenObservable from 'zen-observable-ts';
 
 //#region Subscription link enums