fix(@aws-amplify/pubsub): sending connection error to observable on A…

…WSAppSyncProvider
zegates · Aug 16, 2019 · 8b7cac7 · 8b7cac7
1 parent 7f09c03
commit 8b7cac7
Showing 1 changed file with 11 additions and 4 deletions.
diff --git a/packages/pubsub/src/Providers/AWSAppSyncProvider.ts b/packages/pubsub/src/Providers/AWSAppSyncProvider.ts
@@ -129,10 +129,17 @@ export class AWSAppSyncProvider extends MqttOverWSProvider {
                 // reconnect everything we have in the map
                 await Promise.all(map.map(async ([clientId, { url, topics }]) => {
                     // connect to new client
-                    const client = await this.connect(clientId, {
-                        clientId,
-                        url,
-                    });
+                    let client = null;
+                    try {
+                        client = await this.connect(clientId, {
+                            clientId,
+                            url,
+                        });
+                    } catch (err) {
+                        observer.error('Fail to connect');
+                        observer.complete();
+                        return Promise.resolve(undefined)
+                    }
 
                     // subscribe to all topics for this client
                     // store topic-client mapping