Handle exceptions

Liza K · Liza K · commit c8294b63d976 · 2020-10-14T16:38:13.000+03:00
diff --git a/src/plugins/data/common/utils/tap_once.test.ts b/src/plugins/data/common/utils/tap_once.test.ts
@@ -53,4 +53,22 @@ describe('tapOnce', () => {
       },
     });
   });
+
+  test('fires once even when there is an error', async (done) => {
+    const tester = jest.fn().mockImplementation(() => {
+      throw new Error();
+    });
+
+    const source = from([1, 2, 3, 4]).pipe(tapOnce(tester));
+
+    source.subscribe(() => {});
+    source.subscribe({
+      next: () => {},
+      complete: () => {
+        expect(tester).toBeCalledWith(1);
+        expect(tester).toBeCalledTimes(1);
+        done();
+      },
+    });
+  });
 });
diff --git a/src/plugins/data/common/utils/tap_once.ts b/src/plugins/data/common/utils/tap_once.ts
@@ -29,10 +29,14 @@ export function tapOnce<T>(fn: (v: T) => any) {
     let first = true;
     return source$.pipe(
       tap((payload) => {
-        if (first) {
-          fn(payload);
+        try {
+          if (first) {
+            fn(payload);
+          }
+          first = false;
+        } catch (e) {
+          first = false;
         }
-        first = false;
       })
     );
   };
