通过StreamBuilder监听Directory流时对象丢失问题求助

我来帮你排查这个问题——你遇到的“仅打印最后一个目录”的情况，核心是StreamBuilder的配置错误和不必要的中间StreamController导致的，咱们一步步拆解解决：

问题根源 #

1. 错误的initialData类型：你给StreamBuilder设置了initialData: 23，但你的流是FileSystemEntity类型，第一次build时snapshot.data是int类型，调用.path会直接抛出异常。这个异常会干扰后续数据流的处理，甚至可能让前面的打印被错误信息淹没，只留下最后一条正常输出。
2. 冗余的StreamController：你用了一个中间的_streamController转发internalStorage.list的流，这完全没必要，反而增加了复杂度，还可能因流订阅处理不当导致数据丢失。
3. StreamBuilder的错误处理缺失：代码里没有处理流的错误状态，一旦出现异常就会中断后续数据处理。

修复后的最简代码 #

我们可以去掉多余的StreamController，直接用Directory.list的流作为StreamBuilder的数据源，同时修正initialData的问题：

class _MediaFilesState extends State<MediaFiles> { 
  final Directory internalStorage = Directory('/storage/emulated/0/'); 
  final WatchlistDatabase watchlistDatabase = WatchlistDatabase(); 

  @override 
  void initState() { 
    super.initState(); 
    checkMediaPath(); 
    // 移除不必要的中间StreamController
  } 

  @override 
  void dispose() { 
    super.dispose(); 
    // 无需再关闭额外的StreamController
  } 

  @override 
  Widget build(BuildContext context) { 
    return Scaffold( 
      backgroundColor: const Color(0xFF131214), 
      appBar: AppBar(), 
      body: ListView( 
        children: <Widget>[ 
          Container(child: mediaFilesWidget), 
          SizedBox( 
            height: 400, 
            width: 250, 
            child: StreamBuilder<FileSystemEntity>( 
              // 直接使用Directory的list流，指定泛型更安全
              stream: internalStorage.list(recursive: false, followLinks: false), 
              // 移除错误的initialData，让流自然处理加载状态
              builder: (BuildContext context, AsyncSnapshot<FileSystemEntity> snapshot) { 
                // 先处理错误，避免异常中断流
                if (snapshot.hasError) { 
                  print('流处理出错: ${snapshot.error}'); 
                  return const Text('加载失败'); 
                } 

                // 处理加载中的状态
                if (snapshot.connectionState == ConnectionState.waiting) { 
                  return const CircularProgressIndicator(); 
                } 

                // 每次收到数据都会打印
                if (snapshot.hasData) { 
                  print(snapshot.data!.path); 
                } 

                // 这里可以替换成你需要的UI，比如展示目录列表
                return const CircularProgressIndicator(); 
              }, 
            ), 
          ) 
        ], 
      ), 
    ); 
  } 
}

额外优化：在UI中展示所有目录 #

如果你不仅想打印，还想在界面上展示所有目录，可以在State中维护一个列表来累积流数据：

class _MediaFilesState extends State<MediaFiles> { 
  final Directory internalStorage = Directory('/storage/emulated/0/'); 
  final WatchlistDatabase watchlistDatabase = WatchlistDatabase(); 
  final List<FileSystemEntity> _allEntities = [];

  @override 
  void initState() { 
    super.initState(); 
    checkMediaPath(); 
    // 订阅流来累积数据，同时打印每个路径
    internalStorage.list(recursive: false, followLinks: false).listen((entity) { 
      setState(() { 
        _allEntities.add(entity); 
      }); 
      print(entity.path); 
    }); 
  } 

  @override 
  Widget build(BuildContext context) { 
    return Scaffold( 
      backgroundColor: const Color(0xFF131214), 
      appBar: AppBar(), 
      body: ListView( 
        children: <Widget>[ 
          Container(child: mediaFilesWidget), 
          SizedBox( 
            height: 400, 
            width: 250, 
            child: _allEntities.isEmpty 
                ? const CircularProgressIndicator() 
                : ListView.builder( 
                    itemCount: _allEntities.length, 
                    itemBuilder: (context, index) { 
                      return Padding( 
                        padding: const EdgeInsets.all(8.0), 
                        child: Text( 
                          _allEntities[index].path, 
                          style: const TextStyle(color: Colors.white), 
                        ), 
                      ); 
                    }, 
                  ), 
          ) 
        ], 
      ), 
    ); 
  } 
}

为什么原来initState里的listen能正常工作？ #

因为你直接订阅了internalStorage.list的流，没有经过StreamBuilder的错误initialData干扰，每个数据都能被正常捕获并打印。而StreamBuilder因为初始数据类型不匹配抛出异常，要么掩盖了前面的打印信息，要么直接中断了流的处理，最终只留下最后一条数据的输出。

内容的提问来源于stack exchange，提问作者Nadeem Siddique