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/abortable_stream.cpp | 34 +++++++++++++++++++++++++
 1 file changed, 34 insertions(+)
 create mode 100644 yt/cpp/mapreduce/interface/abortable_stream.cpp

(limited to 'yt/cpp/mapreduce/interface/abortable_stream.cpp')

diff --git a/yt/cpp/mapreduce/interface/abortable_stream.cpp b/yt/cpp/mapreduce/interface/abortable_stream.cpp
new file mode 100644
index 00000000000..fc3b8d01f5b
--- /dev/null
+++ b/yt/cpp/mapreduce/interface/abortable_stream.cpp
@@ -0,0 +1,34 @@
+#include "abortable_stream.h"
+
+#include <yt/cpp/mapreduce/interface/errors.h>
+
+#include <util/system/yassert.h>
+
+namespace NYT {
+
+////////////////////////////////////////////////////////////////////////////////
+
+void IAbortableInputStream::Abort()
+{
+    Y_ABORT("Unimplemented");
+}
+
+bool IAbortableInputStream::IsAborted() const
+{
+    return false;
+}
+
+bool IAbortableInputStream::IsAbortedError(const std::exception_ptr& error)
+{
+    try {
+        std::rethrow_exception(error);
+    } catch (const TInputStreamAbortedError& ex) {
+        return true;
+    } catch (...) {
+        return false;
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+
+} // namespace NYT
-- 
cgit v1.3