Flutter安全流值处理插件safe_stream_value的使用

safe_stream_value 是一个用于在 Flutter 和 RxDart 中安全设置流控制器值的库。如果你有一个 StreamController 对象并关闭了它，然后尝试向其设置值，将会出现错误，表示你不能向已关闭的流设置值。该库的主要目的是检查流是否打开，并为你设置值。

使用方法

要使用此插件，你需要将其添加为 pubspec.yaml 文件中的依赖项：

dependencies:
  safe_stream_value: ^lastVersion

接下来，你可以像下面这样使用它：

import 'dart:async';
import 'package:flutter/material.dart';
import 'package:fluttertoast/fluttertoast.dart';
import 'package:rxdart/rxdart.dart';
import 'package:safe_stream_value/safe_stream_value.dart';

class Bloc {
  final _myBehaviorSubject = BehaviorSubject<String>();
  final _myStream = StreamController<String>();

  Stream<String> get myBehaviorSubject => _myBehaviorSubject.stream;
  Stream<String> get myStream => _myStream.stream;

  void doSomethingOnStreams() async {
    // 安全地设置值到 Behavior Subject
    _myBehaviorSubject.safeValue = 'Hello';
    // 等待一秒钟后
    await Future.delayed(const Duration(seconds: 1));
    // 安全地设置值到 Stream Controller
    _myStream.safeValue = 'World';
  }

  void dispose() {
    // 关闭 Behavior Subject
    _myBehaviorSubject.close();
    // 关闭 Stream Controller
    _myStream.close();
  }
}

class MyHomePage extends StatefulWidget {
  const MyHomePage({Key? key, required this.title}) : super(key: key);

  final String title;

  [@override](/user/override)
  State<MyHomePage> createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {
  late Bloc _bloc;
  int _counter = 0;

  [@override](/user/override)
  void initState() {
    // 初始化 Bloc
    _bloc = Bloc();
    // 监听 Bloc 的流
    _listenBlocStreams();
    super.initState();
  }

  [@override](/user/override)
  void dispose() {
    // 释放 Bloc 资源
    _bloc.dispose();
    super.dispose();
  }

  void _listenBlocStreams() {
    // 监听 Stream 并显示 Toast
    _bloc.myStream.listen((String value) {
      Fluttertoast.showToast(msg: value);
    });

    // 监听 Behavior Subject 并显示 Toast
    _bloc.myBehaviorSubject.listen((String value) {
      Fluttertoast.showToast(msg: value);
    });
  }

  void _incrementCounter() {
    // 执行 Bloc 中的方法
    _bloc.doSomethingOnStreams();
    // 更新计数器
    setState(() {
      _counter++;
    });
  }

  [@override](/user/override)
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text(widget.title),
      ),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: [
            const Text(
              'You have pushed the button this many times:',
            ),
            Text(
              '$_counter',
              style: Theme.of(context).textTheme.headline4,
            ),
          ],
        ),
      ),
      floatingActionButton: FloatingActionButton(
        onPressed: _incrementCounter,
        tooltip: 'Increment',
        child: const Icon(Icons.add),
      ),
    );
  }
}