Address some of fomo\'s comments

Guillermo Rodriguez 2025-03-13 22:47:45 -03:00
parent f552a3f8f5
commit 36d35680f7
No known key found for this signature in database
GPG Key ID: 002CC5F1E6BDA53E
2 changed files with 4 additions and 7 deletions

View File

@ -115,9 +115,6 @@ class RingBuffSender(trio.abc.SendStream):
self._wrap_event.open()
return self
async def __aexit__(self, exc_type, exc_value, traceback):
await self.aclose()
class RingBuffReceiver(trio.abc.ReceiveStream):
'''
@ -215,6 +212,3 @@ class RingBuffReceiver(trio.abc.ReceiveStream):
self._write_event.open()
self._wrap_event.open()
return self
async def __aexit__(self, exc_type, exc_value, traceback):
await self.aclose()

View File

@ -32,7 +32,10 @@ from multiprocessing.shared_memory import (
ShareableList,
)
from msgspec import Struct, to_builtins
from msgspec import (
Struct,
to_builtins
)
import tractor
from tractor.log import get_logger