Searched refs:active_call (Results 1 – 5 of 5) sorted by relevance
50 def handle_request_response(active_call, mth, inter_ctx) argument51 req = active_call.read_unary_request52 call = active_call.single_req_view61 active_call.server_unary_response(63 trailing_metadata: active_call.output_metadata68 def handle_client_streamer(active_call, mth, inter_ctx) argument69 call = active_call.multi_req_view77 active_call.server_unary_response(79 trailing_metadata: active_call.output_metadata84 def handle_server_streamer(active_call, mth, inter_ctx) argument[all …]
394 active_call = new_active_server_call(an_rpc)395 unless active_call.nil?396 @pool.schedule(active_call) do |ac|
275 RawUnaryResponder active_call = in TEST() local281 active_call = std::move(inactive_call); in TEST()290 RawUnaryResponder active_call = in TEST() local298 EXPECT_TRUE(active_call.active()); in TEST()301 active_call = std::move(new_active_call); in TEST()313 RawUnaryResponder active_call = in TEST() local321 active_call = std::move(new_active_call); in TEST()328 active_call.Finish(as_bytes(span(kData)), Status::InvalidArgument())); in TEST()356 RawServerWriter active_call = in TEST() local362 active_call = std::move(inactive_call); in TEST()[all …]
250 RawClientReaderWriter active_call = in TEST() local261 active_call = std::move(inactive_call); in TEST()269 EXPECT_FALSE(active_call.active()); in TEST()277 RawUnaryReceiver active_call = in TEST() local288 active_call = std::move(inactive_call); in TEST()292 EXPECT_FALSE(active_call.active()); in TEST()
36 def inner_call_of_active_call(active_call) argument37 active_call.instance_variable_get(:@call)