22
22
sys .path [0 :0 ] = ["" ]
23
23
from asyncio import iscoroutinefunction
24
24
from test .asynchronous import AsyncIntegrationTest , async_client_context , unittest
25
- from test .utils import EventListener
25
+ from test .utils import OvertCommandListener
26
26
27
27
from bson .dbref import DBRef
28
28
from pymongo .asynchronous .command_cursor import AsyncCommandCursor
@@ -84,7 +84,7 @@ async def _test_ops(
84
84
@async_client_context .require_version_min (4 , 7 , - 1 )
85
85
@async_client_context .require_replica_set
86
86
async def test_database_helpers (self ):
87
- listener = EventListener ()
87
+ listener = OvertCommandListener ()
88
88
db = (await self .async_rs_or_single_client (event_listeners = [listener ])).db
89
89
helpers = [
90
90
(db .watch , []),
@@ -101,7 +101,7 @@ async def test_database_helpers(self):
101
101
@async_client_context .require_version_min (4 , 7 , - 1 )
102
102
@async_client_context .require_replica_set
103
103
async def test_client_helpers (self ):
104
- listener = EventListener ()
104
+ listener = OvertCommandListener ()
105
105
cli = await self .async_rs_or_single_client (event_listeners = [listener ])
106
106
helpers = [
107
107
(cli .watch , []),
@@ -116,7 +116,7 @@ async def test_client_helpers(self):
116
116
117
117
@async_client_context .require_version_min (4 , 7 , - 1 )
118
118
async def test_collection_helpers (self ):
119
- listener = EventListener ()
119
+ listener = OvertCommandListener ()
120
120
db = (await self .async_rs_or_single_client (event_listeners = [listener ]))[self .db .name ]
121
121
coll = db .get_collection ("test" )
122
122
0 commit comments