fix: Remove close call method (#131)

lad-tech · Nov 8, 2024 · 61145d8 · 61145d8
1 parent d8b0ce2
commit 61145d8
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 3 deletions.
diff --git a/src/Client.ts b/src/Client.ts
@@ -97,7 +97,6 @@ export class Client<E extends Emitter = Emitter> extends Root {
         batch.push(message);
       }
       if (batch.length > 0) listener.emit(eventName, batch);
-      await events.close();
     }
   }
 

diff --git a/src/__tests__/Client.ts b/src/__tests__/Client.ts
@@ -101,8 +101,6 @@ describe('Testing Client class methods', () => {
       const payload = { data: { elapsed: 42 } };
       const subscribe = new PassThrough({ objectMode: true });
       const secondSubscribe = new PassThrough({ objectMode: true });
-      subscribe['close'] = jest.fn().mockResolvedValue('Ok');
-      secondSubscribe['close'] = jest.fn().mockResolvedValue('Ok');
       jetstreamFetchMock.mockResolvedValueOnce(subscribe);
       jetstreamFetchMock.mockResolvedValueOnce(secondSubscribe);
-Original file line number
+Diff line change
@@ Expand Up @@
             batch.push(message);
           }
           if (batch.length > 0) listener.emit(eventName, batch);
-          await events.close();
         }
       }
@@ Expand Down @@