Home
last modified time | relevance | path

Searched refs:multi_callable (Results 1 – 11 of 11) sorted by relevance

/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_rpc_test.py209 multi_callable = _unary_unary_multi_callable(self._channel)
210 response = multi_callable(
220 multi_callable = _unary_unary_multi_callable(self._channel)
221 response, call = multi_callable.with_call(
234 multi_callable = _unary_unary_multi_callable(self._channel)
235 response_future = multi_callable.future(
251 multi_callable = _unary_stream_multi_callable(self._channel)
252 response_iterator = multi_callable(
266 multi_callable = _stream_unary_multi_callable(self._channel)
267 response = multi_callable(
[all …]
D_resource_exhausted_test.py152 multi_callable = self._channel.unary_unary(_UNARY_UNARY)
155 futures.append(multi_callable.future(_REQUEST))
160 multi_callable(_REQUEST)
165 future_exception = multi_callable.future(_REQUEST)
174 self.assertEqual(_RESPONSE, multi_callable(_REQUEST))
177 multi_callable = self._channel.unary_stream(_UNARY_STREAM)
180 calls.append(multi_callable(_REQUEST))
185 next(multi_callable(_REQUEST))
197 new_call = multi_callable(_REQUEST)
202 multi_callable = self._channel.stream_unary(_STREAM_UNARY)
[all …]
D_interceptor_test.py357 multi_callable = _stream_stream_multi_callable(channel)
358 response_iterator = multi_callable(
367 multi_callable = _stream_stream_multi_callable(self._channel)
368 response_iterator = multi_callable(
383 multi_callable = _unary_unary_multi_callable(defective_channel)
384 call_future = multi_callable.future(
406 multi_callable = _unary_unary_multi_callable(channel)
407 multi_callable.with_call(
430 multi_callable = _unary_unary_multi_callable(channel)
431 multi_callable(
[all …]
D_channel_close_test.py110 multi_callable = channel.stream_stream('Meffod')
112 response_iterator = multi_callable(request_iterator)
120 multi_callable = channel.stream_stream('Meffod')
122 response_iterator = multi_callable(request_iterator)
132 multi_callable = channel.stream_stream('Meffod')
134 response_iterator = multi_callable(request_iterator)
143 multi_callable = channel.stream_stream('Meffod')
149 response_iterator = multi_callable(request_iterator)
160 multi_callable = channel.stream_stream('Meffod')
162 response_iterator = multi_callable(request_iterator)
D_exit_scenarios.py213 multi_callable = channel.unary_unary(method) variable
214 future = multi_callable.future(REQUEST)
215 result, call = multi_callable.with_call(REQUEST)
218 multi_callable = channel.unary_stream(method) variable
219 response_iterator = multi_callable(REQUEST)
224 multi_callable = channel.stream_unary(method) variable
225 future = multi_callable.future(infinite_request_iterator())
226 result, call = multi_callable.with_call(
230 multi_callable = channel.stream_stream(method) variable
231 response_iterator = multi_callable(infinite_request_iterator())
D_compression_test.py89 multi_callable = compressed_channel.unary_unary(_UNARY_UNARY)
90 response = multi_callable(request)
100 multi_callable = compressed_channel.unary_unary(_UNARY_UNARY)
101 response = multi_callable(
113 multi_callable = compressed_channel.stream_stream(_STREAM_STREAM)
114 call = multi_callable(iter([request] * test_constants.STREAM_LENGTH))
D_invocation_defects_test.py220 multi_callable = _stream_unary_multi_callable(self._channel)
223 response = multi_callable(
230 multi_callable = _stream_unary_multi_callable(self._channel)
231 response_future = multi_callable.future(
240 multi_callable = _stream_stream_multi_callable(self._channel)
241 response_iterator = multi_callable(
251 multi_callable = _stream_stream_multi_callable(self._channel)
252 response_iterator = multi_callable(
262 multi_callable = _defective_handler_multi_callable(self._channel)
265 response = multi_callable(
D_metadata_test.py190 multi_callable = self._channel.unary_unary(_UNARY_UNARY)
191 unused_response, call = multi_callable.with_call(
201 multi_callable = self._channel.unary_stream(_UNARY_STREAM)
202 call = multi_callable(_REQUEST, metadata=_INVOCATION_METADATA)
213 multi_callable = self._channel.stream_unary(_STREAM_UNARY)
214 unused_response, call = multi_callable.with_call(
225 multi_callable = self._channel.stream_stream(_STREAM_STREAM)
226 call = multi_callable(
D_reconnect_test.py89 multi_callable = channel.unary_unary(_UNARY_UNARY)
90 self.assertEqual(_RESPONSE, multi_callable(_REQUEST))
99 self.assertEqual(_RESPONSE, multi_callable(_REQUEST))
D_invalid_metadata_test.py109 multi_callable = _stream_unary_multi_callable(self._channel)
111 multi_callable.with_call(request_iterator, metadata=metadata)
/external/grpc-grpc/src/python/grpcio/grpc/beta/
D_client_adaptations.py176 multi_callable = channel.unary_unary(
182 response, call = multi_callable.with_call(
189 return multi_callable(
201 multi_callable = channel.unary_unary(
206 response_future = multi_callable.future(
217 multi_callable = channel.unary_stream(
222 response_iterator = multi_callable(
235 multi_callable = channel.stream_unary(
241 response, call = multi_callable.with_call(
248 return multi_callable(
[all …]