drainStream previously hung when the server closed the connection before emitting end, and had no coverage for terminal stream states (already errored/ended/closed) that create race conditions if encountered before listeners are attached.

Changes

• stream.ts: Split into two functions:
  • drainStream(stream) — simplified public API (no context), exported from package entrypoint; adds early-exit guards for errored, readableEnded, and closed states; resolves on close event to handle server-side connection teardown before end
  • drainStreamInternal(ctx, stream) — internal variant used by node_base_connection.ts; same logic plus TRACE-level logging of chunk counts, byte totals, and drain duration
• node_base_connection.ts: Switched all call sites from drainStream to drainStreamInternal
• node_stream.test.ts / node_stream_internal.test.ts: New unit test suites covering normal end, already-ended, already-errored, live error, thrown error, and already-closed stream states for both functions

Checklist

• Unit and integration tests covering the common scenarios were added
• A human-readable description of the changes was provided to include in CHANGELOG
• For significant changes, documentation in https://github.com/ClickHouse/clickhouse-docs was updated with further explanations or tutorials

✨ Let Copilot coding agent set things up for you — coding agent works faster and does higher quality work when set up for your repo.