diff --git a/tractor/_exceptions.py b/tractor/_exceptions.py index 9c3edac..79bcd3c 100644 --- a/tractor/_exceptions.py +++ b/tractor/_exceptions.py @@ -61,6 +61,10 @@ class NoRuntime(RuntimeError): "The root actor has not been initialized yet" +class StreamOverrun(trio.TooSlowError): + "This stream was overrun by sender" + + def pack_error( exc: BaseException, tb=None,