如何在Dart中使用StreamZip合并流

import 'dart:async';

void main() async {
  // 创建两个模拟的流
  final stream1 = Stream.fromIterable([1, 2, 3]);
  final stream2 = Stream.fromIterable(['a', 'b', 'c']);

  // 使用 StreamZip 合并这两个流
  final zippedStream = StreamZip([stream1, stream2]);

  // 监听合并后的流
  await for (var values in zippedStream) {
    print(values); // 输出: [1, 'a'], [2, 'b'], [3, 'c']
  }
}

import 'dart:async';

void main() async {
  final stream1 = Stream.fromIterable([1, 2, 3]);
  final stream2 = Stream.fromIterable(['a', 'b']);

  final zippedStream = StreamZip([stream1, stream2]);

  await for (var values in zippedStream) {
    print(values); // 输出: [1, 'a'], [2, 'b']
  }

  // 处理剩余的元素
  await for (var value in stream1) {
    print('Remaining from stream1: $value'); // 输出: Remaining from stream1: 3
  }
}