@@ -1450,28 +1450,28 @@ void main() {
1450
1450
.deepEquals (expected..insertAll (0 , [101 , 103 , 105 ]));
1451
1451
1452
1452
// … and on MessageEvent.
1453
- await store.handleEvent (eg. messageEvent (
1454
- eg.streamMessage (id: 301 , stream: stream1, topic: 'A' ))) ;
1453
+ await store.addMessage (
1454
+ eg.streamMessage (id: 301 , stream: stream1, topic: 'A' ));
1455
1455
checkNotifiedOnce ();
1456
1456
check (model.messages.map ((m) => m.id)).deepEquals (expected..add (301 ));
1457
1457
1458
- await store.handleEvent (eg. messageEvent (
1459
- eg.streamMessage (id: 302 , stream: stream1, topic: 'B' ))) ;
1458
+ await store.addMessage (
1459
+ eg.streamMessage (id: 302 , stream: stream1, topic: 'B' ));
1460
1460
checkNotNotified ();
1461
1461
check (model.messages.map ((m) => m.id)).deepEquals (expected);
1462
1462
1463
- await store.handleEvent (eg. messageEvent (
1464
- eg.streamMessage (id: 303 , stream: stream2, topic: 'C' ))) ;
1463
+ await store.addMessage (
1464
+ eg.streamMessage (id: 303 , stream: stream2, topic: 'C' ));
1465
1465
checkNotifiedOnce ();
1466
1466
check (model.messages.map ((m) => m.id)).deepEquals (expected..add (303 ));
1467
1467
1468
- await store.handleEvent (eg. messageEvent (
1469
- eg.streamMessage (id: 304 , stream: stream2, topic: 'D' ))) ;
1468
+ await store.addMessage (
1469
+ eg.streamMessage (id: 304 , stream: stream2, topic: 'D' ));
1470
1470
checkNotNotified ();
1471
1471
check (model.messages.map ((m) => m.id)).deepEquals (expected);
1472
1472
1473
- await store.handleEvent (eg. messageEvent (
1474
- eg.dmMessage (id: 305 , from: eg.otherUser, to: [eg.selfUser]))) ;
1473
+ await store.addMessage (
1474
+ eg.dmMessage (id: 305 , from: eg.otherUser, to: [eg.selfUser]));
1475
1475
checkNotifiedOnce ();
1476
1476
check (model.messages.map ((m) => m.id)).deepEquals (expected..add (305 ));
1477
1477
});
@@ -1507,18 +1507,18 @@ void main() {
1507
1507
.deepEquals (expected..insertAll (0 , [101 , 102 ]));
1508
1508
1509
1509
// … and on MessageEvent.
1510
- await store.handleEvent (eg. messageEvent (
1511
- eg.streamMessage (id: 301 , stream: stream, topic: 'A' ))) ;
1510
+ await store.addMessage (
1511
+ eg.streamMessage (id: 301 , stream: stream, topic: 'A' ));
1512
1512
checkNotifiedOnce ();
1513
1513
check (model.messages.map ((m) => m.id)).deepEquals (expected..add (301 ));
1514
1514
1515
- await store.handleEvent (eg. messageEvent (
1516
- eg.streamMessage (id: 302 , stream: stream, topic: 'B' ))) ;
1515
+ await store.addMessage (
1516
+ eg.streamMessage (id: 302 , stream: stream, topic: 'B' ));
1517
1517
checkNotifiedOnce ();
1518
1518
check (model.messages.map ((m) => m.id)).deepEquals (expected..add (302 ));
1519
1519
1520
- await store.handleEvent (eg. messageEvent (
1521
- eg.streamMessage (id: 303 , stream: stream, topic: 'C' ))) ;
1520
+ await store.addMessage (
1521
+ eg.streamMessage (id: 303 , stream: stream, topic: 'C' ));
1522
1522
checkNotNotified ();
1523
1523
check (model.messages.map ((m) => m.id)).deepEquals (expected);
1524
1524
});
@@ -1549,8 +1549,8 @@ void main() {
1549
1549
.deepEquals (expected..insertAll (0 , [101 ]));
1550
1550
1551
1551
// … and on MessageEvent.
1552
- await store.handleEvent (eg. messageEvent (
1553
- eg.streamMessage (id: 301 , stream: stream, topic: 'A' ))) ;
1552
+ await store.addMessage (
1553
+ eg.streamMessage (id: 301 , stream: stream, topic: 'A' ));
1554
1554
checkNotifiedOnce ();
1555
1555
check (model.messages.map ((m) => m.id)).deepEquals (expected..add (301 ));
1556
1556
});
@@ -1589,7 +1589,7 @@ void main() {
1589
1589
// … and on MessageEvent.
1590
1590
final messages = getMessages (301 );
1591
1591
for (var i = 0 ; i < 3 ; i += 1 ) {
1592
- await store.handleEvent (eg. messageEvent ( messages[i]) );
1592
+ await store.addMessage ( messages[i]);
1593
1593
checkNotifiedOnce ();
1594
1594
check (model.messages.map ((m) => m.id)).deepEquals (expected..add (301 + i));
1595
1595
}
@@ -1627,7 +1627,7 @@ void main() {
1627
1627
// … and on MessageEvent.
1628
1628
final messages = getMessages (301 );
1629
1629
for (var i = 0 ; i < 2 ; i += 1 ) {
1630
- await store.handleEvent (eg. messageEvent ( messages[i]) );
1630
+ await store.addMessage ( messages[i]);
1631
1631
checkNotifiedOnce ();
1632
1632
check (model.messages.map ((m) => m.id)).deepEquals (expected..add (301 + i));
1633
1633
}
@@ -1718,11 +1718,11 @@ void main() {
1718
1718
checkNotified (count: 2 );
1719
1719
1720
1720
// Then test MessageEvent, where a new header is needed…
1721
- await store.handleEvent (eg. messageEvent ( streamMessage (13 ) ));
1721
+ await store.addMessage ( streamMessage (13 ));
1722
1722
checkNotifiedOnce ();
1723
1723
1724
1724
// … and where it's not.
1725
- await store.handleEvent (eg. messageEvent ( streamMessage (14 ) ));
1725
+ await store.addMessage ( streamMessage (14 ));
1726
1726
checkNotifiedOnce ();
1727
1727
1728
1728
// Then test UpdateMessageEvent edits, where a header is and remains needed…
0 commit comments