Raise error on parsing errors (#1987)

2020-03-02 09:09:27 +01:00
parent 0d58c77de0
commit af1a3385cc
2 changed files with 6 additions and 1 deletions
@@ -253,7 +253,11 @@ export default class Rpc implements RpcInterface {
              return;
            }

-            observer.next(this.formatOutput(method, params, result));
+            try {
+              observer.next(this.formatOutput(method, params, result));
+            } catch (error) {
+              observer.error(error);
+            }
          };

          subscriptionPromise = this.createSubscriber({ subType, subName, paramsJson, update }, errorHandler);