Dart 颤动流停止和启动有条件吗？

Question

我想有条件地停止并重新启动流，我该怎么做？

_fireStore
.collection(...)
.doc(...)
.snapshots().takeWhile((element) => _listenable);

当 _listenable 为 false 时流停止，但当 true 时不重新启动？

有人知道该怎么做吗？

Answer 1

您可以使用 async 轻松控制流 这就是您可以做到的。

首先像这样创建一个 StreamSubsctiprion

StreamSubscription<QuerySnapshot>? _eventStream;

，然后为快照流设置一个侦听器。

这是如何存储流查询快照

 Stream<QuerySnapshot> streamSub =_fireStore
    .collection(...)
    .doc(...)
    .snapshots();

为您的流添加侦听器，如下所示

   _eventStream = streamSub.listen((snapshot) => _eventStream);

然后您可以使用事件流取消、暂停和恢复您的流，如下所示这

 _eventStream!.pause();
 _eventStream!.cancel();
 _eventStream!.resume();

是我的最终代码

class MainScreen extends State<PaymentScreen> {
  StreamSubscription<QuerySnapshot>? _eventStream;

  @override
  Widget build(BuildContext context) {
    Stream<QuerySnapshot> myStream = FirebaseFirestore.instance.collection('Users').snapshots();
    return Scaffold(
      body: Padding(
        padding: const EdgeInsets.symmetric(horizontal: 20),
        child: Column(
          mainAxisAlignment: MainAxisAlignment.end,
          children: [
            StreamBuilder<QuerySnapshot>(
              stream: myStream,
              builder: (BuildContext context,
                  AsyncSnapshot<QuerySnapshot> snapshot) {
                if (snapshot.hasError) {
                  return Text('Something went wrong');
                }

                if (snapshot.connectionState == ConnectionState.waiting) {
                  return Text("Loading");
                }

                return Column(
                  children:
                      snapshot.data!.docs.map((DocumentSnapshot document) {
                    Map<String, dynamic> data =
                        document.data()! as Map<String, dynamic>;
                    return ListTile(
                      title: Text(data['firstName']),
                    );
                  }).toList(),
                );
              },
            ),
            FloatingActionButton.extended(
              onPressed: () {
                _eventStream = myStream.listen((snapshot) => _eventStream);
                try {
                  _eventStream!.pause();
                  print('paused');
                } catch (e, s) {
                  print(s);
                }
              },
              label: const Text("Pause Stream"),
            ),
          ],
        ),
      ),
    );
  }
}