Skip to content

Commit a1cfca6

Browse files
committed
Changed default get_message timeout behaviour to block execution
1 parent fb74aa2 commit a1cfca6

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

redis/asyncio/client.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -1079,7 +1079,7 @@ async def listen(self) -> AsyncIterator:
10791079
yield response
10801080

10811081
async def get_message(
1082-
self, ignore_subscribe_messages: bool = False, timeout: Optional[float] = 0.0
1082+
self, ignore_subscribe_messages: bool = False, timeout: Optional[float] = None
10831083
):
10841084
"""
10851085
Get the next message if one is available, otherwise None.

redis/client.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -1048,7 +1048,7 @@ def listen(self):
10481048
yield response
10491049

10501050
def get_message(
1051-
self, ignore_subscribe_messages: bool = False, timeout: float = 0.0
1051+
self, ignore_subscribe_messages: bool = False, timeout: Optional[float] = None
10521052
):
10531053
"""
10541054
Get the next message if one is available, otherwise None.

0 commit comments

Comments
 (0)