Home
last modified time | relevance | path

Searched defs:request_iterator (Results 1 – 25 of 33) sorted by relevance

12

/external/grpc-grpc/src/python/grpcio_tests/tests/testing/
D_server_application.py43 def StreUn(self, request_iterator, context): argument
58 def StreStre(self, request_iterator, context): argument
/external/grpc-grpc/src/python/grpcio_tests/tests/qps/
Dbenchmark_server.py26 def StreamingCall(self, request_iterator, context): argument
42 def StreamingCall(self, request_iterator, context): argument
Dworker_server.py41 def RunServer(self, request_iterator, context): argument
104 def RunClient(self, request_iterator, context): argument
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/
D_multi_callable.py67 request_iterator, argument
78 request_iterator, argument
89 request_iterator, argument
107 request_iterator, argument
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_interceptor_test.py85 def handle_stream_unary(self, request_iterator, servicer_context): argument
101 def handle_stream_stream(self, request_iterator, servicer_context): argument
205 request_iterator): argument
212 request_iterator): argument
242 request_iterator): argument
247 request_iterator): argument
261 def intercept_call(client_call_details, request_iterator, request_streaming, argument
273 def intercept_call(client_call_details, request_iterator, argument
342 def triple(request_iterator): argument
D_exit_scenarios.py73 def hang_stream_unary(request_iterator, servicer_context): argument
77 def hang_partial_stream_unary(request_iterator, servicer_context): argument
83 def hang_stream_stream(request_iterator, servicer_context): argument
87 def hang_partial_stream_stream(request_iterator, servicer_context): argument
D_empty_message_test.py40 def handle_stream_unary(request_iterator, servicer_context): argument
46 def handle_stream_stream(request_iterator, servicer_context): argument
D_resource_exhausted_test.py78 def handle_stream_unary(trigger, request_iterator, servicer_context): argument
86 def handle_stream_stream(trigger, request_iterator, servicer_context): argument
D_metadata_test.py116 def handle_stream_unary(test, request_iterator, servicer_context): argument
126 def handle_stream_stream(test, request_iterator, servicer_context): argument
D_compression_test.py34 def handle_stream(request_iterator, servicer_context): argument
/external/grpc-grpc/examples/python/multiplex/
Droute_guide_pb2_grpc.py67 def RecordRoute(self, request_iterator, context): argument
77 def RouteChat(self, request_iterator, context): argument
Dmultiplex_server.py92 def RecordRoute(self, request_iterator, context): argument
114 def RouteChat(self, request_iterator, context): argument
/external/grpc-grpc/examples/python/route_guide/
Droute_guide_pb2_grpc.py67 def RecordRoute(self, request_iterator, context): argument
77 def RouteChat(self, request_iterator, context): argument
Droute_guide_server.py84 def RecordRoute(self, request_iterator, context): argument
106 def RouteChat(self, request_iterator, context): argument
/external/grpc-grpc/examples/python/interceptors/headers/
Dgeneric_client_interceptor.py40 request_iterator): argument
47 request_iterator): argument
Dheader_manipulator_client_interceptor.py32 def intercept_call(client_call_details, request_iterator, request_streaming, argument
/external/grpc-grpc/src/python/grpcio/grpc/
D_interceptor.py290 request_iterator, argument
302 request_iterator, argument
309 def continuation(new_details, request_iterator): argument
329 request_iterator, argument
340 request_iterator, argument
347 def continuation(new_details, request_iterator): argument
371 request_iterator, argument
378 def continuation(new_details, request_iterator): argument
D_channel.py179 def _consume_request_iterator(request_iterator, state, call, request_serializer, argument
600 def _blocking(self, request_iterator, timeout, metadata, credentials): argument
619 request_iterator, argument
628 request_iterator, argument
637 request_iterator, argument
664 request_iterator, argument
D__init__.py444 request_iterator): argument
482 request_iterator): argument
706 request_iterator, argument
733 request_iterator, argument
760 request_iterator, argument
789 request_iterator, argument
/external/grpc-grpc/src/python/grpcio/grpc/beta/
D_server_adaptations.py97 def adaptation(request_iterator, servicer_context): argument
158 def _run_request_pipe_thread(request_iterator, request_consumer, argument
209 def adaptation(request_iterator, servicer_context): argument
225 def adaptation(request_iterator, servicer_context): argument
D_client_adaptations.py232 request_iterator, request_serializer, argument
258 metadata, metadata_transformer, request_iterator, argument
274 metadata_transformer, request_iterator, request_serializer, argument
366 request_iterator, argument
378 request_iterator, argument
408 request_iterator, argument
499 request_iterator, argument
520 request_iterator, argument
540 request_iterator, argument
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/
D_beta_features_test.py70 def stream_unary(self, request_iterator, context): argument
81 def stream_stream(self, request_iterator, context): argument
/external/tensorflow/tensorflow/python/debug/lib/
Ddebug_service_pb2_grpc.py63 def SendEvents(self, request_iterator, context): argument
/external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/
Dface.py487 request_iterator, argument
515 request_iterator, argument
568 request_iterator, argument
786 request_iterator, argument
821 request_iterator, argument
848 request_iterator, argument
/external/grpc-grpc/src/python/grpcio_tests/tests/interop/
Dmethods.py78 def StreamingInputCall(self, request_iterator, context): argument
86 def FullDuplexCall(self, request_iterator, context): argument
98 def HalfDuplexCall(self, request_iterator, context): argument

12