@@ -367,8 +367,7 @@ void main() {
367
367
List .generate (30 , (i) => eg.streamMessage (stream: stream)));
368
368
369
369
check (model).messages.length.equals (30 );
370
- await store.handleEvent (MessageEvent (id: 0 ,
371
- message: eg.streamMessage (stream: stream)));
370
+ await store.addMessage (eg.streamMessage (stream: stream));
372
371
checkNotifiedOnce ();
373
372
check (model).messages.length.equals (31 );
374
373
});
@@ -381,17 +380,15 @@ void main() {
381
380
382
381
check (model).messages.length.equals (30 );
383
382
final otherStream = eg.stream ();
384
- await store.handleEvent (MessageEvent (id: 0 ,
385
- message: eg.streamMessage (stream: otherStream)));
383
+ await store.addMessage (eg.streamMessage (stream: otherStream));
386
384
checkNotNotified ();
387
385
check (model).messages.length.equals (30 );
388
386
});
389
387
390
388
test ('MessageEvent, before fetch' , () async {
391
389
final stream = eg.stream ();
392
390
await prepare (narrow: ChannelNarrow (stream.streamId));
393
- await store.handleEvent (MessageEvent (id: 0 ,
394
- message: eg.streamMessage (stream: stream)));
391
+ await store.addMessage (eg.streamMessage (stream: stream));
395
392
checkNotNotified ();
396
393
check (model).fetched.isFalse ();
397
394
});
@@ -1314,7 +1311,7 @@ void main() {
1314
1311
}
1315
1312
1316
1313
final message = eg.streamMessage (stream: stream, topic: 'hello' );
1317
- await store.handleEvent ( MessageEvent (id : 0 , message: message) );
1314
+ await store.addMessage ( message);
1318
1315
1319
1316
await store.handleEvent (
1320
1317
eg.reactionEvent (eg.unicodeEmojiReaction, ReactionOp .add, message.id));
@@ -1396,8 +1393,7 @@ void main() {
1396
1393
await prepare (narrow: ChannelNarrow (stream.streamId));
1397
1394
await prepareMessages (foundOldest: true , messages:
1398
1395
List .generate (30 , (i) => eg.streamMessage (stream: stream)));
1399
- await store.handleEvent (MessageEvent (id: 0 ,
1400
- message: eg.streamMessage (stream: stream)));
1396
+ await store.addMessage (eg.streamMessage (stream: stream));
1401
1397
checkNotifiedOnce ();
1402
1398
check (model).messages.length.equals (31 );
1403
1399
@@ -1644,8 +1640,7 @@ void main() {
1644
1640
await prepare (narrow: ChannelNarrow (stream.streamId));
1645
1641
await prepareMessages (foundOldest: true , messages: []);
1646
1642
1647
- await store.handleEvent (MessageEvent (id: 0 ,
1648
- message: eg.streamMessage (stream: stream)));
1643
+ await store.addMessage (eg.streamMessage (stream: stream));
1649
1644
// Each [checkNotifiedOnce] call ensures there's been a [checkInvariants]
1650
1645
// call, where the [ContentNode] gets checked. The additional checks to
1651
1646
// make this test explicit.
@@ -1659,13 +1654,13 @@ void main() {
1659
1654
await prepare (narrow: ChannelNarrow (stream.streamId));
1660
1655
await prepareMessages (foundOldest: true , messages: []);
1661
1656
1662
- await store.handleEvent ( MessageEvent (id : 0 , message : eg.streamMessage (
1657
+ await store.addMessage ( eg.streamMessage (
1663
1658
stream: stream,
1664
1659
sender: eg.selfUser,
1665
1660
submessages: [
1666
1661
eg.submessage (senderId: eg.selfUser.userId,
1667
1662
content: eg.pollWidgetData (question: 'question' , options: ['A' ])),
1668
- ]))) ;
1663
+ ]));
1669
1664
// Each [checkNotifiedOnce] call ensures there's been a [checkInvariants]
1670
1665
// call, where the value of the [Poll] gets checked. The additional
1671
1666
// checks make this test explicit.
0 commit comments