bloc_generic_streams 是一个用于 Flutter 的插件，它提供了一种更灵活的方式来管理流（Stream）和状态，特别是在使用 BLoC（Business Logic Component）模式时。这个插件允许你使用泛型来定义流，从而减少重复代码并提高代码的可维护性。

安装

首先，你需要在 pubspec.yaml 文件中添加 bloc_generic_streams 依赖：

dependencies:
  flutter:
    sdk: flutter
  bloc_generic_streams: ^0.1.0

然后运行 flutter pub get 来安装依赖。

基本用法

bloc_generic_streams 提供了一个 GenericStream 类，它允许你使用泛型来定义流。你可以通过 GenericStream 来管理状态，并在 UI 中监听这些状态的变化。

1. 创建 BLoC

首先，创建一个 BLoC 类，并使用 GenericStream 来管理状态。

import 'package:bloc_generic_streams/bloc_generic_streams.dart';

class CounterBloc {
  // 使用 GenericStream 来管理一个整数状态
  final GenericStream<int> _counterStream = GenericStream<int>(initialValue: 0);

  // 暴露流给外部使用
  Stream<int> get counterStream => _counterStream.stream;

  // 增加计数器
  void increment() {
    _counterStream.add(_counterStream.value + 1);
  }

  // 减少计数器
  void decrement() {
    _counterStream.add(_counterStream.value - 1);
  }

  // 释放资源
  void dispose() {
    _counterStream.close();
  }
}

2. 在 UI 中使用 BLoC

在 Flutter 的 UI 中，你可以使用 StreamBuilder 来监听 GenericStream 的状态变化。

import 'package:flutter/material.dart';
import 'counter_bloc.dart';

class CounterPage extends StatefulWidget {
  @override
  _CounterPageState createState() => _CounterPageState();
}

class _CounterPageState extends State<CounterPage> {
  final CounterBloc _counterBloc = CounterBloc();

  @override
  void dispose() {
    _counterBloc.dispose();
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text('Counter with GenericStream'),
      ),
      body: Center(
        child: StreamBuilder<int>(
          stream: _counterBloc.counterStream,
          builder: (context, snapshot) {
            if (snapshot.hasData) {
              return Text(
                'Counter: ${snapshot.data}',
                style: Theme.of(context).textTheme.headline4,
              );
            } else {
              return CircularProgressIndicator();
            }
          },
        ),
      ),
      floatingActionButton: Column(
        mainAxisAlignment: MainAxisAlignment.end,
        children: [
          FloatingActionButton(
            onPressed: _counterBloc.increment,
            tooltip: 'Increment',
            child: Icon(Icons.add),
          ),
          SizedBox(height: 10),
          FloatingActionButton(
            onPressed: _counterBloc.decrement,
            tooltip: 'Decrement',
            child: Icon(Icons.remove),
          ),
        ],
      ),
    );
  }
}

高级用法

bloc_generic_streams 还提供了其他一些功能，比如 GenericStreamTransformer，它允许你对流进行转换。

使用 GenericStreamTransformer

import 'package:bloc_generic_streams/bloc_generic_streams.dart';

class CounterBloc {
  final GenericStream<int> _counterStream = GenericStream<int>(initialValue: 0);

  // 使用 GenericStreamTransformer 来转换流
  final GenericStreamTransformer<int, String> _transformer =
      GenericStreamTransformer<int, String>((value) => 'Count: $value');

  Stream<String> get transformedCounterStream =>
      _counterStream.stream.transform(_transformer);

  void increment() {
    _counterStream.add(_counterStream.value + 1);
  }

  void decrement() {
    _counterStream.add(_counterStream.value - 1);
  }

  void dispose() {
    _counterStream.close();
  }
}

在 UI 中，你可以监听转换后的流：

StreamBuilder<String>(
  stream: _counterBloc.transformedCounterStream,
  builder: (context, snapshot) {
    if (snapshot.hasData) {
      return Text(
        snapshot.data,
        style: Theme.of(context).textTheme.headline4,
      );
    } else {
      return CircularProgressIndicator();
    }
  },
)