fix(Channel): set default limit to infinite

src/adapters/Channel.spec.ts

@@ -9,6 +9,19 @@ describe('Channel', () => {
     expect(new Channel()).toBeInstanceOf(Channel);
   });
 
+  it('pushes', async () => {
+    const c = new Channel<number>();
+    c.push(1);
+    expect(await c.next()).toEqual({ done: false, value: 1 });
+  });
+
+  it('pulls', async () => {
+    const c = new Channel<number>();
+    const p = c.next();
+    c.push(1);
+    expect(await p).toEqual({ done: false, value: 1 });
+  });
+
   it('can balance pull after push', async () => {
     const c = new Channel<number>();
     const ns = [1, 2, 3];

src/adapters/Channel.ts

@@ -37,7 +37,7 @@ export default class Channel<A> implements PushAdapter<A> {
 
   constructor(
     /** Limit (bounds) after which the oldest buffered value is dropped. */
-    limit = 0,
+    limit = Infinity,
   ) {
     this.pushBuffer = new LinkedQueue(limit);
     this.pullBuffer = new LinkedQueue(limit);