diff options
| author | hcpp <hcpp@yandex-team.ru> | 2022-02-10 16:50:01 +0300 |
|---|---|---|
| committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:01 +0300 |
| commit | cd53b77f6fe67a131e376d74d4e6ffa25e35d412 (patch) | |
| tree | e61539274ba7a458eab77a08b2765a07f94398e7 /library/cpp/grpc/server/grpc_request.h | |
| parent | 8cb7383a794381ba734eebe2a6737c40e0223f2f (diff) | |
| download | ydb-cd53b77f6fe67a131e376d74d4e6ffa25e35d412.tar.gz | |
Restoring authorship annotation for <hcpp@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/grpc/server/grpc_request.h')
| -rw-r--r-- | library/cpp/grpc/server/grpc_request.h | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/library/cpp/grpc/server/grpc_request.h b/library/cpp/grpc/server/grpc_request.h index 5bd8d3902b..acde4cd846 100644 --- a/library/cpp/grpc/server/grpc_request.h +++ b/library/cpp/grpc/server/grpc_request.h @@ -37,13 +37,13 @@ public: IStreamAdaptor::TPtr CreateStreamAdaptor(); /////////////////////////////////////////////////////////////////////////////// -template<typename TIn, typename TOut, typename TService, typename TInProtoPrinter, typename TOutProtoPrinter> +template<typename TIn, typename TOut, typename TService, typename TInProtoPrinter, typename TOutProtoPrinter> class TGRpcRequestImpl : public TBaseAsyncContext<TService> , public IQueueEvent , public IRequestContextBase { - using TThis = TGRpcRequestImpl<TIn, TOut, TService, TInProtoPrinter, TOutProtoPrinter>; + using TThis = TGRpcRequestImpl<TIn, TOut, TService, TInProtoPrinter, TOutProtoPrinter>; public: using TOnRequest = std::function<void (IRequestContextBase* ctx)>; @@ -244,7 +244,7 @@ private: void WriteDataOk(NProtoBuf::Message* resp) { auto makeResponseString = [&] { TString x; - TOutProtoPrinter printer; + TOutProtoPrinter printer; printer.SetSingleLineMode(true); printer.PrintToString(*resp, &x); return x; @@ -334,7 +334,7 @@ private: auto makeRequestString = [&] { TString resp; if (ok) { - TInProtoPrinter printer; + TInProtoPrinter printer; printer.SetSingleLineMode(true); printer.PrintToString(*Request_, &resp); } else { @@ -510,9 +510,9 @@ private: IStreamAdaptor::TPtr StreamAdaptor_; }; -template<typename TIn, typename TOut, typename TService, typename TInProtoPrinter=google::protobuf::TextFormat::Printer, typename TOutProtoPrinter=google::protobuf::TextFormat::Printer> -class TGRpcRequest: public TGRpcRequestImpl<TIn, TOut, TService, TInProtoPrinter, TOutProtoPrinter> { - using TBase = TGRpcRequestImpl<TIn, TOut, TService, TInProtoPrinter, TOutProtoPrinter>; +template<typename TIn, typename TOut, typename TService, typename TInProtoPrinter=google::protobuf::TextFormat::Printer, typename TOutProtoPrinter=google::protobuf::TextFormat::Printer> +class TGRpcRequest: public TGRpcRequestImpl<TIn, TOut, TService, TInProtoPrinter, TOutProtoPrinter> { + using TBase = TGRpcRequestImpl<TIn, TOut, TService, TInProtoPrinter, TOutProtoPrinter>; public: TGRpcRequest(TService* server, typename TService::TCurrentGRpcService::AsyncService* service, |