fix receive function

django · Feb 15, 2023 · d93d1fa · d93d1fa
1 parent e3da586
commit d93d1fa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/channels/layers.py b/channels/layers.py
@@ -249,7 +249,7 @@ async def receive(self, channel):
 
         # Do a plain direct receive
         try:
-            _, message = await asyncio.wait_for(queue.get(), self.expiry)
+            _, message = await queue.get()
         finally:
             if queue.empty():
                 self.channels.pop(channel, None)