Test subscribe

packages/vest/src/suite/__tests__/subscribe.test.ts

@@ -1,3 +1,5 @@
+import wait from 'wait';
+
 import { SuiteSerializer } from 'SuiteSerializer';
 import * as vest from 'vest';
 
@@ -8,23 +10,43 @@ describe('suite.subscribe', () => {
     expect(typeof suite.subscribe).toBe('function');
   });
 
-  it('Should call the callback on suite updates', () => {
+  it('Should call the callback on suite updates', async () => {
+    const cb = jest.fn(() => {
+      dumps.push(SuiteSerializer.serialize(suite));
+    });
+    let callCount = cb.mock.calls.length;
+
     const suite = vest.create('suite', () => {
+      expect(cb.mock.calls.length).toBeGreaterThan(callCount);
+      callCount = cb.mock.calls.length;
       vest.test('field', () => {});
+      expect(cb.mock.calls.length).toBeGreaterThan(callCount);
+      callCount = cb.mock.calls.length;
       vest.test('field2', () => {});
+      expect(cb.mock.calls.length).toBeGreaterThan(callCount);
+      callCount = cb.mock.calls.length;
       vest.test('field3', () => false);
+      expect(cb.mock.calls.length).toBeGreaterThan(callCount);
+      callCount = cb.mock.calls.length;
       vest.test('field4', async () => Promise.reject<undefined>());
+      expect(cb.mock.calls.length).toBeGreaterThan(callCount);
+      callCount = cb.mock.calls.length;
     });
 
-    const dumps = [];
-    const cb = jest.fn(() => {
-      console.log(SuiteSerializer.serialize(suite));
-    });
+    const dumps: string[] = [];
 
     suite.subscribe(cb);
+    expect(cb.mock.calls).toHaveLength(0);
     suite();
-    expect(cb.mock.calls.length).toBeGreaterThan(10);
+    expect(cb.mock.calls.length).toBeGreaterThan(callCount);
+    callCount = cb.mock.calls.length;
+
+    // expect some of the dumps to be different
+    expect(dumps.some((dump, i) => dump !== dumps[i - 1])).toBe(true);
+
+    await wait(10);
 
-    // console.log(dumps[0]);
+    // now also after resolving the async test
+    expect(cb.mock.calls.length).toBeGreaterThan(callCount);
   });
 });

packages/vest/src/suite/createSuite.ts

@@ -80,7 +80,7 @@ function createSuite<
         reset: Bus.usePrepareEmitter(Events.RESET_SUITE),
         resetField: Bus.usePrepareEmitter<string>(Events.RESET_FIELD),
         resume: VestRuntime.persist(useLoadSuite),
-        subscribe: VestRuntime.persist(subscribe),
+        subscribe: subscribe,
         ...bindSuiteSelectors<F, G>(VestRuntime.persist(useCreateSuiteResult)),
         ...getTypedMethods<F, G>(),
       }