Flutter中Algolia搜索第二次调用时出现挂起问题求助

核心原因 #

你遇到的问题确实和Stream的订阅机制直接相关：

• await _searchPage.first会订阅_searchPage Stream，等待它发出第一个事件后结束订阅。
• 如果_searchPage是单订阅Stream（Dart默认的Stream类型），第一次订阅完成后Stream会自动关闭。第二次调用first时，因Stream已关闭无法再发出事件，代码会一直挂起等待。
• 另一种可能：第二次调用applyState更新搜索状态后，_searchPage Stream没有触发新的事件，导致first一直等待新数据。

解决思路 #

1. 将单订阅Stream转为广播Stream #

如果_searchPage是单订阅类型，把它转为广播Stream以支持多次订阅：

// 初始化_searchPage时转为广播Stream
final _searchPage = yourOriginalStream.asBroadcastStream();

注意：广播Stream不会缓存事件，需确保每次调用searchPosts时，applyState能立即触发_searchPage发出新的搜索结果事件。

2. 确保状态更新能触发Stream新事件 #

检查_postsSearcher的状态更新逻辑，确认调用applyState后，是否正确触发_searchPage Stream发射新的HitsPage数据：

• 确认_postsSearcher的状态变化是否和_searchPage的Stream发射绑定（比如通过BehaviorSubject或StreamController.add发送新数据）。
• 第二次调用applyState时，确认状态确实发生了变化（比如query、author等值有更新，或强制触发一次搜索请求）。

3. 优化订阅逻辑，避免重复等待 #

改用Completer配合订阅，确保每次搜索都能获取最新事件，同时避免内存泄漏：

Future<List<String>> searchPosts({
  required String author,
  required String title,
  required String content,
}) async {
  final completer = Completer<List<String>>();
  StreamSubscription? subscription;

  _postsSearcher.applyState(
    (state) => state.copyWith(
      query: content,
      page: 0,
      hitsPerPage: 1,
      facetFilters: [
        'author:$author',
        'title:$title',
      ],
    ),
  );

  subscription = _searchPage.listen((results) {
    final postIds = results.items.map((post) => post.postId).toList();
    completer.complete(postIds);
    subscription?.cancel(); // 完成后立即取消订阅
  }, onError: (error) {
    completer.completeError(error);
    subscription?.cancel();
  });

  return completer.future;
}

这种方式每次搜索都会创建新订阅，完成后立即取消，避免Stream关闭导致的挂起问题。

4. 检查Stream是否被意外关闭 #

确认_searchPage的StreamController是否在第一次搜索后被关闭。如果是，需确保StreamController保持打开状态，或每次搜索时重新创建Stream。

内容的提问来源于stack exchange，提问作者H S park