asyncExpandMultipleRecursive method

Stream<T> asyncExpandMultipleRecursive(
  1. Iterable<Stream<T> Function(StreamElement<T>)> mappers
)

Implementation

Stream<T> asyncExpandMultipleRecursive(
    Iterable<Stream<T> Function(StreamElement<T>)> mappers) {
  final mapper = (StreamElement<T> t) => Rx.merge(mappers.map((m) => m(t)));
  return asyncExpandRecursive(mapper);
}