diff --git a/packages/comms/CHANGELOG.md b/packages/comms/CHANGELOG.md index cfd7d3d..e781b8f 100644 --- a/packages/comms/CHANGELOG.md +++ b/packages/comms/CHANGELOG.md @@ -1,3 +1,7 @@ +## 0.0.11 + +- Fix new dart compatibility issue + ## 0.0.10 - Fix one off messages getting buffered when there are active `Listener`s (#54) diff --git a/packages/comms/lib/src/message_sink_register.dart b/packages/comms/lib/src/message_sink_register.dart index 04eb07d..261dafe 100644 --- a/packages/comms/lib/src/message_sink_register.dart +++ b/packages/comms/lib/src/message_sink_register.dart @@ -36,7 +36,7 @@ class MessageSinkRegister { final _uuid = const Uuid(); /// All message sinks and their id's added with [_add]. - final _messageSinks = {}; + final _messageSinks = >{}; /// All last messages sent with each type final _messageBuffers = >{}; diff --git a/packages/comms/lib/src/multi_listener.dart b/packages/comms/lib/src/multi_listener.dart index b83d02c..0ca166e 100644 --- a/packages/comms/lib/src/multi_listener.dart +++ b/packages/comms/lib/src/multi_listener.dart @@ -5,12 +5,12 @@ part of '../comms.dart'; class ListenerDelegate with Listener { ListenerDelegate(); - late final OnMessage _onMessage; - late final OnMessage _onInitialMessage; + late final OnMessage _onMessage; + late final OnMessage _onInitialMessage; @protected @nonVirtual - void _init(OnMessage onMessage, OnMessage onInitialMessage) { + void _init(OnMessage onMessage, OnMessage onInitialMessage) { _onMessage = onMessage; _onInitialMessage = onInitialMessage; listen(); @@ -38,7 +38,7 @@ class ListenerDelegate with Listener { /// /// * [Listener], which enables listening to messages of single type. mixin MultiListener { - List get listenerDelegates; + List> get listenerDelegates; /// Starts message receiving. /// @@ -48,7 +48,7 @@ mixin MultiListener { @nonVirtual void listen() => listenerDelegates.forEach(_listen); - void _listen(ListenerDelegate listenerDelegate) => listenerDelegate + void _listen(ListenerDelegate listenerDelegate) => listenerDelegate .._init( onMessage, onInitialMessage, @@ -71,5 +71,6 @@ mixin MultiListener { @nonVirtual void cancel() => listenerDelegates.forEach(_cancel); - void _cancel(ListenerDelegate listenerDelegate) => listenerDelegate.cancel(); + void _cancel(ListenerDelegate listenerDelegate) => + listenerDelegate.cancel(); } diff --git a/packages/comms/pubspec.yaml b/packages/comms/pubspec.yaml index 1a6cb51..62f31a2 100644 --- a/packages/comms/pubspec.yaml +++ b/packages/comms/pubspec.yaml @@ -1,10 +1,10 @@ name: comms description: Simple communication pattern abstraction on streams, created for communication between logic classes. -version: 0.0.10 +version: 0.0.11 homepage: https://github.com/leancodepl/comms environment: - sdk: ">=2.17.0 <=3.0.0" + sdk: ">=2.17.0 <3.0.0" dependencies: logging: ^1.0.2 @@ -12,5 +12,5 @@ dependencies: uuid: ^3.0.6 dev_dependencies: - leancode_lint: ^2.1.0+1 + leancode_lint: ^3.0.0 test: ^1.16.4