Handle event polling errors

oasislabs · Jul 29, 2020 · 5f7b254 · 5f7b254
1 parent 875abba
commit 5f7b254
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/packages/gateway/src/index.ts b/packages/gateway/src/index.ts
@@ -201,8 +201,12 @@ class HttpGateway implements OasisGateway {
       url: this.url,
       session: this.session,
       queueId: response.id,
-    }).subscribe(response.id, (event: any) => {
-      events.emit(request.event, event);
+    }).subscribe(response.id, (err: any, event: any) => {
+      if (err) {
+        events.emit('error', err);
+      } else {
+        events.emit(request.event, event);
+      }
     });
     return events;
   }

diff --git a/packages/gateway/src/polling.ts b/packages/gateway/src/polling.ts
@@ -162,7 +162,8 @@ export default class PollingService {
     if (this.polling) {
       throw new Error('cannot make a new subscription when already polling');
     }
-    this.responses.addListener(SubscribeTopic, callback);
+    this.responses.on(SubscribeTopic, (event: any) => callback(null, event));
+    this.responses.on('error', (err: any) => callback(err));
     this.start();
   }