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
7
namespace
NYT
{
8
10
14
class
IAbortableInputStream
15
:
public
IInputStream
16
{
17
public
:
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
NYT::IAbortableInputStream
Input stream that supports aborting the read operation.
Definition
abortable_stream.h:16
NYT::IAbortableInputStream::IsAborted
virtual bool IsAborted() const
Check whether the stream has been aborted.
NYT::IAbortableInputStream::Abort
virtual void Abort()
Immediately abort the stream, cancelling current and future reads.
NYT
Main namespace of YT client.
Definition
abortable_stream.h:7
yt
cpp
mapreduce
interface
abortable_stream.h
Generated by
1.15.0