diff options
| author | Rapptz <[email protected]> | 2017-10-14 15:22:39 -0400 |
|---|---|---|
| committer | Rapptz <[email protected]> | 2017-10-14 15:22:39 -0400 |
| commit | 92a37c2e4fe77c12ba2b74c6d283ae4b776917c0 (patch) | |
| tree | 4084d35158b1c225c0fb1f4840d9afff681f46b9 /discord/gateway.py | |
| parent | Implement zlib streaming for the gateway. (diff) | |
| download | discord.py-92a37c2e4fe77c12ba2b74c6d283ae4b776917c0.tar.xz discord.py-92a37c2e4fe77c12ba2b74c6d283ae4b776917c0.zip | |
Revert "Implement zlib streaming for the gateway."
This reverts commit 462191a08b5b2efb83f5bc32935dc546d35a744b.
Diffstat (limited to 'discord/gateway.py')
| -rw-r--r-- | discord/gateway.py | 16 |
1 files changed, 2 insertions, 14 deletions
diff --git a/discord/gateway.py b/discord/gateway.py index eceb7a28..0ab02760 100644 --- a/discord/gateway.py +++ b/discord/gateway.py @@ -186,8 +186,6 @@ class DiscordWebSocket(websockets.client.WebSocketClientProtocol): # ws related stuff self.session_id = None self.sequence = None - self._zlib = zlib.decompressobj() - self._buffer = bytearray() @classmethod @asyncio.coroutine @@ -314,18 +312,8 @@ class DiscordWebSocket(websockets.client.WebSocketClientProtocol): self._dispatch('socket_raw_receive', msg) if isinstance(msg, bytes): - self._buffer.extend(msg) - - if len(msg) >= 4: - suffix = int.from_bytes(msg[-4:], byteorder='big') - if suffix == 0xFFFF: - msg = self._zlib.decompress(self._buffer) - msg = msg.decode('utf-8') - self._buffer = bytearray() - else: - return - else: - return + msg = zlib.decompress(msg, 15, 10490000) # This is 10 MiB + msg = msg.decode('utf-8') msg = json.loads(msg) |