Skip to content

Comments

Updates for fetch API change#156

Closed
RichLogan wants to merge 1 commit intosubgroupsfrom
updates-for-fetch
Closed

Updates for fetch API change#156
RichLogan wants to merge 1 commit intosubgroupsfrom
updates-for-fetch

Conversation

@RichLogan
Copy link
Contributor

Needs #155 + submodule rev.

@RichLogan RichLogan requested a review from TimEvens January 30, 2026 16:36
@RichLogan RichLogan marked this pull request as draft January 30, 2026 16:36
Copy link

@chatgpt-codex-connector chatgpt-codex-connector bot left a comment

Choose a reason for hiding this comment

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

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: 58def77a01

ℹ️ About Codex in GitHub

Codex has been enabled to automatically review pull requests in this repo. Reviews are triggered when you

  • Open a pull request for review
  • Mark a draft as ready
  • Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

When you sign up for Codex through ChatGPT, Codex can also answer questions or update the PR, like "@codex address that feedback".

Comment on lines 125 to 130
updated_data->insert(
updated_data->end(), data->begin() + (data->size() - stream_buffer_.Size()), data->end());
updated_data->end(), data->begin() + (data->size() - stream.buffer.Size()), data->end());

ForwardReceivedData(true, updated_data);
ForwardReceivedData(is_start, stream.current_group_id, stream.current_subgroup_id, updated_data);
} else {
ForwardReceivedData(is_start, data);
ForwardReceivedData(is_start, stream.current_group_id, stream.current_subgroup_id, data);

Choose a reason for hiding this comment

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

P1 Badge Forward new-stream data with correct group/subgroup

Here ForwardReceivedData() is called before stream.current_group_id/current_subgroup_id are populated from the parsed header. Since ForwardReceivedData now gates on SentFirstObject(group_id, subgroup_id), the first chunk of every new stream is forwarded with the default (0/0) IDs and gets skipped, so subscribers never see the is_new_stream event/stream header and later pipeline data arrives without an open stream. This is a regression introduced by the new per-group gating; set the group/subgroup from s_hdr before forwarding, or allow is_new_stream to bypass the SentFirstObject check.

Useful? React with 👍 / 👎.

@TimEvens TimEvens changed the base branch from main to subgroups February 3, 2026 19:46
@TimEvens
Copy link
Collaborator

TimEvens commented Feb 3, 2026

We were working on changes at the same time as #155. I have incorporated these changes into #155.

@RichLogan RichLogan closed this Feb 3, 2026
@TimEvens TimEvens deleted the updates-for-fetch branch February 4, 2026 17:06
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.

2 participants