diff --git a/linkedin_messaging/linkedin.py b/linkedin_messaging/linkedin.py
index cb6dfe8..91849dc 100644
--- a/linkedin_messaging/linkedin.py
+++ b/linkedin_messaging/linkedin.py
@@ -559,7 +559,7 @@ async def _listen_to_event_stream(self):
                 raise TooManyRequestsError(f"Failed to connect. Status {resp.status}.")
 
             while True:
-                line = await resp.content.readline()
+                line = await asyncio.wait_for(resp.content.readline(), timeout=20)
                 if resp.content.at_eof():
                     break