From a6423bf330c10089d7a0e2aaa8d971d0dcbb3fcf Mon Sep 17 00:00:00 2001 From: maybenotilya 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/counting_raw_reader.cpp | 10 ++++++++++ 1 file changed, 10 insertions(+) (limited to 'yt/cpp/mapreduce/io/counting_raw_reader.cpp') diff --git a/yt/cpp/mapreduce/io/counting_raw_reader.cpp b/yt/cpp/mapreduce/io/counting_raw_reader.cpp index c6213e86651..05f3b1cca6b 100644 --- a/yt/cpp/mapreduce/io/counting_raw_reader.cpp +++ b/yt/cpp/mapreduce/io/counting_raw_reader.cpp @@ -28,6 +28,16 @@ size_t TCountingRawTableReader::GetReadByteCount() const return ReadByteCount_; } +void TCountingRawTableReader::Abort() +{ + Reader_->Abort(); +} + +bool TCountingRawTableReader::IsAborted() const +{ + return Reader_->IsAborted(); +} + size_t TCountingRawTableReader::DoRead(void* buf, size_t len) { auto readLen = Reader_->Read(buf, len); -- cgit v1.3