Repository navigation
v2.0.0
- BREAKING CHANGE: Replaced
concurrency, andisolatesparameters with strategy-based API - Added
IsolatedProcessingStrategypattern for better type safety and extensibility - Added
IsolatedProcessingStrategy.concurrent(),.droppable(),.restartable(),.sequential()factories - Improved broadcast stream handling with shared isolates across listeners
- Fixed concurrency tracking issues in isolate boundaries
- Enhanced lazy initialization for better resource management
Migration example:
// Before (v1.x)
stream.isolatedMap(handler, concurrency: 3, isolates: 2)// After (v2.x)
stream.isolatedMap(
handler,
strategy: IsolatedProcessingStrategy.concurrent(
concurrency: 3,
isolates: 2,
),
);