| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _empty_message_test.py | 59 self.unary_stream = None
67 self.unary_stream = handle_unary_stream
104 response_iterator = self._channel.unary_stream(_UNARY_STREAM)(_REQUEST)
|
| D | _exit_scenarios.py | 101 self.unary_stream = None
116 self.unary_stream = hang_partial_unary_stream
118 self.unary_stream = hang_unary_stream
218 multi_callable = channel.unary_stream(method)
|
| D | _invocation_defects_test.py | 118 unary_stream, stream_unary, stream_stream): argument
124 self.unary_stream = unary_stream
181 return channel.unary_stream(
|
| D | _metadata_test.py | 144 self.unary_stream = None
152 self.unary_stream = lambda x, y: handle_unary_stream(test, x, y)
201 multi_callable = self._channel.unary_stream(_UNARY_STREAM)
|
| D | _resource_exhausted_test.py | 102 self.unary_stream = None
111 self.unary_stream = lambda x, y: handle_unary_stream(trigger, x, y)
177 multi_callable = self._channel.unary_stream(_UNARY_STREAM)
|
| D | _interceptor_test.py | 118 unary_stream, stream_unary, stream_stream): argument
124 self.unary_stream = unary_stream
159 return channel.unary_stream(
|
| D | _compression_test.py | 51 self.unary_stream = None
|
| D | _rpc_test.py | 122 unary_stream, stream_unary, stream_stream): argument
128 self.unary_stream = unary_stream
163 return channel.unary_stream(
|
| D | _invalid_metadata_test.py | 38 return channel.unary_stream(
|
| D | _metadata_code_details_test.py | 88 def unary_stream(self, request, context): member in _Servicer
178 grpc.unary_stream_rpc_method_handler(servicer.unary_stream),
210 self._unary_stream = channel.unary_stream('/'.join((
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _channel.py | 41 def unary_stream(self, member in TestingChannel
78 return _channel_rpc.unary_stream(self._state, method_descriptor)
|
| D | _channel_rpc.py | 105 def unary_stream(channel_state, method_descriptor): function
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _beta_features_test.py | 59 def unary_stream(self, request, context): member in _Servicer
147 utilities.unary_stream_inline(self._servicer.unary_stream),
278 utilities.unary_stream_inline(self._servicer.unary_stream),
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | _service.py | 77 def unary_stream(implementation, rpc, request, servicer_context): function
|
| D | _server.py | 42 _service.unary_stream(implementation, rpc, request, servicer_context)
|
| /external/grpc-grpc/examples/python/multiplex/ |
| D | route_guide_pb2_grpc.py | 22 self.ListFeatures = channel.unary_stream(
|
| /external/grpc-grpc/examples/python/route_guide/ |
| D | route_guide_pb2_grpc.py | 22 self.ListFeatures = channel.unary_stream(
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| D | _client_adaptations.py | 217 multi_callable = channel.unary_stream(
612 def unary_stream(self, group, method): member in _GenericStub
670 return self._generic_stub.unary_stream(self._group, attr)
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 416 def unary_stream(self, member in _Channel
420 thunk = lambda m: self._channel.unary_stream(m, request_serializer, response_deserializer)
|
| D | __init__.py | 874 def unary_stream(self, member in Channel
|
| D | _server.py | 536 method_handler.unary_stream, unary_request,
|
| D | _channel.py | 930 def unary_stream(self, member in Channel
|
| /external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/ |
| D | face.py | 998 def unary_stream(self, group, method): member in GenericStub
|