diff --git a/econtext/core.py b/econtext/core.py index 925c8bcd..8b169dd8 100644 --- a/econtext/core.py +++ b/econtext/core.py @@ -644,7 +644,7 @@ class Broker(object): for side in self._readers | self._writers: self._CallAndUpdate(side.stream, side.stream.Shutdown) - deadline = time.time() + 5.0 + deadline = time.time() + 1.0 while (self._readers or self._writers) and time.time() < deadline: self._LoopOnce(1.0)