diff options
author | nadya02 <nadya02@yandex-team.com> | 2024-03-14 12:28:36 +0300 |
---|---|---|
committer | nadya02 <nadya02@yandex-team.com> | 2024-03-14 12:43:49 +0300 |
commit | 261e322cb6cabc8ee5b70d64adcf8cd84a5de97e (patch) | |
tree | 6578b8cc803ccb2ab67cbe718630f01a0e036500 | |
parent | d841f648c9c0bdcbf53e98dd449c620e5b7e4b99 (diff) | |
download | ydb-261e322cb6cabc8ee5b70d64adcf8cd84a5de97e.tar.gz |
Return null SharedRef at the end of stream in http client
0acefa589ef8e5bbd622fec3c2fbc97ac3b6115c
-rw-r--r-- | yt/yt/core/http/stream.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/yt/yt/core/http/stream.cpp b/yt/yt/core/http/stream.cpp index 4189f6c257..30931be20d 100644 --- a/yt/yt/core/http/stream.cpp +++ b/yt/yt/core/http/stream.cpp @@ -479,7 +479,7 @@ void THttpInput::SetPort(int port) TSharedRef THttpInput::DoRead() { if (Parser_.GetState() == EParserState::MessageFinished) { - return TSharedRef::MakeEmpty(); + return TSharedRef{}; } Connection_->SetReadDeadline(TInstant::Now() + Config_->BodyReadIdleTimeout); @@ -504,7 +504,7 @@ TSharedRef THttpInput::DoRead() FinishMessage(); Connection_->SetReadDeadline(std::nullopt); - return TSharedRef::MakeEmpty(); + return TSharedRef{}; } // EOF must be handled by HTTP parser. |