fix size

well-known-components · Aug 24, 2022 · bb0e590 · bb0e590
1 parent eddafef
commit bb0e590
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/etc/pushable-channel.api.md b/etc/pushable-channel.api.md
@@ -7,7 +7,7 @@
 // @public
 export function pushableChannel<T>(onIteratorClose: () => void): {
     iterable: AsyncGenerator<T, any, unknown>;
-    bufferSize: () => () => number;
+    bufferSize: () => number;
     push: (value: T, resolve: (err?: any) => void) => void;
     close: () => void;
     failAndClose: (errorToThrow: Error) => void;

diff --git a/src/push-channel.ts b/src/push-channel.ts
@@ -80,7 +80,7 @@ export function pushableChannel<T>(onIteratorClose: () => void) {
   }
 
   function bufferSize() {
-    return queue.size
+    return queue.size()
   }
 
   function releaseLockIfNeeded() {

diff --git a/test/push-channel.spec.ts b/test/push-channel.spec.ts
@@ -142,6 +142,8 @@ describe("push channel", () => {
       push(4)
     ])
 
+    expect(chan.bufferSize()).toEqual(5)
+
     const takeAll = takeAsync(chan.iterable)
     await jobs
-Original file line number
+Diff line change
@@ Expand Up / @@ -142,6 +142,8 @@ describe("push channel", () => { @@
           push(4)
         ])
+        expect(chan.bufferSize()).toEqual(5)
         const takeAll = takeAsync(chan.iterable)
         await jobs
@@ Expand Down @@