diff options
| author | babenko <[email protected]> | 2025-11-23 22:49:04 +0300 |
|---|---|---|
| committer | babenko <[email protected]> | 2025-11-23 23:07:28 +0300 |
| commit | f823a1cfabf08d8bc36cef95b5d04301068a574d (patch) | |
| tree | 13de6250302563141818382c454c578b04f47f85 /yt/cpp/mapreduce/http/http_client.cpp | |
| parent | 98fb464be98e666f101c559a3ba0731bb5daaf7b (diff) | |
YT-18571: Extract async_stream_helpers.h/cpp
#### Вынос вспомогательных функций работы с асинхронными потоками в отдельный файл 📝
- 📦 Вынесены вспомогательные функции и адаптеры для работы с асинхронными потоками из `async_stream.h/cpp` в новый файл `async_stream_helpers.h/cpp`
- 🔧 Создан новый заголовочный файл, содержащий объявления всех основных адаптеров потоков: синхронных/асинхронных, буферизованных, zero-copy, копирующих, с предзагрузкой, экспирирующих и поддерживающих конкурентный доступ
- 🧩 Весь существующий код переключен на использование нового заголовка `async_stream_helpers.h`, где теперь находятся все ранее доступные функции адаптации потоков
- 🚫 Из оригинального `async_stream.h` удалены все вспомогательные функции, оставлена только основная интерфейсная часть (`IAsyncInputStream`, `IAsyncOutputStream` и их zero-copy варианты)
- ✅ Добавлена новая функция `CheckEndOfStream`, заменяющая собой старую `ExpectEndOfStream` в соответствующих местах кода
- 📁 Исходная реализация всех перенесённых функций перемещена в `async_stream_helpers.cpp`, упрощая оригинальный `async_stream.cpp`, который был удалён
<a href="https://nda.ya.ru/t/qa0kX64r7DqvtN"><font size="2">Autodescription by Yandex Code Assistant</font></a>
commit_hash:0662885b43294bfca7a6db5eaf61c82c90e3d214
Diffstat (limited to 'yt/cpp/mapreduce/http/http_client.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/http/http_client.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/http/http_client.cpp b/yt/cpp/mapreduce/http/http_client.cpp index 820bc0c36af..c0311460841 100644 --- a/yt/cpp/mapreduce/http/http_client.cpp +++ b/yt/cpp/mapreduce/http/http_client.cpp @@ -11,6 +11,7 @@ #include <yt/cpp/mapreduce/interface/logging/yt_log.h> #include <yt/yt/core/concurrency/thread_pool_poller.h> +#include <yt/yt/core/concurrency/async_stream_helpers.h> #include <yt/yt/core/http/client.h> #include <yt/yt/core/http/config.h> |