Skip to content

Conversation

@longcw
Copy link
Contributor

@longcw longcw commented Feb 25, 2025

No description provided.

@longcw longcw requested a review from lukasIO February 25, 2025 08:08
if cb.send_stream_chunk.error:
raise ConnectionError(cb.send_stream_trailer.error)

self._closed = True
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think we should set self._closed = True already in the aclose method before awaiting sending of the trailer

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

and therefore also move the self._closed check into the aclose method

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

yeah, makes sense

@longcw longcw requested a review from lukasIO February 25, 2025 11:05
@longcw longcw merged commit 361f1ea into main Feb 25, 2025
12 checks passed
@longcw longcw deleted the longc/check-stream-closed branch February 25, 2025 13:10
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants