refactor: fix unit-test

Author: John Doe

packages/utils/src/lib/performance-observer.ts

@@ -21,7 +21,6 @@ export class PerformanceObserverHandle<T>
   #captureBuffered: boolean;
   #observedEntryCount: number;
   #flushThreshold: number;
-  #processedEntries = new Set<string>();
   #sink: Sink<T, unknown>;
   #observer: PerformanceObserver | undefined;
   #closed = false;
@@ -68,23 +67,19 @@ export class PerformanceObserverHandle<T>
     // Process all entries
     entries
       .filter(e => e.entryType === 'mark' || e.entryType === 'measure')
-      .filter(e => clear || !this.#processedEntries.has(e.name))
       .forEach(e => {
         const encoded = this.encode(e);
         encoded.forEach(item => {
           this.#sink.write(item);
         });
 
         if (clear) {
-          this.#processedEntries.delete(e.name);
           if (e.entryType === 'mark') {
             performance.clearMarks(e.name);
           }
           if (e.entryType === 'measure') {
             performance.clearMeasures(e.name);
           }
-        } else {
-          this.#processedEntries.add(e.name);
         }
       });
   }

packages/utils/src/lib/performance-observer.unit.test.ts

@@ -233,21 +233,6 @@ describe('PerformanceObserverHandle', () => {
     ]);
   });
 
-  it('should skip already processed entries', () => {
-    const observer = new PerformanceObserverHandle({
-      sink: mockSink,
-      encode: encodeFn,
-    });
-
-    getEntriesByTypeSpy.mockReturnValue([mockMarkEntry]);
-
-    observer.flush();
-    observer.flush();
-
-    expect(encodeFn).toHaveBeenCalledTimes(1);
-    expect(mockSink.written).toStrictEqual(['test-mark:mark']);
-  });
-
   it('should clear processed entries when clear=true', () => {
     const observer = new PerformanceObserverHandle({
       sink: mockSink,