pstruebi/bumble_fork
1
0
Fork 0
forked from auracaster/bumble_mirror
Code Pull Requests Activity

rename .run to .spawn

Browse Source
This commit is contained in:
Gilles Boccon-Gibod
2023-03-22 17:26:32 -07:00
parent bc29f327ef
commit 864889ccab
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
apps/bench.py
View File

@@ -323,7 +323,7 @@ class Receiver:
self.expected_packet_index = packet_index + 1
if packet_flags & PACKET_FLAG_LAST:
AsyncRunner.run(
AsyncRunner.spawn(
self.packet_io.send_packet(
struct.pack('>bbI', PacketType.ACK, packet_flags, packet_index)
)
@@ -423,7 +423,7 @@ class Ping:
self.done.set()
return
AsyncRunner.run(self.send_next_ping())
AsyncRunner.spawn(self.send_next_ping())
# -----------------------------------------------------------------------------
@@ -472,7 +472,7 @@ class Pong:
self.expected_packet_index = packet_index + 1
AsyncRunner.run(
AsyncRunner.spawn(
self.packet_io.send_packet(
struct.pack('>bbI', PacketType.ACK, packet_flags, packet_index)
)

4
bumble/utils.py
View File

@@ -191,9 +191,9 @@ class AsyncRunner:
return decorator
@staticmethod
def run(coroutine):
def spawn(coroutine):
"""
Create a task to run a coroutine in a "fire and forget" task.
Spawn a task to run a coroutine in a "fire and forget" mode.
Using this method instead of just calling `asyncio.create_task(coroutine)`
is necessary when you don't keep a reference to the task, because `asyncio`