Address some of fomo\'s comments
							parent
							
								
									fc7a8a5441
								
							
						
					
					
						commit
						4a47b4a1e3
					
				|  | @ -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() | ||||
|  |  | |||
|  | @ -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 | ||||
|  |  | |||
		Loading…
	
		Reference in New Issue