Skip to content

Commit a085c2e

Browse files
authored
json.dump() each websocket message once instead of twice (#1597)
1 parent 6937ccd commit a085c2e

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

shiny/session/_session.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -955,15 +955,17 @@ async def send_custom_message(self, type: str, message: dict[str, object]) -> No
955955
await self._send_message({"custom": {type: message}})
956956

957957
async def _send_message(self, message: dict[str, object]) -> None:
958-
message_str: str = json.dumps(message) + "\n"
958+
message_str = json.dumps(message)
959959
if self._debug:
960960
print(
961961
"SEND: "
962-
+ re.sub("(?m)base64,[a-zA-Z0-9+/=]+", "[base64 data]", message_str),
962+
+ re.sub(
963+
"(?m)base64,[a-zA-Z0-9+/=]+", "[base64 data]", message_str + "\n"
964+
),
963965
end="",
964966
flush=True,
965967
)
966-
await self._conn.send(json.dumps(message))
968+
await self._conn.send(message_str)
967969

968970
def _send_message_sync(self, message: dict[str, object]) -> None:
969971
_utils.run_coro_hybrid(self._send_message(message))

0 commit comments

Comments
 (0)