Home
last modified time | relevance | path

Searched refs:client_call (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc/src/ruby/spec/generic/
Dactive_call_spec.rb29 def send_and_receive_close_and_status(client_call, server_call) argument
30 client_call.run_batch(CallOps::SEND_CLOSE_FROM_CLIENT => nil)
33 client_call.run_batch(CallOps::RECV_STATUS_ON_CLIENT => nil)
102 client_call = ActiveCall.new(call, @pass_through,
105 client_call.remote_send(msg)
128 client_call = ActiveCall.new(call, marshal, @pass_through, deadline)
130 client_call.remote_send(msg)
154 client_call = ActiveCall.new(call, marshal,
157 client_call.write_flag = f
158 client_call.remote_send(msg)
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/
Dcygrpc_test.py201 client_call = self.client_channel.integrated_call(
310 del client_call
325 client_call = self.client_channel.segregated_call(
341 client_call.next_event)
360 client_call.operate([
365 client_call.next_event)
375 client_call.operate([
381 client_call.next_event(),
382 client_call.next_event(),})
D_read_some_but_not_all_responses_test.py157 client_call = channel.segregated_call(
176 client_call.next_event)
216 client_call.operate([
219 client_receive_first_message_event = client_call.next_event()
221 client_call_cancel_result = client_call.cancel(
223 client_complete_rpc_event = client_call.next_event()
D_cancel_many_calls_test.py177 client_call = channel.integrated_call(
194 client_calls.append(client_call)
212 for client_call in client_calls:
213 client_call.cancel(cygrpc.StatusCode.cancelled, 'Cancelled!')
D_no_messages_single_server_completion_queue_test.py42 client_call = self.channel.integrated_call(
57 client_call.operate([
D_no_messages_server_completion_queue_per_call_test.py47 client_call = self.channel.integrated_call(
55 client_call.operate([
/external/grpc-grpc/src/ruby/spec/
Dclient_server_spec.rb632 def credentials_update_test_finish_call(client_call, server_call) argument
641 final_client_batch = client_call.run_batch(