diff --git a/test/asynchronous/test_read_concern.py b/test/asynchronous/test_read_concern.py
new file mode 100644
index 0000000000..fbc07a5c36
--- /dev/null
+++ b/test/asynchronous/test_read_concern.py
@@ -0,0 +1,122 @@
+# Copyright 2015-present MongoDB, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+"""Test the read_concern module."""
+from __future__ import annotations
+
+import sys
+import unittest
+
+sys.path[0:0] = [""]
+
+from test.asynchronous import AsyncIntegrationTest, async_client_context
+from test.utils import OvertCommandListener
+
+from bson.son import SON
+from pymongo.errors import OperationFailure
+from pymongo.read_concern import ReadConcern
+
+_IS_SYNC = False
+
+
+class TestReadConcern(AsyncIntegrationTest):
+    listener: OvertCommandListener
+
+    @async_client_context.require_connection
+    async def asyncSetUp(self):
+        await super().asyncSetUp()
+        self.listener = OvertCommandListener()
+        self.client = await self.async_rs_or_single_client(event_listeners=[self.listener])
+        self.db = self.client.pymongo_test
+        await async_client_context.client.pymongo_test.create_collection("coll")
+
+    async def asyncTearDown(self):
+        await async_client_context.client.pymongo_test.drop_collection("coll")
+
+    def test_read_concern(self):
+        rc = ReadConcern()
+        self.assertIsNone(rc.level)
+        self.assertTrue(rc.ok_for_legacy)
+
+        rc = ReadConcern("majority")
+        self.assertEqual("majority", rc.level)
+        self.assertFalse(rc.ok_for_legacy)
+
+        rc = ReadConcern("local")
+        self.assertEqual("local", rc.level)
+        self.assertTrue(rc.ok_for_legacy)
+
+        self.assertRaises(TypeError, ReadConcern, 42)
+
+    async def test_read_concern_uri(self):
+        uri = f"mongodb://{await async_client_context.pair}/?readConcernLevel=majority"
+        client = await self.async_rs_or_single_client(uri, connect=False)
+        self.assertEqual(ReadConcern("majority"), client.read_concern)
+
+    async def test_invalid_read_concern(self):
+        coll = self.db.get_collection("coll", read_concern=ReadConcern("unknown"))
+        # We rely on the server to validate read concern.
+        with self.assertRaises(OperationFailure):
+            await coll.find_one()
+
+    async def test_find_command(self):
+        # readConcern not sent in command if not specified.
+        coll = self.db.coll
+        await coll.find({"field": "value"}).to_list()
+        self.assertNotIn("readConcern", self.listener.started_events[0].command)
+
+        self.listener.reset()
+
+        # Explicitly set readConcern to 'local'.
+        coll = self.db.get_collection("coll", read_concern=ReadConcern("local"))
+        await coll.find({"field": "value"}).to_list()
+        self.assertEqualCommand(
+            SON(
+                [
+                    ("find", "coll"),
+                    ("filter", {"field": "value"}),
+                    ("readConcern", {"level": "local"}),
+                ]
+            ),
+            self.listener.started_events[0].command,
+        )
+
+    async def test_command_cursor(self):
+        # readConcern not sent in command if not specified.
+        coll = self.db.coll
+        await (await coll.aggregate([{"$match": {"field": "value"}}])).to_list()
+        self.assertNotIn("readConcern", self.listener.started_events[0].command)
+
+        self.listener.reset()
+
+        # Explicitly set readConcern to 'local'.
+        coll = self.db.get_collection("coll", read_concern=ReadConcern("local"))
+        await (await coll.aggregate([{"$match": {"field": "value"}}])).to_list()
+        self.assertEqual({"level": "local"}, self.listener.started_events[0].command["readConcern"])
+
+    async def test_aggregate_out(self):
+        coll = self.db.get_collection("coll", read_concern=ReadConcern("local"))
+        await (
+            await coll.aggregate([{"$match": {"field": "value"}}, {"$out": "output_collection"}])
+        ).to_list()
+
+        # Aggregate with $out supports readConcern MongoDB 4.2 onwards.
+        if async_client_context.version >= (4, 1):
+            self.assertIn("readConcern", self.listener.started_events[0].command)
+        else:
+            self.assertNotIn("readConcern", self.listener.started_events[0].command)
+
+
+if __name__ == "__main__":
+    unittest.main()
diff --git a/test/test_read_concern.py b/test/test_read_concern.py
index f7c0901422..8ec9865eaa 100644
--- a/test/test_read_concern.py
+++ b/test/test_read_concern.py
@@ -27,6 +27,8 @@
 from pymongo.errors import OperationFailure
 from pymongo.read_concern import ReadConcern
 
+_IS_SYNC = True
+
 
 class TestReadConcern(IntegrationTest):
     listener: OvertCommandListener
@@ -71,14 +73,14 @@ def test_invalid_read_concern(self):
     def test_find_command(self):
         # readConcern not sent in command if not specified.
         coll = self.db.coll
-        tuple(coll.find({"field": "value"}))
+        coll.find({"field": "value"}).to_list()
         self.assertNotIn("readConcern", self.listener.started_events[0].command)
 
         self.listener.reset()
 
         # Explicitly set readConcern to 'local'.
         coll = self.db.get_collection("coll", read_concern=ReadConcern("local"))
-        tuple(coll.find({"field": "value"}))
+        coll.find({"field": "value"}).to_list()
         self.assertEqualCommand(
             SON(
                 [
@@ -93,19 +95,19 @@ def test_find_command(self):
     def test_command_cursor(self):
         # readConcern not sent in command if not specified.
         coll = self.db.coll
-        tuple(coll.aggregate([{"$match": {"field": "value"}}]))
+        (coll.aggregate([{"$match": {"field": "value"}}])).to_list()
         self.assertNotIn("readConcern", self.listener.started_events[0].command)
 
         self.listener.reset()
 
         # Explicitly set readConcern to 'local'.
         coll = self.db.get_collection("coll", read_concern=ReadConcern("local"))
-        tuple(coll.aggregate([{"$match": {"field": "value"}}]))
+        (coll.aggregate([{"$match": {"field": "value"}}])).to_list()
         self.assertEqual({"level": "local"}, self.listener.started_events[0].command["readConcern"])
 
     def test_aggregate_out(self):
         coll = self.db.get_collection("coll", read_concern=ReadConcern("local"))
-        tuple(coll.aggregate([{"$match": {"field": "value"}}, {"$out": "output_collection"}]))
+        (coll.aggregate([{"$match": {"field": "value"}}, {"$out": "output_collection"}])).to_list()
 
         # Aggregate with $out supports readConcern MongoDB 4.2 onwards.
         if client_context.version >= (4, 1):
diff --git a/tools/synchro.py b/tools/synchro.py
index dc272929ad..59c5e1ad4f 100644
--- a/tools/synchro.py
+++ b/tools/synchro.py
@@ -216,6 +216,7 @@ def async_only_test(f: str) -> bool:
     "test_logger.py",
     "test_monitoring.py",
     "test_raw_bson.py",
+    "test_read_concern.py",
     "test_retryable_reads.py",
     "test_retryable_writes.py",
     "test_session.py",