| 1477 | /// This generator may queue up to max_subscriptions instances of T |
| 1478 | template <typename T> |
| 1479 | AsyncGenerator<T> MakeMergedGenerator(AsyncGenerator<AsyncGenerator<T>> source, |
| 1480 | int max_subscriptions) { |
| 1481 | return MergedGenerator<T>(std::move(source), max_subscriptions); |
| 1482 | } |
| 1483 | |
| 1484 | template <typename T> |
| 1485 | Result<AsyncGenerator<T>> MakeSequencedMergedGenerator( |
no outgoing calls