Utilities/mailer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

minor fix

Browse Source
This commit is contained in:
break27
2025-09-10 20:02:39 +08:00
parent 185b2abae4
commit 15ff6a17c6
2 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
main.py
View File

@@ -541,7 +541,7 @@ async def handler(request: ws.WebSocketRequest):
message = await connection.get_message() message = await connection.get_message()
inbox.put(message) inbox.put(message)
except Exception as e: except Exception as e:
tell('Receiver', e, level=0) inbox.shutdown(immediate=True)
break break
async def sender(): async def sender():
@@ -550,16 +550,13 @@ async def handler(request: ws.WebSocketRequest):
message = await trio.to_thread.run_sync(outbox.get) message = await trio.to_thread.run_sync(outbox.get)
await connection.send_message(str(message)) await connection.send_message(str(message))
except Exception as e: except Exception as e:
tell('Sender', e, level=0) outbox.shutdown(immediate=True)
break break
async with trio.open_nursery() as nursery: async with trio.open_nursery() as nursery:
nursery.start_soon(receiver) nursery.start_soon(receiver)
nursery.start_soon(sender) nursery.start_soon(sender)
outbox.shutdown(immediate=True)
inbox.shutdown(immediate=True)
async def backend(listen='127.0.0.1', port=0): async def backend(listen='127.0.0.1', port=0):
global server global server
listeners = await trio.open_tcp_listeners(port, host=listen) listeners = await trio.open_tcp_listeners(port, host=listen)