| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_close_test.py | 37 def stream_stream(self, request_iterator, servicer_context): member in _MethodHandler
110 multi_callable = channel.stream_stream('Meffod')
120 multi_callable = channel.stream_stream('Meffod')
132 multi_callable = channel.stream_stream('Meffod')
143 multi_callable = channel.stream_stream('Meffod')
160 multi_callable = channel.stream_stream('Meffod')
|
| D | _compression_test.py | 53 self.stream_stream = None
55 self.stream_stream = handle_stream
113 multi_callable = compressed_channel.stream_stream(_STREAM_STREAM)
|
| D | _empty_message_test.py | 61 self.stream_stream = None
63 self.stream_stream = handle_stream_stream
114 response_iterator = self._channel.stream_stream(_STREAM_STREAM)(iter(
|
| D | _exit_scenarios.py | 103 self.stream_stream = None
106 self.stream_stream = hang_partial_stream_stream
108 self.stream_stream = hang_stream_stream
230 multi_callable = channel.stream_stream(method)
|
| D | _invocation_defects_test.py | 118 unary_stream, stream_unary, stream_stream): argument
126 self.stream_stream = stream_stream
195 return channel.stream_stream(_STREAM_STREAM)
|
| D | _metadata_test.py | 146 self.stream_stream = None
148 self.stream_stream = lambda x, y: handle_stream_stream(test, x, y)
225 multi_callable = self._channel.stream_stream(_STREAM_STREAM)
|
| D | _resource_exhausted_test.py | 104 self.stream_stream = None
106 self.stream_stream = (
229 multi_callable = self._channel.stream_stream(_STREAM_STREAM)
|
| D | _interceptor_test.py | 118 unary_stream, stream_unary, stream_stream): argument
126 self.stream_stream = stream_stream
173 return channel.stream_stream(_STREAM_STREAM)
|
| D | _invalid_metadata_test.py | 52 return channel.stream_stream(_STREAM_STREAM)
|
| D | _rpc_test.py | 122 unary_stream, stream_unary, stream_stream): argument
130 self.stream_stream = stream_stream
177 return channel.stream_stream(_STREAM_STREAM)
|
| D | _metadata_code_details_test.py | 125 def stream_stream(self, request_iterator, context): member in _Servicer
183 servicer.stream_stream,
220 self._stream_stream = channel.stream_stream(
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _channel.py | 53 def stream_stream(self, member in TestingChannel
84 return _channel_rpc.stream_stream(self._state, method_descriptor)
|
| D | _channel_rpc.py | 117 def stream_stream(channel_state, method_descriptor): function
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _beta_features_test.py | 81 def stream_stream(self, request_iterator, context): member in _Servicer
151 utilities.stream_stream_inline(self._servicer.stream_stream),
282 utilities.stream_stream_inline(self._servicer.stream_stream),
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | _service.py | 86 def stream_stream(implementation, rpc, handler, servicer_context): function
|
| D | _server.py | 58 _service.stream_stream(implementation, rpc, handler, servicer_context)
|
| /external/tensorflow/tensorflow/python/debug/lib/ |
| D | debug_service_pb2_grpc.py | 41 self.SendEvents = channel.stream_stream(
|
| /external/grpc-grpc/examples/python/multiplex/ |
| D | route_guide_pb2_grpc.py | 32 self.RouteChat = channel.stream_stream(
|
| /external/grpc-grpc/examples/python/route_guide/ |
| D | route_guide_pb2_grpc.py | 32 self.RouteChat = channel.stream_stream(
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| D | _client_adaptations.py | 276 multi_callable = channel.stream_stream(
638 def stream_stream(self, group, method): member in _GenericStub
674 return self._generic_stub.stream_stream(self._group, attr)
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _interceptor.py | 436 def stream_stream(self, member in _Channel
440 thunk = lambda m: self._channel.stream_stream(m, request_serializer, response_deserializer)
|
| D | __init__.py | 914 def stream_stream(self, member in Channel
|
| D | _server.py | 555 method_handler.stream_stream, lambda: request_iterator,
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/qps/ |
| D | benchmark_client.py | 37 self.StreamingCall = channel.stream_stream(
|
| /external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/ |
| D | face.py | 1024 def stream_stream(self, group, method): member in GenericStub
|