'Future<dynamic>' 类型不是从 Firebase 获取数据的 'Stream<dynamic>' 类型的子类型

Question

我正在从 Firebase 存储和 Firestore 检索数据，以在列表中显示带有图标（如果项目是文件）或图像（如果是图像）的项目。问题是，如果我一次获得所有图像，它不会全部加载。它最多加载 20 个并且由于内存泄漏而崩溃。所以我的想法是做一个按时间获取 10 个元素的列表，当用户向下滚动到结果的底部时，它会加载更多的 10 个元素并随后加载。但是，我使用的是 Future builder，并且我无法在需要时更新列表并且问题仍然存在，所以现在，我正在尝试进入流并使用 StreamBuilder 显示以便能够动态更新列表。

这是我的控制器：

loadList(String submenu, [int limit]) async {
    var parts = submenu.split('/');
    var pathSlashless = parts[0].trim();
    var subPathSlashless = parts.sublist(1).join('/').trim();

    var snapshot = await _storage.ref().child("/${submenu}");
    var retorno = await snapshot.listAll();
    List<ItemLab> conteudo = [];

    if(subPathSlashless.isEmpty || subPathSlashless == null){
      retorno.prefixes.forEach((element) {
        conteudo.add(
          ItemLab(
            tipo: 'PASTA',
            elemento: element,
          ),
        );
      });
    }

    for(int i = 0; i < retorno.items.length ; i++){
      var url = await retorno.items[i].getDownloadURL();
      conteudo.add(
        ItemLab(
          tipo: 'FILE',
          elemento: retorno.items[i],
          imageUrl: url,
        ),
      );

      if(limit != null){
        if(conteudo.length > limit){
          hasMore = true;
          return Stream.value(conteudo);
        }else{
          hasMore = false;
          print("less than 9");
        }
      }
    }

    try {
      if(subPathSlashless.isNotEmpty){
        print(subPathSlashless);
        List items;
        await databaseReference
            .collection("lab_${pathSlashless}_url")
            .snapshots().forEach((element) {
              element.docs.forEach((f) {
                if(f.data()['videos'] != null){
                    items == null ? items = f.data()['videos'] :
                    items.addAll(f.data()['videos']);
                  };
                  print("ITEMS :::: >>> ${items}");
              });
        });


        for(int i = 0; i < items.length; i ++){
          //print(items[i]);
          conteudo.add(
            ItemLab(
              tipo: 'VIDEO',
              elemento: null,
              video: items[i],
            ),
          );
        }

      }else{
        await databaseReference
            .collection("lab_${pathSlashless}_url")
            .snapshots().forEach((element) {
          element.docs.forEach((f) {
            if(f.data().isNotEmpty){
              print(f.data());
              if(f.data().keys.contains("videos")){
                conteudo.add(
                  ItemLab(
                      tipo: 'PASTA',
                      pastaVideo: findFolderName(f.reference.path)
                  ),
                );
              }else{
                conteudo.add(
                  ItemLab(
                    tipo: 'VIDEO',
                    elemento: null,
                    video: f.data(),
                  ),
                );
              }
            }
          });
        });
      }


    }catch(e){
      print(e);
    }

    pathSlashless = null;
    subPathSlashless = null;
    conteudo = checkDuplicateFolder(conteudo, submenu);
    return Stream.value(conteudo);
  }

这里是我的清单：

return StreamBuilder(
      stream: ctrl.loadList(submenu),
      builder: (ctx, snapshot) {

但是，如果我运行这段代码，它会抛出这个错误：

类型“未来”不是类型“流”的子类型

我该如何处理才能使用流而不是 Future 动态更新列表

Answer 1

你不能等待.snapshots()，因为它返回流，你可以改变它来获取。还可以了解更多关于flutter firebase实时和正常用例的信息，查看flutter fire docs

loadList(String submenu, [int limit]) async {
    var parts = submenu.split('/');
    var pathSlashless = parts[0].trim();
    var subPathSlashless = parts.sublist(1).join('/').trim();

    var snapshot = await _storage.ref().child("/${submenu}");
    var retorno = await snapshot.listAll();
    List<ItemLab> conteudo = [];

    if(subPathSlashless.isEmpty || subPathSlashless == null){
      retorno.prefixes.forEach((element) {
        conteudo.add(
          ItemLab(
            tipo: 'PASTA',
            elemento: element,
          ),
        );
      });
    }

    for(int i = 0; i < retorno.items.length ; i++){
      var url = await retorno.items[i].getDownloadURL();
      conteudo.add(
        ItemLab(
          tipo: 'FILE',
          elemento: retorno.items[i],
          imageUrl: url,
        ),
      );

      if(limit != null){
        if(conteudo.length > limit){
          hasMore = true;
          return Stream.value(conteudo);
        }else{
          hasMore = false;
          print("less than 9");
        }
      }
    }

    try {
      if(subPathSlashless.isNotEmpty){
        print(subPathSlashless);
        List items;
        (await databaseReference
            .collection("lab_${pathSlashless}_url")
            .get()).docs.forEach((f) {
                if(f.data()['videos'] != null){
                    items == null ? items = f.data()['videos'] :
                    items.addAll(f.data()['videos']);
                  };
                  print("ITEMS :::: >>> ${items}");
              });


        for(int i = 0; i < items.length; i ++){
          //print(items[i]);
          conteudo.add(
            ItemLab(
              tipo: 'VIDEO',
              elemento: null,
              video: items[i],
            ),
          );
        }

      }else{
        (await databaseReference
            .collection("lab_${pathSlashless}_url")
            .get()).docs.forEach((f) {
            if(f.data().isNotEmpty){
              print(f.data());
              if(f.data().keys.contains("videos")){
                conteudo.add(
                  ItemLab(
                      tipo: 'PASTA',
                      pastaVideo: findFolderName(f.reference.path)
                  ),
                );
              }else{
                conteudo.add(
                  ItemLab(
                    tipo: 'VIDEO',
                    elemento: null,
                    video: f.data(),
                  ),
                );
              }
            }
          });
      }


    }catch(e){
      print(e);
    }

    pathSlashless = null;
    subPathSlashless = null;
    conteudo = checkDuplicateFolder(conteudo, submenu);
    return conteudo;
  }

还有名单

return FutureBuilder(
      future: ctrl.loadList(submenu),
      builder: (ctx, snapshot) {