We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
raw
use_bin_type
1 parent 7a2e014 commit 78d8233Copy full SHA for 78d8233
ably/transport/websockettransport.py
@@ -206,7 +206,7 @@ async def ws_read_loop(self):
206
207
def decode_raw_websocket_frame(self, raw: str | bytes) -> dict:
208
if self.format == 'msgpack':
209
- return msgpack.unpackb(raw)
+ return msgpack.unpackb(raw, raw=False)
210
return json.loads(raw)
211
212
def on_protcol_message_handled(self, task):
@@ -247,7 +247,7 @@ async def send(self, message: dict):
247
raise Exception()
248
# Encode based on format
249
250
- raw_msg = msgpack.packb(message)
+ raw_msg = msgpack.packb(message, use_bin_type=True)
251
log.info(f'WebSocketTransport.send(): sending msgpack message (length: {len(raw_msg)} bytes)')
252
else:
253
raw_msg = json.dumps(message)
0 commit comments