From a80e4327e307c5d621da0935ba783a75dfb6ab29 Mon Sep 17 00:00:00 2001 From: icham Date: Mon, 5 Aug 2024 15:45:59 -0400 Subject: [PATCH] fix QuestCallback writer fail to close --- cryptofeed/backends/quest.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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"