Skip to content

rust(feature): sift stream send api updates#519

Merged
tsift merged 9 commits into
mainfrom
rust/sift-stream-send-api-updates
Apr 1, 2026
Merged

rust(feature): sift stream send api updates#519
tsift merged 9 commits into
mainfrom
rust/sift-stream-send-api-updates

Conversation

@tsift
Copy link
Copy Markdown
Contributor

@tsift tsift commented Mar 30, 2026

Updates the sift_stream "send" APIs to have the following form:

  • async "send" : will await for space in underlying channels.
  • async "send_requests" : will await for space in underlying channels, accepting a batch of messages.
  • sync "try_send" : will return an error if there is no space available in the underlying channels.
  • sync "try_send_requests" : will return an error if there is no space available in the underlying channels, accepting a batch of messages.

Further, any messages not able to be send, either from a full or closed channel are returned to callers.

The python updates reflect the new API format of sift_stream, though at this time the Python return types do not allow for returning the messages back to the caller on failure -- this can be added in the future.

@tsift tsift requested review from nathan-sift and solidiquis March 30, 2026 22:46
@tsift tsift marked this pull request as ready for review March 30, 2026 22:46
Copy link
Copy Markdown
Contributor

@nathan-sift nathan-sift left a comment

Choose a reason for hiding this comment

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

I like this approach. Only one comment

Comment thread rust/crates/sift_stream/src/stream/mode/ingestion_config.rs
@tsift tsift requested a review from nathan-sift March 31, 2026 19:48
Copy link
Copy Markdown
Contributor

@nathan-sift nathan-sift left a comment

Choose a reason for hiding this comment

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

lgtm!

@solidiquis solidiquis changed the title Rust/sift stream send api updates rust(feature): sift stream send api updates Apr 1, 2026
@tsift tsift merged commit d52246d into main Apr 1, 2026
21 of 23 checks passed
@tsift tsift deleted the rust/sift-stream-send-api-updates branch April 1, 2026 18:48
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