run_forever(): first ensure that _run_once() will not be called

1 files changed, 5 insertions, 1 deletions

diff --git a/aiogreen.py b/aiogreen.py
index 5a00043..77bb0d9 100644
--- a/aiogreen.py
+++ b/aiogreen.py
@@ -354,8 +354,12 @@ class EventLoop(BaseEventLoop):
             # sleep until the stop() method is called
             stop_event.wait()
         finally:
-            self._stop_event = None
+            # First ensure that _run_once() will not be called
             self._scheduler.stop()
+
+            # The event loop stopped
+            self._stop_event = None
+
             # Stop the greenthread of the thread queue.
             # call_soon_threadsafe() can still be called, handles will be
             # stored in the thread queue.