C++ YT Wrapper
C++ library for working with YT clusters
Loading...
Searching...
No Matches
abortable_stream.h
1#pragma once
2
3#include <util/stream/input.h>
4
5#include <exception>
6
7namespace NYT {
8
10
15 : public IInputStream
16{
17public:
18 ~IAbortableInputStream() override = default;
19
23 virtual void Abort();
24
26 virtual bool IsAborted() const;
27
28 static bool IsAbortedError(const std::exception_ptr& error);
29};
30
32
33} // namespace NYT
Input stream that supports aborting the read operation.
Definition abortable_stream.h:16
virtual bool IsAborted() const
Check whether the stream has been aborted.
virtual void Abort()
Immediately abort the stream, cancelling current and future reads.
Main namespace of YT client.
Definition abortable_stream.h:7