Expand description
Linearizability/Isolation conformance: genuinely-overlapping writers and a
parked subscriber. Real overlap via tokio::spawn + Barrier (CLAUDE
rule 8 — never sequential-then-check).
Functions§
- check_
caught_ up_ boundary_ race - Appends racing the catch-up→live boundary are neither lost nor duplicated,
and
CaughtUpis still emitted exactly once. - check_
concurrent_ distinct_ streams_ all_ land - Overlapping appenders on DISTINCT streams never conflict; every event
lands;
$allholds all of them with strictly increasing positions. - check_
concurrent_ same_ stream_ single_ winner - N overlapping appenders race the same fresh stream with the same expectation: exactly ONE wins, every loser sees Conflict, and the store holds exactly the winner’s event.
- check_
wake_ after_ idle - Wake-after-idle: a subscriber parked at
CaughtUpis woken by a later append from another task — the lost-wakeup race the arm-before-rescan discipline exists to prevent.