We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1d2eede commit 75cf18bCopy full SHA for 75cf18b
1 file changed
src/replit_river/v2/session.py
@@ -1152,11 +1152,11 @@ async def _serve(
1152
message = await ws.recv(decode=False)
1153
try:
1154
msg = parse_transport_msg(message)
1155
- # logger.debug(
1156
- # "[%s] got a message %r",
1157
- # transport_id,
1158
- # msg,
1159
- # )
+ logger.debug(
+ "[%s] got a message %r",
+ transport_id,
+ msg,
+ )
1160
1161
if msg.controlFlags & STREAM_OPEN_BIT != 0:
1162
raise InvalidMessageException(
@@ -1179,13 +1179,6 @@ async def _serve(
1179
case other:
1180
assert_never(other)
1181
1182
- # TODO: Delete me
1183
- logger.debug(
1184
- "[%s] got a message %r",
1185
- transport_id,
1186
- msg,
1187
- )
1188
-
1189
reset_session_close_countdown()
1190
1191
# Shortcut to avoid processing ack packets
0 commit comments