Address some of fomo\'s comments
parent
b6bc57c4e0
commit
9d25cce945
|
@ -115,9 +115,6 @@ class RingBuffSender(trio.abc.SendStream):
|
||||||
self._wrap_event.open()
|
self._wrap_event.open()
|
||||||
return self
|
return self
|
||||||
|
|
||||||
async def __aexit__(self, exc_type, exc_value, traceback):
|
|
||||||
await self.aclose()
|
|
||||||
|
|
||||||
|
|
||||||
class RingBuffReceiver(trio.abc.ReceiveStream):
|
class RingBuffReceiver(trio.abc.ReceiveStream):
|
||||||
'''
|
'''
|
||||||
|
@ -215,6 +212,3 @@ class RingBuffReceiver(trio.abc.ReceiveStream):
|
||||||
self._write_event.open()
|
self._write_event.open()
|
||||||
self._wrap_event.open()
|
self._wrap_event.open()
|
||||||
return self
|
return self
|
||||||
|
|
||||||
async def __aexit__(self, exc_type, exc_value, traceback):
|
|
||||||
await self.aclose()
|
|
||||||
|
|
|
@ -32,7 +32,10 @@ from multiprocessing.shared_memory import (
|
||||||
ShareableList,
|
ShareableList,
|
||||||
)
|
)
|
||||||
|
|
||||||
from msgspec import Struct, to_builtins
|
from msgspec import (
|
||||||
|
Struct,
|
||||||
|
to_builtins
|
||||||
|
)
|
||||||
import tractor
|
import tractor
|
||||||
|
|
||||||
from tractor.log import get_logger
|
from tractor.log import get_logger
|
||||||
|
|
Loading…
Reference in New Issue