getAllStream method

Implementation

@override
Stream<T> getAllStream() async* {
  final uniqueFieldId = _adapter.getUniqueFieldId();
  for (var meta in _indexDB.records) {
    // skip
    if (meta.uniqueFieldId != uniqueFieldId) continue;

    final jsonDataBytes = await meta.readData(_indexDB.readRaf);
    final map = _adapter.fromJson(_adapter.decodeRecord(jsonDataBytes));
    yield _adapter.fromMap(map);
  }
}