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/proto_table_reader.cpp | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

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

diff --git a/yt/cpp/mapreduce/io/proto_table_reader.cpp b/yt/cpp/mapreduce/io/proto_table_reader.cpp
index 6f79619c810..76e0243b395 100644
--- a/yt/cpp/mapreduce/io/proto_table_reader.cpp
+++ b/yt/cpp/mapreduce/io/proto_table_reader.cpp
@@ -206,6 +206,16 @@ bool TProtoTableReader::IsRawReaderExhausted() const
     return NodeReader_->IsRawReaderExhausted();
 }
 
+void TProtoTableReader::Abort()
+{
+    NodeReader_->Abort();
+}
+
+bool TProtoTableReader::IsAborted() const
+{
+    return NodeReader_->IsAborted();
+}
+
 ////////////////////////////////////////////////////////////////////////////////
 
 TLenvalProtoTableReader::TLenvalProtoTableReader(
@@ -291,6 +301,16 @@ bool TLenvalProtoTableReader::IsRawReaderExhausted() const
     return TLenvalTableReader::IsRawReaderExhausted();
 }
 
+void TLenvalProtoTableReader::Abort()
+{
+    Input_.Abort();
+}
+
+bool TLenvalProtoTableReader::IsAborted() const
+{
+    return Input_.IsAborted();
+}
+
 void TLenvalProtoTableReader::SkipRow()
 {
     while (true) {
-- 
cgit v1.3