-
Notifications
You must be signed in to change notification settings - Fork 7.9k
Implement GH-8641: [Stream] STREAM_NOTIFY_COMPLETED over HTTP never emitted #10505
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
736e3fc
to
b3c23c2
Compare
Right... So the new test is failing because I didn't include my other PR fix in here... I'll wait until that other PR gets merged and keep this on draft for now, and then rebase it later. |
…r emitted This adds support for the completed event. Since the read handler could be entered twice towards the end of the stream we remember what the eof flag was before reading so we can emit the completed event when the flag changes to true.
I rebased this now that the PR this depends on has been merged. I think this is ready for review now. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think it looks reasonable. Just some minor comments.
Thx for the review, addressed the review comments and asked one question on one of your review comments. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I just went again through all the logic and all looks good to me.
Closes GH-8641
This adds support for the completed event. Since the read handler could
be entered twice towards the end of the stream we remember what the eof
flag was before reading so we can emit the completed event when the flag
changes to true.
Please note that this depends on the fix in #10492 , otherwise this PR won't work properly.