From 4aef1e3ba628c74afa2d805296360a8fb7428ad3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Nacho=20Codo=C3=B1er?= <igcogi@gmail.com>
Date: Thu, 22 Feb 2024 16:37:14 +0100
Subject: [PATCH] implement observeChangesAsync test

---
 packages/mongo/mongo_livedata_tests.js | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/packages/mongo/mongo_livedata_tests.js b/packages/mongo/mongo_livedata_tests.js
index 4e50d5d507..3e04440537 100644
--- a/packages/mongo/mongo_livedata_tests.js
+++ b/packages/mongo/mongo_livedata_tests.js
@@ -4302,3 +4302,19 @@ Tinytest.addAsync('mongo-livedata - maintained isomorphism using resolverType co
 
   test.equal(items, []);
 });
+
+Tinytest.addAsync("mongo-livedata - support observeChangesAsync on client and server to keep isomorphism", async (test) => {
+  const Collection = new Mongo.Collection(`observe_changes_async${test.runId()}`, { resolverType: 'stub' });
+  const id = 'a';
+  await Collection.insertAsync({ _id: id, foo: { bar: 123 } });
+
+  return new Promise(async resolve => {
+    const obs = await Collection.find(id).observeChangesAsync({
+      async changed() {
+        resolve();
+        await obs.stop();
+      },
+    });
+    await Collection.updateAsync(id, { $set: { 'foo.bar': 456 } });
+  });
+});