| 977 | /// This generator may queue up to max_readahead instances of T |
| 978 | template <typename T> |
| 979 | AsyncGenerator<T> MakeReadaheadGenerator(AsyncGenerator<T> source_generator, |
| 980 | int max_readahead) { |
| 981 | return ReadaheadGenerator<T>(std::move(source_generator), max_readahead); |
| 982 | } |
| 983 | |
| 984 | /// \brief Creates a generator that will yield finished futures from a vector |
| 985 | /// |
no outgoing calls