getAllStream method

Stream<T> getAllStream({
  1. int? parentId,
})

Read All Stream Box<T>

Implementation

Stream<T> getAllStream({int? parentId}) async* {
  final raf = await _indexedDB.openReadRaf();
  for (var meta in _indexedDB.getAll(parentId: parentId)) {
    if (meta.adapterTypeId != -1 &&
        meta.adapterTypeId != _adapter.adapterTypeId) {
      continue;
    }
    final data = await meta.getData(raf);
    final map = _adapter.fromJson(_adapter.decompress(data));
    yield _adapter.fromMap(map);
  }
  await raf.close();
}