在Dart中将单个订阅流拆分为两个流

import 'dart:async';

void main() {
  // 创建一个原始流
  Stream<int> originalStream = Stream.fromIterable([1, 2, 3, 4, 5]);

  // 创建两个控制器来管理新的流
  StreamController<int> firstStreamController = StreamController<int>();
  StreamController<int> secondStreamController = StreamController<int>();

  // 将原始流的元素分别发送到两个新流
  originalStream.listen((data) {
    firstStreamController.add(data);
    secondStreamController.add(data * 2); // 对第二个流的数据进行处理
  });

  // 监听两个新流
  firstStreamController.stream.listen((data) {
    print('First Stream Data: $data');
  });

  secondStreamController.stream.listen((data) {
    print('Second Stream Data: $data');
  });

  // 关闭控制器
  originalStream.listen().onDone(() {
    firstStreamController.close();
    secondStreamController.close();
  });
}