Add test for _all Consumer

albe · Jun 12, 2021 · 8ece5a2 · 8ece5a2
1 parent c828984
commit 8ece5a2
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/test/EventStore.spec.js b/test/EventStore.spec.js
@@ -664,6 +664,23 @@ describe('EventStore', function() {
             eventstore.commit('foo', { foo: 'bar', id: 2 });
         });
 
+        it('can return a consumer for the _all stream', function(done) {
+            eventstore = new EventStore({
+                storageDirectory
+            });
+
+            const consumer = eventstore.getConsumer('_all', 'consumer1');
+            expect(consumer instanceof Consumer).to.be(true);
+            let i = 0;
+            consumer.on('data', event => {
+                expect(event.payload.id).to.be(++i);
+                if (i === 2) {
+                    done();
+                }
+            });
+            eventstore.commit('foo', { foo: 'bar', id: 1 });
+            eventstore.commit('bar', { foo: 'baz', id: 2 });
+        });
     });
 
 });