| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests_aio/unit/ |
| H A D | client_stream_unary_interceptor_test.py | 40 self, continuation, client_call_details, request_iterator argument
52 self, continuation, client_call_details, request_iterator argument
90 async def request_iterator(): function
180 async def request_iterator(): function
214 async def request_iterator(): function
247 async def request_iterator(): function
293 async def request_iterator(): function
354 self, continuation, client_call_details, request_iterator argument
396 self, continuation, client_call_details, request_iterator argument
474 self, continuation, client_call_details, request_iterator argument
[all …]
|
| H A D | server_test.py | 134 async def _stream_unary_async_gen(self, request_iterator, unused_context): argument
147 async def _stream_unary_evilly_mixed(self, request_iterator, context): argument
156 async def _stream_stream_async_gen(self, request_iterator, unused_context): argument
172 async def _stream_stream_evilly_mixed(self, request_iterator, context): argument
184 async def _error_in_stream_stream(self, request_iterator, unused_context): argument
190 async def _value_error_in_stream_unary(self, request_iterator, context): argument
203 self, request_iterator, context argument
|
| /aosp_15_r20/external/python/bumble/bumble/transport/grpc_protobuf/ |
| D | emulated_bluetooth_pb2_grpc.py | 62 def registerClassicPhy(self, request_iterator, context): argument
79 def registerBlePhy(self, request_iterator, context): argument
96 def registerHCIDevice(self, request_iterator, context): argument
172 def registerClassicPhy(request_iterator, argument
189 def registerBlePhy(request_iterator, argument
206 def registerHCIDevice(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/tools/distrib/python/xds_protos/envoy/service/route/v3/ |
| H A D | rds_pb2_grpc.py | 51 def StreamRoutes(self, request_iterator, context): argument
57 def DeltaRoutes(self, request_iterator, context): argument
105 def StreamRoutes(request_iterator, argument
122 def DeltaRoutes(request_iterator, argument
195 def DeltaVirtualHosts(self, request_iterator, context): argument
230 def DeltaVirtualHosts(request_iterator, argument
|
| H A D | srds_pb2_grpc.py | 57 def StreamScopedRoutes(self, request_iterator, context): argument
63 def DeltaScopedRoutes(self, request_iterator, context): argument
114 def StreamScopedRoutes(request_iterator, argument
131 def DeltaScopedRoutes(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| H A D | _interceptor_test.py | 115 def handle_stream_unary(self, request_iterator, servicer_context): argument
138 def handle_stream_stream(self, request_iterator, servicer_context): argument
294 self, continuation, client_call_details, request_iterator argument
303 self, continuation, client_call_details, request_iterator argument
370 self, continuation, client_call_details, request_iterator argument
383 self, continuation, client_call_details, request_iterator argument
399 request_iterator, argument
414 request_iterator, argument
491 def triple(request_iterator): argument
|
| H A D | _exit_scenarios.py | 74 def hang_stream_unary(request_iterator, servicer_context): argument
78 def hang_partial_stream_unary(request_iterator, servicer_context): argument
84 def hang_stream_stream(request_iterator, servicer_context): argument
88 def hang_partial_stream_stream(request_iterator, servicer_context): argument
|
| /aosp_15_r20/external/grpc-grpc/tools/distrib/python/xds_protos/envoy/service/discovery/v3/ |
| H A D | ads_pb2_grpc.py | 58 def StreamAggregatedResources(self, request_iterator, context): argument
65 def DeltaAggregatedResources(self, request_iterator, context): argument
108 def StreamAggregatedResources(request_iterator, argument
125 def DeltaAggregatedResources(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/tools/distrib/python/xds_protos/envoy/service/discovery/v2/ |
| H A D | ads_pb2_grpc.py | 58 def StreamAggregatedResources(self, request_iterator, context): argument
65 def DeltaAggregatedResources(self, request_iterator, context): argument
108 def StreamAggregatedResources(request_iterator, argument
125 def DeltaAggregatedResources(request_iterator, argument
|
| H A D | sds_pb2_grpc.py | 41 def DeltaSecrets(self, request_iterator, context): argument
47 def StreamSecrets(self, request_iterator, context): argument
90 def DeltaSecrets(request_iterator, argument
107 def StreamSecrets(request_iterator, argument
|
| H A D | rtds_pb2_grpc.py | 45 def StreamRuntime(self, request_iterator, context): argument
51 def DeltaRuntime(self, request_iterator, context): argument
96 def StreamRuntime(request_iterator, argument
113 def DeltaRuntime(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/ |
| H A D | _python_plugin_test.py | 153 def StreamingInputCall(self, request_iterator, context): argument
158 def FullDuplexCall(self, request_iterator, context): argument
161 def HalfDuplexCall(self, request_iterator, context): argument
576 def StreamingInputCall(self, request_iterator, context): argument
581 def FullDuplexCall(self, request_iterator, context): argument
586 def HalfDuplexCall(self, request_iterator, context): argument
|
| /aosp_15_r20/external/grpc-grpc/tools/distrib/python/xds_protos/envoy/service/runtime/v3/ |
| H A D | rtds_pb2_grpc.py | 45 def StreamRuntime(self, request_iterator, context): argument
51 def DeltaRuntime(self, request_iterator, context): argument
96 def StreamRuntime(request_iterator, argument
113 def DeltaRuntime(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/tools/distrib/python/xds_protos/envoy/service/extension/v3/ |
| H A D | config_discovery_pb2_grpc.py | 85 def StreamExtensionConfigs(self, request_iterator, context): argument
91 def DeltaExtensionConfigs(self, request_iterator, context): argument
156 def StreamExtensionConfigs(request_iterator, argument
173 def DeltaExtensionConfigs(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/tools/distrib/python/xds_protos/envoy/service/secret/v3/ |
| H A D | sds_pb2_grpc.py | 41 def DeltaSecrets(self, request_iterator, context): argument
47 def StreamSecrets(self, request_iterator, context): argument
90 def DeltaSecrets(request_iterator, argument
107 def StreamSecrets(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/tools/distrib/python/xds_protos/envoy/service/cluster/v3/ |
| H A D | cds_pb2_grpc.py | 43 def StreamClusters(self, request_iterator, context): argument
49 def DeltaClusters(self, request_iterator, context): argument
93 def StreamClusters(request_iterator, argument
110 def DeltaClusters(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/tools/distrib/python/xds_protos/envoy/service/listener/v3/ |
| H A D | lds_pb2_grpc.py | 51 def DeltaListeners(self, request_iterator, context): argument
57 def StreamListeners(self, request_iterator, context): argument
105 def DeltaListeners(request_iterator, argument
122 def StreamListeners(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/tools/distrib/python/xds_protos/envoy/service/endpoint/v3/ |
| H A D | eds_pb2_grpc.py | 43 def StreamEndpoints(self, request_iterator, context): argument
51 def DeltaEndpoints(self, request_iterator, context): argument
95 def StreamEndpoints(request_iterator, argument
112 def DeltaEndpoints(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests_aio/benchmark/ |
| H A D | worker_servicer.py | 207 async def _run_single_server(self, config, request_iterator, context): argument
223 async def RunServer(self, request_iterator, context): argument
291 async def _run_single_client(self, config, request_iterator, context): argument
322 async def RunClient(self, request_iterator, context): argument
|
| /aosp_15_r20/external/grpc-grpc/examples/python/multiplex/ |
| H A D | route_guide_pb2_grpc.py | 68 def RecordRoute(self, request_iterator, context): argument
78 def RouteChat(self, request_iterator, context): argument
157 def RecordRoute(request_iterator, argument
174 def RouteChat(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| H A D | _multi_callable.py | 80 self, request_iterator, timeout=None, metadata=None, credentials=None argument
93 self, request_iterator, timeout=None, metadata=None, credentials=None argument
106 self, request_iterator, timeout=None, metadata=None, credentials=None argument
125 self, request_iterator, timeout=None, metadata=None, credentials=None argument
|
| /aosp_15_r20/external/grpc-grpc/examples/python/data_transmission/ |
| H A D | demo_pb2_grpc.py | 57 def ClientStreamingMethod(self, request_iterator, context): argument
75 def BidirectionalStreamingMethod(self, request_iterator, context): argument
138 def ClientStreamingMethod(request_iterator, argument
172 def BidirectionalStreamingMethod(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/examples/python/route_guide/ |
| H A D | route_guide_pb2_grpc.py | 68 def RecordRoute(self, request_iterator, context): argument
78 def RouteChat(self, request_iterator, context): argument
157 def RecordRoute(request_iterator, argument
174 def RouteChat(request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| H A D | _client_adaptations.py | 286 request_iterator, argument
324 request_iterator, argument
351 request_iterator, argument
497 request_iterator, argument
518 self, request_iterator, timeout, metadata=None, protocol_options=None argument
562 self, request_iterator, timeout, metadata=None, protocol_options=None argument
709 request_iterator, argument
745 request_iterator, argument
779 request_iterator, argument
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/interop/ |
| H A D | service.py | 80 def StreamingInputCall(self, request_iterator, context): argument
89 def FullDuplexCall(self, request_iterator, context): argument
107 def HalfDuplexCall(self, request_iterator, context): argument
|