diff --git a/cryptofeed/backends/quest.py b/cryptofeed/backends/quest.py
index d0660f629..1d6b1c99c 100644
--- a/cryptofeed/backends/quest.py
+++ b/cryptofeed/backends/quest.py
@@ -22,7 +22,7 @@ def __init__(self, host='127.0.0.1', port=9009, key=None, **kwargs):
         self.running = True
 
     async def writer(self):
-        while True:
+        while self.running:
             await self.connect()
             async with self.read_queue() as updates:
                 update = "\n".join(updates) + "\n"