[Search] Client side session service

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();
+ },
+ });
+ });
 });

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;
  })
  );
  };