@@ -453,14 +453,19 @@ void main() {
453453
454454 // Start the renarrowAndFetch.
455455 final newNarrow = ChannelNarrow (channel.streamId);
456+ final newAnchor = NumericAnchor (messages[3 ].id);
457+
456458 final result = eg.getMessagesResult (
457- anchor: model.anchor, foundOldest: false , messages: messages);
459+ anchor: newAnchor,
460+ foundOldest: false , foundNewest: false ,
461+ messages: messages.sublist (3 , 5 ));
458462 connection.prepare (json: result.toJson (), delay: Duration (seconds: 1 ));
459- model.renarrowAndFetch (newNarrow);
463+ model.renarrowAndFetch (newNarrow, newAnchor );
460464 checkNotifiedOnce ();
461465 check (model)
462466 ..fetched.isFalse ()
463467 ..narrow.equals (newNarrow)
468+ ..anchor.equals (newAnchor)
464469 ..messages.isEmpty ();
465470
466471 // Elapse until the fetchOlder is done but renarrowAndFetch is still
@@ -476,7 +481,8 @@ void main() {
476481 check (model)
477482 ..fetched.isTrue ()
478483 ..narrow.equals (newNarrow)
479- ..messages.length.equals (100 );
484+ ..anchor.equals (newAnchor)
485+ ..messages.length.equals (2 );
480486 }));
481487 });
482488
@@ -3380,6 +3386,7 @@ extension MessageListMessageItemChecks on Subject<MessageListMessageItem> {
33803386extension MessageListViewChecks on Subject <MessageListView > {
33813387 Subject <PerAccountStore > get store => has ((x) => x.store, 'store' );
33823388 Subject <Narrow > get narrow => has ((x) => x.narrow, 'narrow' );
3389+ Subject <Anchor > get anchor => has ((x) => x.anchor, 'anchor' );
33833390 Subject <List <Message >> get messages => has ((x) => x.messages, 'messages' );
33843391 Subject <List <OutboxMessage >> get outboxMessages => has ((x) => x.outboxMessages, 'outboxMessages' );
33853392 Subject <int > get middleMessage => has ((x) => x.middleMessage, 'middleMessage' );
0 commit comments