@@ -314,7 +314,7 @@ kphp::coro::task<kphp::rpc::query_info> send_request(string actor, Optional<doub
314314 auto waiter_task{std::invoke (
315315 [](int64_t query_id, auto comp_query, std::chrono::nanoseconds timeout, bool collect_responses_extra_info) noexcept -> kphp::coro::task<string> {
316316 auto fetch_task{f$component_client_fetch_response (std::move (comp_query))};
317- const auto response{(co_await wait_with_timeout_t {fetch_task.operator co_await (), timeout}).value_or (string{})};
317+ auto response{(co_await wait_with_timeout_t {fetch_task.operator co_await (), timeout}).value_or (string{})};
318318 // update response extra info if needed
319319 if (collect_responses_extra_info) {
320320 auto & extra_info_map{RpcClientInstanceState::get ().rpc_responses_extra_info };
@@ -343,13 +343,13 @@ kphp::coro::task<std::expected<void, kphp::rpc::error>> send_response(std::span<
343343 auto & instance_st{InstanceState::get ()};
344344 const auto stream_d{instance_st.standard_stream ()};
345345 if (stream_d == k2::INVALID_PLATFORM_DESCRIPTOR) [[unlikely]] {
346- co_return std::unexpected ( kphp::rpc::error::invalid_stream) ;
346+ co_return std::unexpected{ kphp::rpc::error::invalid_stream} ;
347347 }
348348 if (instance_st.instance_kind () != instance_kind::rpc_server) [[unlikely]] {
349- co_return std::unexpected ( kphp::rpc::error::not_rpc_stream) ;
349+ co_return std::unexpected{ kphp::rpc::error::not_rpc_stream} ;
350350 }
351351 if (co_await write_all_to_stream (stream_d, reinterpret_cast <const char *>(response.data ()), response.size ()) != response.size ()) [[unlikely]] {
352- co_return std::unexpected ( kphp::rpc::error::write_failed) ;
352+ co_return std::unexpected{ kphp::rpc::error::write_failed} ;
353353 }
354354 instance_st.release_stream (stream_d);
355355 co_return std::expected<void , kphp::rpc::error>{};
0 commit comments