Convert Stream<List<T>> to Stream<T>

user_10667562 0
Viewed 55

I try to convert Stream of List to a single Stream of T.

I want to achieve Stream<T> from Sream<List<T>> in pure dart.

Example:

Convert stream that emits these values

Stream.fromIterable([[1, 2, 3], [4, 5, 6]]);

To stream that emits these values

Stream.fromIterable([1, 2, 3, 4, 5, 6]);
dart
2 Answers

You can use expand:

stream = streamOfList.expand((e) => e);
user_6348630

You can use a function like:

Stream<T> flatten<T>(Stream<List<T>> source) async* {
  await for (var list in source) {
    for (var element in list) {
      yield element;
    }
  }
}

Or use expand as suggested.

user_21566210
Related