|
@@ -267,9 +267,9 @@ async def send(peer, message):
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
async def receive(peer):
|
|
async def receive(peer):
|
|
|
- await cooldown(peer, False)
|
|
|
|
|
-
|
|
|
|
|
async with peer.receive_lock:
|
|
async with peer.receive_lock:
|
|
|
|
|
+ await cooldown(peer, False)
|
|
|
|
|
+
|
|
|
kind = (await read(peer, 1))[0]
|
|
kind = (await read(peer, 1))[0]
|
|
|
|
|
|
|
|
if kind != 0xff:
|
|
if kind != 0xff:
|
