We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cc7ad83 commit 87aaba8Copy full SHA for 87aaba8
1 file changed
src/replit_river/v2/session.py
@@ -1104,11 +1104,11 @@ async def _serve(
1104
message = await ws.recv(decode=False)
1105
try:
1106
msg = parse_transport_msg(message)
1107
- logger.debug(
1108
- "[%s] got a message %r",
1109
- transport_id,
1110
- msg,
1111
- )
+ # logger.debug(
+ # "[%s] got a message %r",
+ # transport_id,
+ # msg,
+ # )
1112
1113
if msg.controlFlags & STREAM_OPEN_BIT != 0:
1114
raise InvalidMessageException(
@@ -1131,6 +1131,13 @@ async def _serve(
1131
case other:
1132
assert_never(other)
1133
1134
+ # TODO: Delete me
1135
+ logger.debug(
1136
+ "[%s] got a message %r",
1137
+ transport_id,
1138
+ msg,
1139
+ )
1140
+
1141
reset_session_close_countdown()
1142
1143
# Shortcut to avoid processing ack packets
0 commit comments