fix: Fix subscribe error handling (#21)

4Catalyzer · Aug 11, 2018 · fe9308b · fe9308b
1 parent 247ca09
commit fe9308b
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/AuthorizedSocketConnection.js b/src/AuthorizedSocketConnection.js
@@ -190,8 +190,12 @@ export default class AuthorizedSocketConnection<TContext, TCredentials> {
       try {
         resultOrStream = await sourcePromise;
       } catch (err) {
-        this.subscriptions.delete(id);
-        throw err;
+        if (err instanceof GraphQLError) {
+          resultOrStream = { errors: [err] };
+        } else {
+          this.subscriptions.delete(id);
+          throw err;
+        }
       }
 
       if (resultOrStream.errors != null) {