@@ -498,6 +498,9 @@ void main() {
498498 });
499499
500500 group ('reconcileMessages' , () {
501+ Condition <Object ?> conditionIdentical <T >(T element) =>
502+ (it) => it.identicalTo (element);
503+
501504 test ('from empty' , () async {
502505 await prepare ();
503506 check (store.messages).isEmpty ();
@@ -507,8 +510,7 @@ void main() {
507510 final messages = < Message > [message1, message2, message3];
508511 store.reconcileMessages (messages);
509512 check (messages).deepEquals (
510- [message1, message2, message3]
511- .map ((m) => (Subject <Object ?> it) => it.identicalTo (m)));
513+ [message1, message2, message3].map (conditionIdentical));
512514 check (store.messages).deepEquals ({
513515 for (final m in messages) m.id: m,
514516 });
@@ -524,8 +526,7 @@ void main() {
524526 final newMessage = eg.streamMessage ();
525527 store.reconcileMessages ([newMessage]);
526528 check (messages).deepEquals (
527- [message1, message2, message3]
528- .map ((m) => (Subject <Object ?> it) => it.identicalTo (m)));
529+ [message1, message2, message3].map (conditionIdentical));
529530 check (store.messages).deepEquals ({
530531 for (final m in messages) m.id: m,
531532 newMessage.id: newMessage,
@@ -540,7 +541,9 @@ void main() {
540541 final newMessage = eg.streamMessage (id: 1 , content: '<p>bar</p>' );
541542 final messages = [newMessage];
542543 store.reconcileMessages (messages);
543- check (messages).single.identicalTo (message);
544+ check (messages).deepEquals (
545+ // (We'll check more messages in an upcoming commit.)
546+ [message].map (conditionIdentical));
544547 check (store.messages).deepEquals ({1 : message});
545548 });
546549
0 commit comments