Skip to content

Conversation

@andrea-reale
Copy link
Member

@andrea-reale andrea-reale commented May 28, 2025

This is an attempt to make reading from the server stream faster, to see if there is a client bottleneck.
What this does is:

  • One tokio task (the main task), pulls items from the stream, no processing
  • We spawn one task per item and do the chunk conversion work, which I assumed could be expensive, and puts the results in a channel
  • Another task pulls the data from the channel, and adds the data to the stores map.

Related

This is an attempt to make reading from the server stream faster, to see
if there is a client bottleneck.
What this does is:
- One tokio task (the main task), pulls items from the stream, no
  processing
- We spawn one task per item and do the chunk conversion work, which I
  assumed could be expensive, and puts the results in a channel
- Another task pulls the data from the channel, and adds the data to the
  stores map.

Signed-off-by: Andrea Reale <andrea@rerun.io>
@andrea-reale andrea-reale added do-not-merge Do not merge this PR exclude from changelog PRs with this won't show up in CHANGELOG.md dataplatform Rerun Data Platform integration labels May 28, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

dataplatform Rerun Data Platform integration do-not-merge Do not merge this PR exclude from changelog PRs with this won't show up in CHANGELOG.md

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant