fix(pubsub): stop running subscriber callbacks on the publishing thread - #250

Open

YuanYuYuan wants to merge 22 commits into

mainfrom

pr/2-pubsub-reentrancy

Commits on Aug 14, 2026

fix(pubsub): stop running subscriber callbacks on the publishing thread
YuanYuYuan
committed
4d506c9
fix(pubsub): guard the raw publish path and stop mislabelling drops
YuanYuYuan
committed
ccac95f
revert(tests): drop the FFI raw-publish test and its feature
YuanYuYuan
committed
9e6b2ed
fix(py,pubsub): unblock teardown -- GIL deadlock and unbounded drop
YuanYuYuan
committed
709e465
test(ros): fail the interop job when it runs no tests
YuanYuYuan
committed
3cd795f
style: wrap two long assert! calls in the queue tests
YuanYuYuan
committed
193076c
test(pubsub): pin the async publish path's local-publish guard
YuanYuYuan
committed
486d68f
refactor: split the CI gate and the zero-copy callback out
YuanYuYuan
committed
211cae3
fix(pubsub): stop giving queue-mode TransientLocal subs a dispatcher
YuanYuYuan
committed
5151a3a
fix(pubsub): box both dispatcher-callback arms to a common type
YuanYuYuan
committed
e278884
fix(ffi): update the raw subscriber for Option<CallbackDispatcher>
YuanYuYuan
committed
2aac599
fix(ci): stop reverting #271's interop-output fix
YuanYuYuan
committed
c9a1940
fix(pubsub): bound the advanced dispatch queue at the history depth
YuanYuYuan
committed
1c8e360
Revert "fix(pubsub): bound the advanced dispatch queue at the history depth"
YuanYuYuan
committed
5f4a0c1
Reapply "fix(pubsub): bound the advanced dispatch queue at the history depth"
YuanYuYuan
committed
c6ef483
test(pubsub): assert delivery ordering, not completeness, on the bounded path
YuanYuYuan
committed
3aff1ae
fix(node): bound the FFI advanced dispatch queue too
YuanYuYuan
committed
d2fbb84
docs(pubsub): correct why the FFI arm's wrong constant was missed
YuanYuYuan
committed
e7e28bb
docs(pubsub): apply simplified technical english to the dispatcher docs
YuanYuYuan
committed
d6d0f2d
docs: apply ste sentence rules to added comments
YuanYuYuan
committed
6865ced
fix(pubsub): disclose the teardown block and pin the gating decision
YuanYuYuan
committed
f724a0a
docs(pubsub): state the drop-order obligation on Plain too
YuanYuYuan
committed
5aa7e38

Navigation Menu

Uh oh!

fix(pubsub): stop running subscriber callbacks on the publishing thread - #250

fix(pubsub): stop running subscriber callbacks on the publishing thread#250
YuanYuYuan wants to merge 22 commits into
mainfrom
pr/2-pubsub-reentrancy

Commits on Aug 14, 2026

fix(pubsub): stop running subscriber callbacks on the publishing thread

fix(pubsub): guard the raw publish path and stop mislabelling drops

revert(tests): drop the FFI raw-publish test and its feature

fix(py,pubsub): unblock teardown -- GIL deadlock and unbounded drop

test(ros): fail the interop job when it runs no tests

style: wrap two long assert! calls in the queue tests

test(pubsub): pin the async publish path's local-publish guard

refactor: split the CI gate and the zero-copy callback out

fix(pubsub): stop giving queue-mode TransientLocal subs a dispatcher

fix(pubsub): box both dispatcher-callback arms to a common type

fix(ffi): update the raw subscriber for Option<CallbackDispatcher>

fix(ci): stop reverting #271's interop-output fix

fix(pubsub): bound the advanced dispatch queue at the history depth

Revert "fix(pubsub): bound the advanced dispatch queue at the history depth"

Reapply "fix(pubsub): bound the advanced dispatch queue at the history depth"

test(pubsub): assert delivery ordering, not completeness, on the bounded path

fix(node): bound the FFI advanced dispatch queue too

docs(pubsub): correct why the FFI arm's wrong constant was missed

docs(pubsub): apply simplified technical english to the dispatcher docs

docs: apply ste sentence rules to added comments

fix(pubsub): disclose the teardown block and pin the gating decision

docs(pubsub): state the drop-order obligation on Plain too