| 704 | /// This generator may queue up to max_readahead additional instances of T |
| 705 | template <typename T> |
| 706 | AsyncGenerator<T> MakeSerialReadaheadGenerator(AsyncGenerator<T> source_generator, |
| 707 | int max_readahead) { |
| 708 | return SerialReadaheadGenerator<T>(std::move(source_generator), max_readahead); |
| 709 | } |
| 710 | |
| 711 | /// \brief Create a generator that immediately pulls from the source |
| 712 | /// |
no outgoing calls
no test coverage detected