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

Question

我正在从 Firebase Storage 和 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) {

但是，如果我 运行 此代码会抛出此错误：

type 'Future' is not a subtype of type 'Stream'

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

Answer 1

你不能等待 .snapshots()，因为它 returns 流，你可以改变它来获取。还可以了解有关 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) {