Skip to content

Commit f57e4a7

Browse files
authored
Fix handling of binary buffers (#18)
1 parent f9f6507 commit f57e4a7

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/bokeh_fastapi/handler.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -354,10 +354,10 @@ async def send_message(self, message: Message) -> int:
354354
await self._socket.send_text(message.content_json)
355355
sent += len(message.content_json)
356356

357-
for header, payload in cast(
358-
list[tuple[dict[str, Any], bytes]], message._buffers
359-
):
360-
await self._socket.send_text(json.dumps(header))
357+
for buff in message._buffers:
358+
header = json.dumps(buff.ref)
359+
payload = buff.to_bytes()
360+
await self._socket.send_text(header)
361361
await self._socket.send_bytes(payload)
362362
sent += len(header) + len(payload)
363363
except WebSocketDisconnect as e:

0 commit comments

Comments
 (0)