feat(pubsub): intra-process delivery hands the subscriber an Arc<T> - #340

Open

YuanYuYuan wants to merge 37 commits into

mainfrom

feat/publisher-locality

Commits on Sep 2, 2026

feat(pubsub): let a publisher restrict its locality
YuanYuYuan
committed
68919a5
feat(pubsub): prototype intra-process Arc<T> delivery without serialization
YuanYuYuan
committed
8b78e1f
perf(local_bus): resolve a publisher's channel once, not per message
YuanYuYuan
committed
827ef32
feat(zbuf): let a solely owned payload buffer be written in place
YuanYuYuan
committed
b240323
chore(deps): point the zenoh-buffers patch at the forge, not GitHub
YuanYuYuan
committed
40e7df8
chore(deps): pin the zenoh-buffers patch to a rev, not a branch
YuanYuYuan
committed
e4e9302
fix(pubsub): stop the bus swallowing same-session wire traffic
YuanYuYuan
committed
9baef40
perf(local_bus): take the locks and the refcounts off the publish path
YuanYuYuan
committed
8a772e7
feat(pubsub): ask the graph, and let a sole receiver own the message
YuanYuYuan
committed
302d5be
fix(pubsub): let the graph decide, for every publisher
YuanYuYuan
committed
a1f87b9
fix(pubsub): three ways a message was silently lost
YuanYuYuan
committed
c3c6685
fix(deps): stop requiring an unreleased zenoh-buffers to build
YuanYuYuan
committed
03284c6
fix(pubsub): the caller asserts the audience; the graph cannot
YuanYuYuan
committed
daf5df5
fix(local_bus): isolate a panicking subscriber, and route user code through the re-entrancy check
YuanYuYuan
committed
6867fb8
fix(pubsub): publish_owned lost every remote subscriber, and Published could not say why
YuanYuYuan
committed
02a13a1
fix(local_bus): make Delivery public, as Published now carries it
YuanYuYuan
committed
e336484
test: per-path detectors for the three routing defects
YuanYuYuan
committed
0f153a3
test: assert the outcome, not a count
YuanYuYuan
committed
a3d8478
fix(pubsub): serve owned subscribers on a Remote publisher
YuanYuYuan
committed
7294c53
refactor(pubsub): resolve the route once, and correct the stale docs
YuanYuYuan
committed
6ccb14c
docs(pubsub): reattach the shared-callback doc to its own method
YuanYuYuan
committed
4454fc5
style: cargo fmt --all
YuanYuYuan
committed
953a4a4
docs: fully qualify four intra-doc links
YuanYuYuan
committed
bdfdf62
refactor!: drop the pooled-payload feature and its ZBuf accessor
YuanYuYuan
committed
f164b2d
fix(pubsub): refuse a publish an owned subscriber cannot receive, and publish on the wire first
YuanYuYuan
committed
23ea748
fix(local_bus): re-raise the re-entrancy violation, count deliveries, reclaim channels
YuanYuYuan
committed
efa8430
fix: repair two bad insertions; document the guard's scope and the graph token
YuanYuYuan
committed
356747b
test: assert deliveries rather than invocations in the panic tests
YuanYuYuan
committed
f873263
docs(local_bus): repair a comment mangled by an earlier edit
YuanYuYuan
committed
05ebd82
fix(local_bus): the re-raise must not break a release build
YuanYuYuan
committed
3a57db0
fix(local_bus): unforgeable violation payload, and four routing/accounting fixes
YuanYuYuan
committed
d769c6e
fix: capture the subscriber locality before self is consumed
YuanYuYuan
committed
954df5b
fix(reentrancy): use non_exhaustive rather than a private unit field
YuanYuYuan
committed
fa5f15b
test(reentrancy): assert the violation by type, not by message
YuanYuYuan
committed
c1a9303
style(test): satisfy clippy on the hiroz-tests crate
YuanYuYuan
committed
95508f5
docs: drop internal tracker references from shipped source
YuanYuYuan
committed
6e2e5e1
style(test): name the subscriber type in publisher_locality
YuanYuYuan
committed
3397354