Skip to content

Commit

Permalink
fix receive function
Browse files Browse the repository at this point in the history
  • Loading branch information
devkral committed Jul 22, 2024
1 parent 6f03d69 commit e8f958f
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion channels/layers.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit e8f958f

Please sign in to comment.