Skip to content

Commit 3056704

Browse files
committed
Added debug statements
1 parent 313a56d commit 3056704

File tree

1 file changed

+9
-5
lines changed

1 file changed

+9
-5
lines changed

lf_toolkit/io/stream_io.py

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -84,23 +84,27 @@ async def _handle_client(self, client: StreamIO):
8484

8585
while True:
8686
try:
87+
import sys
88+
print("waiting for data...", file=sys.stderr, flush=True)
8789
data = await io.read(4096)
90+
print(f"got data: {data[:80]}", file=sys.stderr, flush=True)
8891

8992
if not data:
90-
# print("Received empty data")
9193
break
9294

95+
print("dispatching...", file=sys.stderr, flush=True)
9396
response = await self.dispatch(data.decode("utf-8"))
94-
print(f"Responding: {response}") # and this
97+
print(f"got response: {str(response)[:80]}", file=sys.stderr, flush=True)
9598

9699
await io.write(response.encode("utf-8"))
100+
print("wrote response", file=sys.stderr, flush=True)
97101
except anyio.EndOfStream:
98-
# print("Client disconnected")
99102
break
100103
except anyio.ClosedResourceError:
101-
# print("Client disconnected")
102104
break
103105
except Exception as e:
104-
# print(f"Exception: {e}")
106+
import traceback
107+
traceback.print_exc(file=sys.stderr)
105108
break
109+
106110
await client.close()

0 commit comments

Comments
 (0)