fix: async requerying

Author: maxnowack

__tests__/Cursor.spec.ts

@@ -323,7 +323,7 @@ describe('Cursor', () => {
       expect(callbacks.removed).not.toHaveBeenCalled()
     })
 
-    it('should call the appropriate callbacks when items are added, moved, changed, or removed', () => {
+    it('should call the appropriate callbacks when items are added, moved, changed, or removed', async () => {
       const col = new Collection<TestItem & { count: number }>()
       items.forEach((item, index) => col.insert({ ...item, count: index }))
 
@@ -342,28 +342,33 @@ describe('Cursor', () => {
 
       // Change data
       col.insert({ id: 4, name: 'item4', count: 99 }) // Add new item
+      await new Promise((resolve) => { setTimeout(resolve, 0) })
       expect(callbacks.added).toHaveBeenCalledWith(expect.objectContaining({ id: 4, name: 'item4' }))
       expect(callbacks.addedBefore).toHaveBeenCalledWith(
         expect.objectContaining({ id: 4, name: 'item4' }),
         null,
       )
 
       col.updateOne({ id: 1 }, { $set: { name: 'item1_modified' } }) // Modify existing item
+      await new Promise((resolve) => { setTimeout(resolve, 0) })
       expect(callbacks.changed).toHaveBeenCalledWith(expect.objectContaining({ id: 1, name: 'item1_modified' }))
 
       col.updateOne({ id: 1 }, { $set: { count: 42 } }) // Move existing item
+      await new Promise((resolve) => { setTimeout(resolve, 0) })
       expect(callbacks.movedBefore).toHaveBeenCalledWith(
         expect.objectContaining({ id: 1 }),
         expect.objectContaining({ id: 4 }),
       )
 
       col.updateOne({ id: 2 }, { $set: { count: 999 } }) // Move existing item
+      await new Promise((resolve) => { setTimeout(resolve, 0) })
       expect(callbacks.movedBefore).toHaveBeenCalledWith(
         expect.objectContaining({ id: 2 }),
         null,
       )
 
       col.removeOne({ id: 2 }) // Remove item
+      await new Promise((resolve) => { setTimeout(resolve, 0) })
       expect(callbacks.removed).toHaveBeenCalledWith(expect.objectContaining({ id: 2, name: 'Item 2' }))
     })
 

__tests__/reactivity/maverick-js.spec.ts

@@ -28,7 +28,7 @@ describe('@maverick-js/signals', () => {
     }),
   })
 
-  it('should be reactive with @maverick-js/signals', () => {
+  it('should be reactive with @maverick-js/signals', async () => {
     const collection = new Collection({ reactivity })
     const callback = vi.fn()
 
@@ -38,6 +38,7 @@ describe('@maverick-js/signals', () => {
     tick()
     collection.insert({ id: '1', name: 'John' })
     tick()
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     expect(reactivity.onDispose).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenLastCalledWith(1)

__tests__/reactivity/mobx.spec.ts

@@ -29,7 +29,7 @@ describe('MobX', () => {
     },
   })
 
-  it('should be reactive with MobX', () => {
+  it('should be reactive with MobX', async () => {
     const collection = new Collection({ reactivity })
     const callback = vi.fn()
 
@@ -38,6 +38,7 @@ describe('MobX', () => {
       callback(cursor.count())
     })
     collection.insert({ id: '1', name: 'John' })
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     expect(callback).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenLastCalledWith(1)
     stop()

__tests__/reactivity/oby.spec.ts

@@ -27,7 +27,7 @@ describe('oby', () => {
     }),
   })
 
-  it('should be reactive with oby', () => {
+  it('should be reactive with oby', async () => {
     const collection = new Collection({ reactivity })
     const callback = vi.fn()
 
@@ -37,6 +37,7 @@ describe('oby', () => {
     tick()
     collection.insert({ id: '1', name: 'John' })
     tick()
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     expect(reactivity.onDispose).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenLastCalledWith(1)

__tests__/reactivity/preact.spec.ts

@@ -18,7 +18,7 @@ describe('preact', () => {
     },
   })
 
-  it('should be reactive with preact', () => {
+  it('should be reactive with preact', async () => {
     const collection = new Collection({ reactivity })
     const callback = vi.fn()
     const cleanup = vi.fn()
@@ -32,6 +32,7 @@ describe('preact', () => {
       }
     })
     collection.insert({ id: '1', name: 'John' })
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     expect(cleanup).toHaveBeenCalledTimes(1)
     expect(callback).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenLastCalledWith(1)

__tests__/reactivity/reactively.spec.ts

@@ -20,7 +20,7 @@ describe('@reactively/core', () => {
     }),
   })
 
-  it('should be reactive with reactively', () => {
+  it('should be reactive with reactively', async () => {
     const collection = new Collection({ reactivity })
     const callback = vi.fn()
 
@@ -30,7 +30,9 @@ describe('@reactively/core', () => {
     })
     exec.get()
     collection.insert({ id: '1', name: 'John' })
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     exec.get()
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
 
     expect(reactivity.onDispose).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenCalledTimes(2)

__tests__/reactivity/s-js.spec.ts

@@ -20,7 +20,7 @@ describe('S.js', () => {
     }),
   })
 
-  it('should be reactive with S.js', () => {
+  it('should be reactive with S.js', async () => {
     const collection = new Collection({ reactivity })
     const callback = vi.fn()
 
@@ -29,6 +29,7 @@ describe('S.js', () => {
       callback(cursor.count())
     })
     collection.insert({ id: '1', name: 'John' })
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     expect(reactivity.onDispose).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenLastCalledWith(1)

__tests__/reactivity/sinuous.spec.ts

@@ -23,7 +23,7 @@ describe('sinuous', () => {
     }),
   })
 
-  it('should be reactive with sinuous', () => {
+  it('should be reactive with sinuous', async () => {
     const collection = new Collection({ reactivity })
     const callback = vi.fn()
 
@@ -32,6 +32,7 @@ describe('sinuous', () => {
       callback(cursor.count())
     })
     collection.insert({ id: '1', name: 'John' })
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     expect(reactivity.onDispose).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenLastCalledWith(1)

__tests__/reactivity/solid-js.spec.ts

@@ -26,22 +26,21 @@ describe('solid', () => {
     },
   })
 
-  it('should be reactive with solid', () => {
+  it('should be reactive with solid', async () => {
     const callback = vi.fn()
+    const collection = new Collection({ reactivity })
     createRoot(() => {
-      const collection = new Collection({ reactivity })
-
       const cursor = collection.find({ name: 'John' })
       createEffect(() => {
         const c = cursor.count()
         callback(c)
       })
-      setTimeout(() => {
-        collection.insert({ id: '1', name: 'John' })
-
-        expect(callback).toHaveBeenCalledTimes(2)
-        expect(callback).toHaveBeenLastCalledWith(1)
-      })
     })
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
+    collection.insert({ id: '1', name: 'John' })
+
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
+    expect(callback).toHaveBeenCalledTimes(2)
+    expect(callback).toHaveBeenLastCalledWith(1)
   })
 })

__tests__/reactivity/tracker.spec.ts

@@ -21,7 +21,7 @@ describe('Tracker', () => {
     }),
   })
 
-  it('should be reactive with Tracker', () => {
+  it('should be reactive with Tracker', async () => {
     const collection = new Collection({ reactivity })
     const callback = vi.fn()
 
@@ -30,13 +30,15 @@ describe('Tracker', () => {
     })
     Tracker.flush()
     collection.insert({ id: '1', name: 'John' })
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     Tracker.flush()
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     expect(reactivity.onDispose).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenLastCalledWith(1)
   })
 
-  it('should allow overriding reactivity primitives for query', () => {
+  it('should allow overriding reactivity primitives for query', async () => {
     const collection = new Collection()
     const callback = vi.fn()
 
@@ -47,7 +49,9 @@ describe('Tracker', () => {
     })
     Tracker.flush()
     collection.insert({ id: '1', name: 'John' })
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     Tracker.flush()
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     expect(callback).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenLastCalledWith(1)
   })

__tests__/reactivity/usignal.spec.ts

@@ -21,7 +21,7 @@ describe('usignal', () => {
     },
   })
 
-  it('should be reactive with usignal', () => {
+  it('should be reactive with usignal', async () => {
     const collection = new Collection({ reactivity })
     const callback = vi.fn()
     const cleanup = vi.fn()
@@ -35,6 +35,7 @@ describe('usignal', () => {
       }
     })
     collection.insert({ id: '1', name: 'John' })
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     expect(cleanup).toHaveBeenCalledTimes(1)
     expect(callback).toHaveBeenCalledTimes(2)
     expect(callback).toHaveBeenLastCalledWith(1)

__tests__/reactivity/vue.spec.ts

@@ -44,6 +44,7 @@ describe('Vue.js', () => {
     await vueNextTick()
     collection.insert({ id: '1', name: 'John' })
     await vueNextTick()
+    await new Promise((resolve) => { setTimeout(resolve, 0) })
     expect(callback).toHaveBeenLastCalledWith(1)
     expect(callback).toHaveBeenCalledTimes(2)
     expect(reactivity.onDispose).toHaveBeenCalledTimes(2)

src/Collection/Cursor.ts

@@ -137,8 +137,8 @@ export default class Cursor<T extends BaseItem, U = T> {
     const observer = new Observer(
       transformedCallbacks,
       () => {
-        const cleanup = this.options.bindEvents
-          && this.options.bindEvents(() => observer.check(this.getItems()))
+        const cleanup = this.options.bindEvents && this.options.bindEvents(() =>
+          setTimeout(() => observer.check(this.getItems()), 0))
         return () => {
           if (cleanup) cleanup()
         }