blob: 10b8f75e1f77edb3654ea3efc8a9b385c75d98bc (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
#pragma once
#include <yt/yt/core/concurrency/async_stream.h>
namespace NYT::NDetail {
////////////////////////////////////////////////////////////////////////////////
NConcurrency::IAsyncInputStreamPtr CreateHaltingAsyncStream(
NConcurrency::IAsyncInputStreamPtr underlying,
i64 bytesBeforeHalt);
////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NDetail
|
