rx_pack 是一个用于 Flutter 的响应式编程插件，它基于 RxDart，提供了一些方便的工具和扩展，帮助开发者更容易地实现响应式编程。RxDart 是一个强大的 Dart 响应式编程库，扩展了 Dart 的 Stream API，提供了更多的操作符和功能。

1. 安装 rx_pack

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

dependencies:
  flutter:
    sdk: flutter
  rx_pack: ^0.0.1  # 请根据最新版本号进行替换

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

2. 基本使用

rx_pack 提供了一些扩展方法和工具，使得使用 RxDart 更加方便。以下是一些常见的使用场景：

2.1 创建 Subject

Subject 是 RxDart 中的一种特殊的 StreamController，它可以同时作为 Stream 和 Sink 使用。

import 'package:rx_pack/rx_pack.dart';

final subject = BehaviorSubject<int>();

subject.stream.listen((value) {
  print('Received: $value');
});

subject.add(1);  // 输出: Received: 1
subject.add(2);  // 输出: Received: 2

2.2 使用 rx_pack 的扩展方法

rx_pack 提供了一些扩展方法，使得操作 Stream 更加方便。

import 'package:rx_pack/rx_pack.dart';

void main() {
  final stream = Stream.fromIterable([1, 2, 3, 4, 5]);

  stream
      .where((value) => value % 2 == 0)  // 过滤偶数
      .map((value) => value * 2)         // 将偶数乘以2
      .listen((value) {
    print('Transformed: $value');
  });
}

2.3 使用 rx_pack 的 Rx 工具

rx_pack 还提供了一些工具类，例如 Rx，它可以帮助你更方便地管理 Stream 的生命周期。

import 'package:rx_pack/rx_pack.dart';

void main() {
  final rx = Rx<int>();

  rx.stream.listen((value) {
    print('Rx Value: $value');
  });

  rx.add(1);  // 输出: Rx Value: 1
  rx.add(2);  // 输出: Rx Value: 2

  rx.dispose();  // 释放资源
}

3. 结合 Flutter 使用

在 Flutter 中，你可以将 rx_pack 与 StreamBuilder 结合使用，实现响应式 UI。

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

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

class _CounterPageState extends State<CounterPage> {
  final counterSubject = BehaviorSubject<int>.seeded(0);

  void incrementCounter() {
    final currentValue = counterSubject.value;
    counterSubject.add(currentValue + 1);
  }

  @override
  void dispose() {
    counterSubject.close();
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(title: Text('Rx Counter')),
      body: Center(
        child: StreamBuilder<int>(
          stream: counterSubject.stream,
          builder: (context, snapshot) {
            return Text('Counter: ${snapshot.data}');
          },
        ),
      ),
      floatingActionButton: FloatingActionButton(
        onPressed: incrementCounter,
        child: Icon(Icons.add),
      ),
    );
  }
}

void main() => runApp(MaterialApp(home: CounterPage()));

在这个例子中，我们使用 BehaviorSubject 来管理计数器的状态，并通过 StreamBuilder 将 UI 与 Stream 绑定，实现响应式更新。

4. 其他功能

rx_pack 还提供了其他一些功能，例如 CompositeSubscription，它可以帮助你管理多个 Subscription，确保在页面销毁时自动取消订阅。

import 'package:rx_pack/rx_pack.dart';

void main() {
  final compositeSubscription = CompositeSubscription();

  final stream1 = Stream.fromIterable([1, 2, 3]);
  final stream2 = Stream.fromIterable([4, 5, 6]);

  compositeSubscription.add(stream1.listen((value) {
    print('Stream1: $value');
  }));

  compositeSubscription.add(stream2.listen((value) {
    print('Stream2: $value');
  }));

  // 取消所有订阅
  compositeSubscription.dispose();
}