blob: 8b58e6582fc38b1c7cb0518997a0489991adc60e (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
#pragma once
#include <yt/cpp/mapreduce/interface/abortable_stream.h>
#include <yt/yt/core/concurrency/async_stream.h>
#include <memory>
namespace NYT::NDetail {
////////////////////////////////////////////////////////////////////////////////
std::unique_ptr<IAbortableInputStream> CreateAbortableInputStreamAdapter(
NConcurrency::IAsyncInputStreamPtr underlyingStream);
std::unique_ptr<IAbortableInputStream> CreateAbortableInputStreamAdapterFallback(
IInputStream* underlyingStream);
////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NDetail
|
