Commit 3a5158b
committed
refactor: Implement high-performance State Machine for flatMapLatest
- Replaces AsyncThrowingStream implementation with a custom AsyncSequence, Storage, and StateMachine.
- Implements explicit state management using Lock for thread safety.
- Handles concurrency between outer and inner sequences robustly.
- Ensures correct cancellation propagation and error handling.
- Verified with test_interleaving_race_condition.1 parent 4f74f31 commit 3a5158b
1 file changed
+659
-65
lines changed
0 commit comments