[Rust] Add multiplexed stream builder - #818
Open
danilonajkov-db wants to merge 3 commits into
Open
danilonajkov-db wants to merge 3 commits into
danilonajkov-db wants to merge 3 commits into
Conversation
danilonajkov-db
force-pushed
the
effort/mux-streams-streambuilder
branch
from
September 2, 2026 13:23
c901de4 to
d121baa
Compare
danilonajkov-db
changed the base branch from
main
to
effort/mux-stream-lifecycle-hardening
September 17, 2026 10:31
Base automatically changed from
effort/mux-stream-lifecycle-hardening
to
main
September 17, 2026 12:30
danilonajkov-db
force-pushed
the
effort/mux-streams-streambuilder
branch
2 times, most recently
from
September 17, 2026 14:56
f8b6aef to
04ae050
Compare
danilonajkov-db
marked this pull request as ready for review
September 17, 2026 14:56
Signed-off-by: danilo-najkov-db <danilo.najkov@databricks.com>
danilonajkov-db
force-pushed
the
effort/mux-streams-streambuilder
branch
2 times, most recently
from
September 17, 2026 16:30
b3a21ad to
ee00d55
Compare
Signed-off-by: danilo-najkov-db <danilo.najkov@databricks.com>
danilonajkov-db
force-pushed
the
effort/mux-streams-streambuilder
branch
from
September 17, 2026 16:37
ee00d55 to
bf0ea41
Compare
Signed-off-by: danilo-najkov-db <danilo.najkov@databricks.com>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
Builds on the lifecycle hardening merged in #826.
StreamBuilder::multiplexed(n)(Beta) for JSON, compiled protobuf, and dynamic protobuf, available with default features.connection_per_stream(true)creates dedicated transports andfalseretains shared-channel behavior.ack_callback(...)and provide a separatemultiplexed_ack_callback(...)usingMessageId. Validate callback/format mismatches before opening connections.MultiplexedStream::newconstructor.Use multiplexing when one gRPC stream limits throughput and global ordering is unnecessary.
Validation
make test— workspace tests, all-feature/default-feature SDK tests, doctests, and all-feature JNI testsmake lint— full repository Clippy matrix with warnings deniedcargo check --offline --locked -p rust-examples-proto --example proto_compiled_multiplexedcargo fmt --all --checkandgit diff --checkrand 0.9resolutionFocused regressions cover callback-mode validation, lane-count/capacity validation, Avro rejection, cancelled construction, and dedicated versus shared mux connections.