@@ -360,37 +360,39 @@ void main() {
360
360
});
361
361
});
362
362
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)));
368
369
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
+ });
374
375
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)));
380
381
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
+ });
387
388
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
+ });
394
396
});
395
397
396
398
group ('UserTopicEvent' , () {
0 commit comments