stream_core 0.4.0

stream_core: ^0.4.0 copied to clipboard

💥 BREAKING CHANGES #

• SharedEmitter and StateEmitter now implement Stream<T> directly instead of exposing a stream getter
• Removed stream getter from SharedEmitter and StateEmitter

✨ Features #

• Added hasListener and isClosed properties to SharedEmitter
• Added asSharedEmitter() and asStateEmitter() extension methods for read-only views
• Added update, getAndUpdate, updateAndGet extension methods on MutableStateEmitter
• Added StreamEvent base interface and EventResolver for event transformation

✨ Features #

• Added partition method for splitting lists into two based on a filter condition
• Added compare parameter to updateWhere for optional sorting after updates

✨ Features #

• Added location-based filtering support with LocationCoordinate, Distance, CircularRegion, and BoundingBox
• Added insertAt parameter to upsert for controlling insertion position of new elements

✨ Features #

• Added updateWhere method for updating elements matching a filter condition
• Added batchReplace method for replacing multiple elements based on matching keys
• Added insertUnique method for inserting elements ensuring uniqueness by key with optional sorting
• Added update parameter to upsert for custom merge logic when replacing existing elements
• Added update parameter to batchReplace for custom merge logic
• Added update parameter to sortedUpsert for custom merge logic when replacing existing elements

🐛 Bug Fixes #

• Fixed StreamDioException.toClientException() not handling invalid JSON strings gracefully

💥 BREAKING CHANGES #

• FilterField now requires a value getter function Object? Function(T)
• Filter classes renamed (e.g., EqualOperator → Equal, AndOperator → And)
• Filter signature changed to Filter<T extends Object>

✨ Features #

• Added matches(T other) method for client-side filtering with PostgreSQL-like semantics
• Added utility functions for deep equality, subset containment, and type-safe comparisons
• Enhanced Sort comparator to handle incompatible types safely

💥 BREAKING CHANGES #

• Renamed AppLifecycleStateProvider to LifecycleStateProvider and AppLifecycleState to LifecycleState

✨ Features #

• Added keepConnectionAliveInBackground option to ConnectionRecoveryHandler
• Added unknown state to NetworkState and LifecycleState enums

🐛 Bug Fixes #

• Fixed onClose() not being called when disconnecting during connecting state
• Fixed unnecessary reconnection attempts when network is offline
• Fixed existing connections not being closed before opening new ones

• Initial release