From 77ee417d1ab74b99f2ace968b23189e42886cb79 Mon Sep 17 00:00:00 2001
From: Rodrigo Nascimento <rodrigoknascimento@gmail.com>
Date: Fri, 2 Jun 2023 18:52:06 -0300
Subject: [PATCH] Update observe_changes_tests.js

---
 packages/mongo/observe_changes_tests.js | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/packages/mongo/observe_changes_tests.js b/packages/mongo/observe_changes_tests.js
index ec349557d0..30004d4b1d 100644
--- a/packages/mongo/observe_changes_tests.js
+++ b/packages/mongo/observe_changes_tests.js
@@ -477,14 +477,14 @@ if (Meteor.isServer) {
       self.xs = [];
       self.expects = [];
       self.insert = async function(fields) {
-        coll.insertAsync(
+        return coll.insertAsync(
           _.extend({ ts: new MongoInternals.MongoTimestamp(0, 0) }, fields)
         );
       };
 
       // Tailable observe shouldn't show things that are in the initial
       // contents.
-      self.insert({ x: 1 });
+      await self.insert({ x: 1 });
       // Wait for one added call before going to the next test function.
 
       const [resolver, promise] = getPromiseAndResolver();
@@ -519,11 +519,11 @@ if (Meteor.isServer) {
       const [resolver1, promise1] = getPromiseAndResolver();
       const [resolver2, promise2] = getPromiseAndResolver();
 
-      self.insert({x: 2, y: 3});
-      self.insert({x: 3, y: 7});  // filtered out by the query
-      self.insert({x: 4});
+      await self.insert({x: 2, y: 3});
+      self.expects.push(resolver1, resolver2);
+      await self.insert({x: 3, y: 7});  // filtered out by the query
+      await self.insert({x: 4});
       // Expect two added calls to happen.
-      self.expects = [resolver1, resolver2];
       await Promise.all([promise1, promise2]);
     },
     function (test, expect) {