Flutter StreamSubscription不能暂停或停止。

Question

在我的Flutter应用中，StreamSubscription无法暂停或取消。当我调用cancel()如果它在启动之前开始，它会停止。如果我在启动后调用cancel()，它将不会停止。我正在使用Firestore快照监听器。以下是我的代码。 我尝试了不同的方法，但仍然无法正常工作。问题在于Firestore listener在加载数据后没有停止。

    StreamSubscription<QuerySnapshot> streamSubscription;

    @override
    void initState() {
    super.initState();
    
        print("Creating a streamSubscription...");
        streamSubscription =Firestore.collection("name").document("d1").collection("d1")
            .snapshots().listen((data){
                //It will display items
            }, onDone: () { // Not excecuting
                print("Task Done");
            }, onError: (error) {
                print("Some Error");
        });
         streamSubscription.cancel(); //It will work but cancel stream before loading
    }

    @override
    void dispose() {
     streamSubscription.cancel(); //Not working
    super.dispose();
    }

- Joe

---

stream.close() 应该改为 stream.cancel()，而 StreamSubscription 应该被称为 streamSubscription 或 subscription 而不是 stream，因为这很容易引起混淆，因为 Stream 是完全不同的东西。 - Günter Zöchbauer

在https://api.dartlang.org/stable/2.2.0/dart-async/StreamSubscription-class.html中没有`close()`，所以它不起作用并不奇怪。如果您收到错误消息，请将该错误消息与您的问题一起发布。 - Günter Zöchbauer

我已经编辑了我的问题。我正在使用'cancel()'而不是'close'。对于错误的发生，我很抱歉。 - Joe

@GünterZöchbauer 当我跳转到另一个页面时，监听器没有停止。它正在执行新页面并中断其他监听器。我在dispose()中添加了cancel，但它并没有取消执行新页面。 - Joe

让我们在聊天中继续这个讨论。 - Joe

Answer 1

当您推出新页面时，先前的页面仍然呈现，因此不会调用dispose()。

• 如何在Flutter中获取当前路由路径？

有时小部件不再呈现，但尚未调用dispose，这可能导致奇怪的错误消息。因此，如果使用dispose，添加此类检查也可能是一个好主意。

• https://docs.flutter.io/flutter/widgets/State/mounted.html

更改：

//It will display items

to

if(myIsCurrentRoute && mounted) {
  //It will display items
}

- Günter Zöchbauer

Answer 2

你没有将订阅分配给正确的变量。

注：Original Answer翻译成“最初的回答”

StreamSubscription<QuerySnapshot> subscription;

@override
void initState() {
super.initState();

    print("Creating a streamSubscription...");
    subscription=Firestore.collection("name").document("d1").collection("d1")
        .snapshots().listen((data){
            //It will display items
        }, onDone: () { // Not excecuting
            print("Task Done");
        }, onError: (error) {
            print("Some Error");
    });


     subscription.cancel(); //It will work but cancel stream before loading



}

@override
void dispose() {
 subscription.cancel(); //Not working
super.dispose();
}

- dshukertjr

---

这是我问题中的错误。我修改了我的问题。我将其分配给正确的变量。请再次检查问题并检查您的答案。 - Joe

@Joe 你尝试过检查dispose函数是否被调用了吗？在dispose函数内打印一些内容，看看它是否被调用了。 - dshukertjr

我已经尝试在 dispose() 中处理，我的 dispose() 能够正常工作，但是无法取消监听。在调用新屏幕之前，我也调用了 Navigator.push(context,MaterialPageRoute(builder: (context) => SecondScreen()));。 - Joe

有人能告诉我为什么这里 onDone 没有执行吗？ - Piyush Jain

Answer 3

我曾经遇到过同样的问题，后来发现流似乎会在取消之前继续监听一段时间，但是如果你进行调试，你会发现在调用 dispose 后它会停止监听。因此，Gunter's 的解决方案很好，因为如果挂载为 false，也就是说你的页面不存在了，你可以防止回调函数被调用。

- dcg