iterate method

@override Stream<AtNotification> iterate()

Iterate every notification entry. Used by the persistence migrator to copy notification content from one backend to another.

Implementation

@override
Stream<AtNotification> iterate() async* {
  final rows =
      _db.raw.select('SELECT payload FROM notifications ORDER BY id;');
  for (final r in rows) {
    yield SqliteNotificationCodec.decode(r['payload'] as String);
  }
}