@@ -360,37 +360,39 @@ void main() {
360360 });
361361 });
362362
363- test ('MessageEvent' , () async {
364- final stream = eg.stream ();
365- await prepare (narrow: ChannelNarrow (stream.streamId));
366- await prepareMessages (foundOldest: true , messages:
367- List .generate (30 , (i) => eg.streamMessage (stream: stream)));
363+ group ('MessageEvent' , () {
364+ test ('in narrow' , () async {
365+ final stream = eg.stream ();
366+ await prepare (narrow: ChannelNarrow (stream.streamId));
367+ await prepareMessages (foundOldest: true , messages:
368+ List .generate (30 , (i) => eg.streamMessage (stream: stream)));
368369
369- check (model).messages.length.equals (30 );
370- await store.addMessage (eg.streamMessage (stream: stream));
371- checkNotifiedOnce ();
372- check (model).messages.length.equals (31 );
373- });
370+ check (model).messages.length.equals (30 );
371+ await store.addMessage (eg.streamMessage (stream: stream));
372+ checkNotifiedOnce ();
373+ check (model).messages.length.equals (31 );
374+ });
374375
375- test ('MessageEvent, not in narrow' , () async {
376- final stream = eg.stream ();
377- await prepare (narrow: ChannelNarrow (stream.streamId));
378- await prepareMessages (foundOldest: true , messages:
379- List .generate (30 , (i) => eg.streamMessage (stream: stream)));
376+ test ('not in narrow' , () async {
377+ final stream = eg.stream ();
378+ await prepare (narrow: ChannelNarrow (stream.streamId));
379+ await prepareMessages (foundOldest: true , messages:
380+ List .generate (30 , (i) => eg.streamMessage (stream: stream)));
380381
381- check (model).messages.length.equals (30 );
382- final otherStream = eg.stream ();
383- await store.addMessage (eg.streamMessage (stream: otherStream));
384- checkNotNotified ();
385- check (model).messages.length.equals (30 );
386- });
382+ check (model).messages.length.equals (30 );
383+ final otherStream = eg.stream ();
384+ await store.addMessage (eg.streamMessage (stream: otherStream));
385+ checkNotNotified ();
386+ check (model).messages.length.equals (30 );
387+ });
387388
388- test ('MessageEvent, before fetch' , () async {
389- final stream = eg.stream ();
390- await prepare (narrow: ChannelNarrow (stream.streamId));
391- await store.addMessage (eg.streamMessage (stream: stream));
392- checkNotNotified ();
393- check (model).fetched.isFalse ();
389+ test ('before fetch' , () async {
390+ final stream = eg.stream ();
391+ await prepare (narrow: ChannelNarrow (stream.streamId));
392+ await store.addMessage (eg.streamMessage (stream: stream));
393+ checkNotNotified ();
394+ check (model).fetched.isFalse ();
395+ });
394396 });
395397
396398 group ('UserTopicEvent' , () {
0 commit comments