fix(@aws-amplify/datastore): call disconnectionHandler on subscriptio…

…n error (aws-amplify#6366)
abdielou · Jul 21, 2020 · a7feace · a7feace
1 parent d14c076
commit a7feace
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/packages/datastore/src/sync/index.ts b/packages/datastore/src/sync/index.ts
@@ -652,7 +652,8 @@ export class SyncEngine {
 				},
 				error: err => {
 					reject(err);
-					this.disconnectionHandler(datastoreConnectivity);
+					const handleDisconnect = this.disconnectionHandler(datastoreConnectivity);
+					handleDisconnect(err);
 				},
 			});
 		});

diff --git a/packages/datastore/src/sync/processors/subscription.ts b/packages/datastore/src/sync/processors/subscription.ts
@@ -357,11 +357,13 @@ class SubscriptionProcessor {
 															errors: [],
 														},
 													} = subscriptionError;
-													logger.warn(message);
+													logger.warn('subscriptionError', message);
 
 													if (typeof subscriptionReadyCallback === 'function') {
 														subscriptionReadyCallback();
 													}
+
+													observer.error(message);
 												},
 											})
 									);