aboutsummaryrefslogtreecommitdiff
path: root/discord/client.py
diff options
context:
space:
mode:
Diffstat (limited to 'discord/client.py')
-rw-r--r--discord/client.py13
1 files changed, 7 insertions, 6 deletions
diff --git a/discord/client.py b/discord/client.py
index 78da75d0..95f71327 100644
--- a/discord/client.py
+++ b/discord/client.py
@@ -342,17 +342,18 @@ class Client:
@asyncio.coroutine
def _connect(self):
- self.ws = yield from DiscordWebSocket.from_client(self, shard_id=self.shard_id)
-
+ coro = DiscordWebSocket.from_client(self, shard_id=self.shard_id)
+ self.ws = yield from asyncio.wait_for(coro, timeout=180.0, loop=self.loop)
while True:
try:
yield from self.ws.poll_event()
except ResumeWebSocket as e:
log.info('Got a request to RESUME the websocket.')
- self.ws = yield from DiscordWebSocket.from_client(self, shard_id=self.shard_id,
- session=self.ws.session_id,
- sequence=self.ws.sequence,
- resume=True)
+ coro = DiscordWebSocket.from_client(self, shard_id=self.shard_id,
+ session=self.ws.session_id,
+ sequence=self.ws.sequence,
+ resume=True)
+ self.ws = yield from asyncio.wait_for(coro, timeout=180.0, loop=self.loop)
@asyncio.coroutine
def connect(self, *, reconnect=True):