File tree Expand file tree Collapse file tree 3 files changed +14
-14
lines changed Expand file tree Collapse file tree 3 files changed +14
-14
lines changed Original file line number Diff line number Diff line change @@ -27,7 +27,7 @@ async def trio_main():
27
27
to_trio , from_aio = trio .open_memory_channel (float ("inf" ))
28
28
from_trio = asyncio .Queue ()
29
29
30
- _task_ref = asyncio .create_task (aio_pingpong (from_trio , to_trio ))
30
+ task_ref = asyncio .create_task (aio_pingpong (from_trio , to_trio ))
31
31
32
32
from_trio .put_nowait (0 )
33
33
@@ -37,7 +37,7 @@ async def trio_main():
37
37
from_trio .put_nowait (n + 1 )
38
38
if n >= 10 :
39
39
return
40
- del _task_ref
40
+ del task_ref
41
41
42
42
43
43
async def aio_pingpong (from_trio , to_trio ):
Original file line number Diff line number Diff line change @@ -467,7 +467,7 @@ async def open_file(
467
467
:func:`trio.Path.open`
468
468
469
469
"""
470
- _file = wrap_file (
470
+ file_ = wrap_file (
471
471
await trio .to_thread .run_sync (
472
472
io .open ,
473
473
file ,
@@ -480,7 +480,7 @@ async def open_file(
480
480
opener ,
481
481
),
482
482
)
483
- return _file
483
+ return file_
484
484
485
485
486
486
def wrap_file (file : FileT ) -> AsyncIOWrapper [FileT ]:
Original file line number Diff line number Diff line change @@ -1283,26 +1283,26 @@ async def sendto(self, *args: object) -> int:
1283
1283
@_wraps (_stdlib_socket .socket .sendmsg , assigned = (), updated = ())
1284
1284
async def sendmsg (
1285
1285
self ,
1286
- __buffers : Iterable [Buffer ],
1287
- __ancdata : Iterable [tuple [int , int , Buffer ]] = (),
1288
- __flags : int = 0 ,
1289
- __address : AddressFormat | None = None ,
1286
+ buffers : Iterable [Buffer ],
1287
+ ancdata : Iterable [tuple [int , int , Buffer ]] = (),
1288
+ flags : int = 0 ,
1289
+ address : AddressFormat | None = None ,
1290
1290
) -> int :
1291
1291
"""Similar to :meth:`socket.socket.sendmsg`, but async.
1292
1292
1293
1293
Only available on platforms where :meth:`socket.socket.sendmsg` is
1294
1294
available.
1295
1295
1296
1296
"""
1297
- if __address is not None :
1298
- __address = await self ._resolve_address_nocp (__address , local = False )
1297
+ if address is not None :
1298
+ address = await self ._resolve_address_nocp (address , local = False )
1299
1299
return await self ._nonblocking_helper (
1300
1300
_core .wait_writable ,
1301
1301
_stdlib_socket .socket .sendmsg ,
1302
- __buffers ,
1303
- __ancdata ,
1304
- __flags ,
1305
- __address ,
1302
+ buffers ,
1303
+ ancdata ,
1304
+ flags ,
1305
+ address ,
1306
1306
)
1307
1307
1308
1308
################################################################
You can’t perform that action at this time.
0 commit comments