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/interface/raw_client.h | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

(limited to 'yt/cpp/mapreduce/interface/raw_client.h')

diff --git a/yt/cpp/mapreduce/interface/raw_client.h b/yt/cpp/mapreduce/interface/raw_client.h
index e318c022ce5..9347a95e6e6 100644
--- a/yt/cpp/mapreduce/interface/raw_client.h
+++ b/yt/cpp/mapreduce/interface/raw_client.h
@@ -4,6 +4,8 @@
 #include "client_method_options.h"
 #include "operation.h"
 
+#include <yt/cpp/mapreduce/interface/abortable_stream.h>
+
 #include <yt/cpp/mapreduce/http/context.h>
 
 namespace NYT {
@@ -213,7 +215,7 @@ public:
 
     // Files
 
-    virtual std::unique_ptr<IInputStream> ReadFile(
+    virtual std::unique_ptr<IAbortableInputStream> ReadFile(
         const TTransactionId& transactionId,
         const TRichYPath& path,
         const TFileReaderOptions& options = {}) = 0;
@@ -299,18 +301,18 @@ public:
         const TMaybe<TFormat>& format,
         const TTableWriterOptions& options = {}) = 0;
 
-    virtual std::unique_ptr<IInputStream> ReadTable(
+    virtual std::unique_ptr<IAbortableInputStream> ReadTable(
         const TTransactionId& transactionId,
         const TRichYPath& path,
         const TFormat& format,
         const TTableReaderOptions& options = {}) = 0;
 
-    virtual std::unique_ptr<IInputStream> ReadTablePartition(
+    virtual std::unique_ptr<IAbortableInputStream> ReadTablePartition(
         const TString& cookie,
         const TFormat& format,
         const TTablePartitionReaderOptions& options = {}) = 0;
 
-    virtual std::unique_ptr<IInputStream> ReadBlobTable(
+    virtual std::unique_ptr<IAbortableInputStream> ReadBlobTable(
         const TTransactionId& transactionId,
         const TRichYPath& path,
         const TKey& key,
-- 
cgit v1.3