Intermediate changes

1 files changed, 4 insertions, 4 deletions

diff --git a/library/cpp/neh/neh.cpp b/library/cpp/neh/neh.cpp
index dded731bb7..f669ea3757 100644
--- a/library/cpp/neh/neh.cpp
+++ b/library/cpp/neh/neh.cpp
@@ -104,18 +104,18 @@ namespace {
     const TString svcFail = "service status: failed";
 }
 
-THandleRef NNeh::Request(const TMessage& msg, IOnRecv* fallback, bool useAsyncSendRequest) {
+THandleRef NNeh::Request(const TMessage& msg, IOnRecv* fallback) {
     TServiceStatRef ss;
 
     if (TServiceStat::Disabled()) {
-        return ProtocolForMessage(msg)->ScheduleAsyncRequest(msg, fallback, ss, useAsyncSendRequest);
+        return ProtocolForMessage(msg)->ScheduleRequest(msg, fallback, ss);
     }
 
     ss = GetServiceStat(msg.Addr);
     TServiceStat::EStatus es = ss->GetStatus();
 
     if (es == TServiceStat::Ok) {
-        return ProtocolForMessage(msg)->ScheduleAsyncRequest(msg, fallback, ss, useAsyncSendRequest);
+        return ProtocolForMessage(msg)->ScheduleRequest(msg, fallback, ss);
     }
 
     if (es == TServiceStat::ReTry) {
@@ -124,7 +124,7 @@ THandleRef NNeh::Request(const TMessage& msg, IOnRecv* fallback, bool useAsyncSe
 
         validator.Addr = msg.Addr;
 
-        ProtocolForMessage(msg)->ScheduleAsyncRequest(validator, nullptr, ss, useAsyncSendRequest);
+        ProtocolForMessage(msg)->ScheduleRequest(validator, nullptr, ss);
     }
 
     TNotifyHandleRef h(new TNotifyHandle(fallback, msg));