Revision history [back]

To combine streams of different types in Dartlang using rxdart, you can use the .combineLatest method or zip method.

.combineLatest method: This method merges the latest values emitted by each stream into a new stream. For example, if you have two streams of type int and String, and you want to combine them into a new stream with each emitted value as a list [int, String], you can use the following code:

import 'package:rxdart/rxdart.dart';

Stream<int> stream1 = Stream.fromIterable([1, 2, 3]);
Stream<String> stream2 = Stream.fromIterable(['a', 'b', 'c']);

Stream<List<dynamic>> combinedStream = Rx.combineLatest2(
  stream1, stream2, (a, b) => [a, b]);

zip method: This method merges the corresponding values emitted by each stream into a new stream. For example, if you have two streams of type int and String, and you want to combine them into a new stream with each emitted value as a list [int, String], you can use the following code:

import 'package:rxdart/rxdart.dart';

Stream<int> stream1 = Stream.fromIterable([1, 2, 3]);
Stream<String> stream2 = Stream.fromIterable(['a', 'b', 'c']);

Stream<List<dynamic>> combinedStream = Rx.zip2(
  stream1, stream2, (a, b) => [a, b]);

Note: In both cases, the resulting Stream is of type Stream<List<dynamic>>, where dynamic represents the type of values emitted by each original stream.