Method needAsyncPrefetch

src/IO/ReadPipeline.cpp:141–150

}

void ReadPipeline::needAsyncPrefetch(
    IAsynchronousReader & reader,
    AsyncReadCountersPtr async_read_counters,
    FilesystemReadPrefetchesLogPtr prefetches_log)
{
    async_prefetch = AsyncPrefetchStage{
        .reader = &reader,
        .async_read_counters = std::move(async_read_counters),
        .prefetches_log = std::move(prefetches_log)};
}

void ReadPipeline::needDecryption(String path, size_t buffer_size, KeyFinderFunc key_finder)
{