anchor.diff:            'dateTime': Timestamp.fromDateTime(DateTime.utc(2014))
           });
         });
  -      results = await store.query(finder: finder).onSnapshots(db).first;
  -      expect(results.map((e) => e.key), [4, 1]);
  +      await expectQueryAndFirstSnapshotKeys(finder, [4, 1]);
         await record2
             .put(db, {'dateTime': Timestamp.fromDateTime(DateTime.utc(2017))});
  -      results = await store.query(finder: finder).onSnapshots(db).first;
  -      expect(results.map((e) => e.key), [3, 4]);
  +      await expectQueryAndFirstSnapshotKeys(finder, [3, 4]);
  +
  +      await db.transaction((txn) async {
  +        await record1.delete(txn);
  +        await record3.delete(txn);
  +      });
  +      await expectQueryAndFirstSnapshotKeys(finder, [4]);
         expect(results1.map((e) => e.map((e) => e.key).toList()).toList(), [
           [],
           [3],
           [4, 1],
           [3, 4],
  +        [4],
         ]);
         await subscription.cancel();
       });
  
positive.code:       expect((await query.getSnapshots(db)).map((snapshot) => snapshot.key),
            [1, 2]);
        expect((await query.getSnapshot(db)).key, 1);
        query = store.query(
            finder: Finder(filter: Filter.equals(Field.value, 'test2')));
        expect(
            (await query.getSnapshots(db)).map((snapshot) => snapshot.key), [2]);
        expect((await query.getSnapshot(db)).key, 2);
        query = store.query(
            finder: Finder(filter: Filter.equals(Field.value, 'test3')));
        expect(
            (await query.getSnapshots(db)).map((snapshot) => snapshot.key), []);
        expect((await query.getSnapshot(db)), isNull);
  
negative.code:     });
  
      test('onSnapshots 2 records sort order end', () async {
        var store = StoreRef<int, String>.main();
        var record1 = store.record(1);
        var record2 = store.record(2);
  