Skip to content

Commit 574c0ec

Browse files
committed
WIP abstraction of Connection.conn to Connection.NetworkingInterface
1 parent 4b25e95 commit 574c0ec

File tree

5 files changed

+459
-879
lines changed

5 files changed

+459
-879
lines changed

pymongo/asynchronous/network.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@
4747
from bson import CodecOptions
4848
from pymongo.asynchronous.client_session import AsyncClientSession
4949
from pymongo.asynchronous.mongo_client import AsyncMongoClient
50-
from pymongo.asynchronous.pool import AsyncConnectionProtocol
50+
from pymongo.asynchronous.pool import AsyncConnection
5151
from pymongo.compression_support import SnappyContext, ZlibContext, ZstdContext
5252
from pymongo.monitoring import _EventListeners
5353
from pymongo.read_concern import ReadConcern
@@ -59,7 +59,7 @@
5959

6060

6161
async def command(
62-
conn: AsyncConnectionProtocol,
62+
conn: AsyncConnection,
6363
dbname: str,
6464
spec: MutableMapping[str, Any],
6565
is_mongos: bool,
@@ -189,7 +189,7 @@ async def command(
189189
)
190190

191191
try:
192-
await async_sendall(conn, msg)
192+
await async_sendall(conn.conn.writer, msg)
193193
if use_op_msg and unacknowledged:
194194
# Unacknowledged, fake a successful command response.
195195
reply = None

0 commit comments

Comments
 (0)