@@ -367,8 +367,7 @@ void main() {
367367 List .generate (30 , (i) => eg.streamMessage (stream: stream)));
368368
369369 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));
372371 checkNotifiedOnce ();
373372 check (model).messages.length.equals (31 );
374373 });
@@ -381,17 +380,15 @@ void main() {
381380
382381 check (model).messages.length.equals (30 );
383382 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));
386384 checkNotNotified ();
387385 check (model).messages.length.equals (30 );
388386 });
389387
390388 test ('MessageEvent, before fetch' , () async {
391389 final stream = eg.stream ();
392390 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));
395392 checkNotNotified ();
396393 check (model).fetched.isFalse ();
397394 });
@@ -1314,7 +1311,7 @@ void main() {
13141311 }
13151312
13161313 final message = eg.streamMessage (stream: stream, topic: 'hello' );
1317- await store.handleEvent ( MessageEvent (id : 0 , message: message) );
1314+ await store.addMessage ( message);
13181315
13191316 await store.handleEvent (
13201317 eg.reactionEvent (eg.unicodeEmojiReaction, ReactionOp .add, message.id));
@@ -1396,8 +1393,7 @@ void main() {
13961393 await prepare (narrow: ChannelNarrow (stream.streamId));
13971394 await prepareMessages (foundOldest: true , messages:
13981395 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));
14011397 checkNotifiedOnce ();
14021398 check (model).messages.length.equals (31 );
14031399
@@ -1644,8 +1640,7 @@ void main() {
16441640 await prepare (narrow: ChannelNarrow (stream.streamId));
16451641 await prepareMessages (foundOldest: true , messages: []);
16461642
1647- await store.handleEvent (MessageEvent (id: 0 ,
1648- message: eg.streamMessage (stream: stream)));
1643+ await store.addMessage (eg.streamMessage (stream: stream));
16491644 // Each [checkNotifiedOnce] call ensures there's been a [checkInvariants]
16501645 // call, where the [ContentNode] gets checked. The additional checks to
16511646 // make this test explicit.
@@ -1659,13 +1654,13 @@ void main() {
16591654 await prepare (narrow: ChannelNarrow (stream.streamId));
16601655 await prepareMessages (foundOldest: true , messages: []);
16611656
1662- await store.handleEvent ( MessageEvent (id : 0 , message : eg.streamMessage (
1657+ await store.addMessage ( eg.streamMessage (
16631658 stream: stream,
16641659 sender: eg.selfUser,
16651660 submessages: [
16661661 eg.submessage (senderId: eg.selfUser.userId,
16671662 content: eg.pollWidgetData (question: 'question' , options: ['A' ])),
1668- ]))) ;
1663+ ]));
16691664 // Each [checkNotifiedOnce] call ensures there's been a [checkInvariants]
16701665 // call, where the value of the [Poll] gets checked. The additional
16711666 // checks make this test explicit.
0 commit comments