feat(funnel): add ObservationFunnel read-side listener mechanism - #131

Merged

Bre77 merged 7 commits into

mainfrom

fm/pytfa-stream-router-slice1

Aug 22, 2026

Commits on Aug 22, 2026

feat(router): add StreamRouter, a read router that never polls
Bre77
committed
613cd7e
fix(router): ignore observations from an unhealthy source
Bre77
committed
e758ab4
fix(router): rank only eligible sources and correct announced availability
Bre77
committed
7361fe3
no-mistakes(document): docs(router): fix stale __init__ docstring for StreamRouter
Bre77
committed
d96fc8e
fix(router): anchor grace to source loss, not to the last observation
Bre77
committed
e4622f4
no-mistakes(review): {"summary": "fix(router): guard availability dispatch reentrancy and demand double-unsubscribe"}
Bre77
committed
15e3114
refactor(funnel): replace StreamRouter with a many-to-one ObservationFunnel
Bre77
committed
74d3108