From a6423bf330c10089d7a0e2aaa8d971d0dcbb3fcf Mon Sep 17 00:00:00 2001
From: maybenotilya <maybenotilya@yandex-team.com>
Date: Fri, 17 Apr 2026 11:57:44 +0300
Subject: YT-26179: Add Abort for readers

* Changelog entry
  Type: feature
  Component: cpp-sdk

Add Abort for table readers
commit_hash:be5026883c90d18333f20468946f1e5a5b71839b
---
 yt/cpp/mapreduce/io/stream_raw_reader.cpp | 10 ++++++++++
 1 file changed, 10 insertions(+)

(limited to 'yt/cpp/mapreduce/io/stream_raw_reader.cpp')

diff --git a/yt/cpp/mapreduce/io/stream_raw_reader.cpp b/yt/cpp/mapreduce/io/stream_raw_reader.cpp
index ec19b67d0b0..f69eb9f034f 100644
--- a/yt/cpp/mapreduce/io/stream_raw_reader.cpp
+++ b/yt/cpp/mapreduce/io/stream_raw_reader.cpp
@@ -5,6 +5,10 @@
 #include "skiff_table_reader.h"
 #include "yamr_table_reader.h"
 
+#include <yt/cpp/mapreduce/common/abortable_stream.h>
+
+#include <yt/yt/core/concurrency/async_stream_helpers.h>
+
 #include <util/system/env.h>
 #include <util/string/type.h>
 
@@ -33,6 +37,12 @@ namespace NDetail {
 
 ////////////////////////////////////////////////////////////////////////////////
 
+TInputStreamProxy::TInputStreamProxy(IInputStream* stream)
+    : Stream_(CreateAbortableInputStreamAdapter(NConcurrency::CreateAsyncAdapter(stream)))
+{ }
+
+////////////////////////////////////////////////////////////////////////////////
+
 ::TIntrusivePtr<IProtoReaderImpl> CreateProtoReader(
     IInputStream* stream,
     const TTableReaderOptions& /* options */,
-- 
cgit v1.3