| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _empty_message_test.py | 60 self.stream_unary = None
65 self.stream_unary = handle_stream_unary
109 response = self._channel.stream_unary(_STREAM_UNARY)(iter(
|
| D | _exit_scenarios.py | 102 self.stream_unary = None
111 self.stream_unary = hang_partial_stream_unary
113 self.stream_unary = hang_stream_unary
224 multi_callable = channel.stream_unary(method)
|
| D | _invocation_defects_test.py | 118 unary_stream, stream_unary, stream_stream): argument
125 self.stream_unary = stream_unary
188 return channel.stream_unary(
|
| D | _metadata_test.py | 145 self.stream_unary = None
150 self.stream_unary = lambda x, y: handle_stream_unary(test, x, y)
213 multi_callable = self._channel.stream_unary(_STREAM_UNARY)
|
| D | _resource_exhausted_test.py | 103 self.stream_unary = None
109 self.stream_unary = lambda x, y: handle_stream_unary(trigger, x, y)
202 multi_callable = self._channel.stream_unary(_STREAM_UNARY)
|
| D | _interceptor_test.py | 118 unary_stream, stream_unary, stream_stream): argument
125 self.stream_unary = stream_unary
166 return channel.stream_unary(
|
| D | _compression_test.py | 52 self.stream_unary = None
|
| D | _rpc_test.py | 122 unary_stream, stream_unary, stream_stream): argument
129 self.stream_unary = stream_unary
170 return channel.stream_unary(
|
| D | _invalid_metadata_test.py | 45 return channel.stream_unary(
|
| D | _metadata_code_details_test.py | 105 def stream_unary(self, request_iterator, context): member in _Servicer
180 grpc.stream_unary_rpc_method_handler(servicer.stream_unary),
215 self._stream_unary = channel.stream_unary('/'.join((
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _channel.py | 47 def stream_unary(self, member in TestingChannel
81 return _channel_rpc.stream_unary(self._state, method_descriptor)
|
| D | _channel_rpc.py | 112 def stream_unary(channel_state, method_descriptor): function
|
| /external/flatbuffers/tests/MyGame/Example/ |
| D | monster_test_grpc_fb.py | 23 self.GetMaxHitPoint = channel.stream_unary(
112 self.GetMaxHitPoint = channel.stream_unary(
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _beta_features_test.py | 70 def stream_unary(self, request_iterator, context): member in _Servicer
149 utilities.stream_unary_inline(self._servicer.stream_unary),
280 utilities.stream_unary_inline(self._servicer.stream_unary),
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | _service.py | 81 def stream_unary(implementation, rpc, handler, servicer_context): function
|
| D | _server.py | 50 _service.stream_unary(implementation, rpc, handler, servicer_context)
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| D | _client_adaptations.py | 235 multi_callable = channel.stream_unary(
260 multi_callable = channel.stream_unary(
625 def stream_unary(self, group, method): member in _GenericStub
672 return self._generic_stub.stream_unary(self._group, attr)
|
| /external/grpc-grpc/examples/python/route_guide/ |
| D | route_guide_pb2_grpc.py | 27 self.RecordRoute = channel.stream_unary(
|
| /external/grpc-grpc/examples/python/multiplex/ |
| D | route_guide_pb2_grpc.py | 27 self.RecordRoute = channel.stream_unary(
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 426 def stream_unary(self, member in _Channel
430 thunk = lambda m: self._channel.stream_unary(m, request_serializer, response_deserializer)
|
| D | __init__.py | 894 def stream_unary(self, member in Channel
|
| D | _server.py | 545 _unary_response_in_pool, rpc_event, state, method_handler.stream_unary,
|
| /external/python/python-api-core/google/api_core/ |
| D | grpc_helpers.py | 475 def stream_unary(self, method, request_serializer=None, response_deserializer=None): member in ChannelStub
|
| /external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/ |
| D | face.py | 1011 def stream_unary(self, group, method): member in GenericStub
|
| /external/python/python-api-core/tests/unit/ |
| D | test_grpc_helpers.py | 842 callable_stub = channel.stream_unary(method_name)
|