Home
last modified time | relevance | path

Searched refs:unary_unary (Results 1 – 25 of 78) sorted by relevance

1234

/third_party/grpc/src/python/grpcio/grpc/experimental/
D__init__.py104 return handler._replace(unary_unary=wrapper(handler.unary_unary))
124 from grpc._simple_stubs import unary_unary, unary_stream, stream_unary, stream_stream
125 __all__ = __all__ + (unary_unary, unary_stream, stream_unary, stream_stream)
/third_party/grpc/src/python/grpcio_tests/tests_py3_only/unit/
D_simple_stubs_test.py186 response = grpc.experimental.unary_unary(
198 response = grpc.experimental.unary_unary(
216 grpc.experimental.unary_unary(*args, **run_kwargs)
223 response = grpc.experimental.unary_unary(
242 grpc.experimental.unary_unary(
312 response = grpc.experimental.unary_unary(
318 response = grpc.experimental.unary_unary(_REQUEST,
328 response = grpc.experimental.unary_unary(
365 response = grpc.experimental.unary_unary(_REQUEST,
386 response = grpc.experimental.unary_unary(_REQUEST,
/third_party/grpc/src/python/grpcio_tests/tests_aio/unit/
Dclient_unary_unary_interceptor_test.py68 multicallable = channel.unary_unary(
116 multicallable = channel.unary_unary(
145 multicallable = channel.unary_unary(
205 multicallable = channel.unary_unary(
249 multicallable = channel.unary_unary(
293 multicallable = channel.unary_unary(
322 multicallable = channel.unary_unary(
350 multicallable = channel.unary_unary(
384 multicallable = channel.unary_unary(
420 multicallable = channel.unary_unary(
[all …]
Dcompression_test.py121 multicallable = channel.unary_unary(_TEST_UNARY_UNARY)
132 multicallable = channel.unary_unary(_TEST_UNARY_UNARY)
137 multicallable = self._channel.unary_unary(_TEST_UNARY_UNARY)
147 multicallable = self._channel.unary_unary(_TEST_UNARY_UNARY)
162 multicallable = self._channel.unary_unary(
186 multicallable = channel.unary_unary(_TEST_UNARY_UNARY)
Dmetadata_test.py195 multicallable = self._client.unary_unary(_TEST_CLIENT_TO_SERVER)
202 multicallable = self._client.unary_unary(_TEST_SERVER_TO_CLIENT)
211 multicallable = self._client.unary_unary(_TEST_TRAILING_METADATA)
218 multicallable = self._client.unary_unary(_TEST_CLIENT_TO_SERVER)
227 multicallable = self._client.unary_unary(_TEST_CLIENT_TO_SERVER)
235 multicallable = self._client.unary_unary(_TEST_GENERIC_HANDLER)
Dserver_test.py221 unary_unary_call = self._channel.unary_unary(_SIMPLE_UNARY_UNARY)
349 await self._channel.unary_unary(_SIMPLE_UNARY_UNARY)(_REQUEST)
354 call = self._channel.unary_unary(_BLOCK_BRIEFLY)(_REQUEST)
368 call = self._channel.unary_unary(_BLOCK_FOREVER)(_REQUEST)
379 call = self._channel.unary_unary(_BLOCK_BRIEFLY)(_REQUEST)
397 call = self._channel.unary_unary(_BLOCK_FOREVER)(_REQUEST)
419 await self._channel.unary_unary(_SIMPLE_UNARY_UNARY)(_REQUEST)
422 call = self._channel.unary_unary(_UNIMPLEMENTED_METHOD)
452 call = self._channel.unary_unary(_ERROR_WITHOUT_RAISE_IN_UNARY_UNARY)(
497 rpcs.append(channel.unary_unary(_BLOCK_BRIEFLY)(_REQUEST))
Dauth_context_test.py76 response = await channel.unary_unary(_UNARY_UNARY)(_REQUEST)
100 response = await channel.unary_unary(_UNARY_UNARY)(_REQUEST)
136 response = await channel.unary_unary(_UNARY_UNARY)(_REQUEST)
153 response = await channel.unary_unary(_UNARY_UNARY)(_REQUEST)
Dabort_test.py98 method = self._channel.unary_unary(_UNARY_UNARY_ABORT)
112 method = self._channel.unary_unary(_SUPPRESS_ABORT)
123 method = self._channel.unary_unary(_REPLACE_ABORT)
Dchannel_test.py54 hi = channel.unary_unary(
62 hi = channel.unary_unary(
72 hi = channel.unary_unary(
95 hi = channel.unary_unary(
Dcompatibility_test.py208 response = channel.unary_unary('/test/test')(b'\x07\x08')
243 response = await self._async_channel.unary_unary(_ADHOC_METHOD)(_REQUEST
256 call = self._async_channel.unary_unary(_ADHOC_METHOD)(_REQUEST)
269 await self._async_channel.unary_unary(_ADHOC_METHOD)(_REQUEST)
281 await self._async_channel.unary_unary(_ADHOC_METHOD)(_REQUEST)
/third_party/grpc/src/python/grpcio_tests/tests_aio/status/
Dgrpc_status_test.py119 call = self._channel.unary_unary(_STATUS_OK)(_REQUEST)
126 call = self._channel.unary_unary(_STATUS_NOT_OK)(_REQUEST)
137 call = self._channel.unary_unary(_ERROR_DETAILS)(_REQUEST)
154 call = self._channel.unary_unary(_INCONSISTENT)(_REQUEST)
166 await self._channel.unary_unary(_INVALID_CODE)(_REQUEST)
/third_party/grpc/src/python/grpcio_tests/tests/status/
D_grpc_status_test.py128 _, call = self._channel.unary_unary(_STATUS_OK).with_call(_REQUEST)
136 self._channel.unary_unary(_STATUS_NOT_OK).with_call(_REQUEST)
146 self._channel.unary_unary(_ERROR_DETAILS).with_call(_REQUEST)
162 self._channel.unary_unary(_INCONSISTENT).with_call(_REQUEST)
171 self._channel.unary_unary(_INVALID_CODE).with_call(_REQUEST)
/third_party/grpc/src/python/grpcio_tests/tests/unit/
D_abort_test.py109 self._channel.unary_unary(_ABORT)(_REQUEST)
126 self._channel.unary_unary(_ABORT)(_REQUEST)
136 self._channel.unary_unary(_ABORT_WITH_STATUS)(_REQUEST)
145 self._channel.unary_unary(_INVALID_CODE)(_REQUEST)
D_invocation_defects_test.py96 request_deserializer, response_serializer, unary_unary, argument
102 self.unary_unary = unary_unary
156 return channel.unary_unary(_UNARY_UNARY)
176 return channel.unary_unary(_DEFECTIVE_GENERIC_RPC_HANDLER)
D_auth_context_test.py75 response = channel.unary_unary(_UNARY_UNARY)(_REQUEST)
99 response = channel.unary_unary(_UNARY_UNARY)(_REQUEST)
135 response = channel.unary_unary(_UNARY_UNARY)(_REQUEST)
152 response = channel.unary_unary(_UNARY_UNARY)(_REQUEST)
D_metadata_flags_test.py67 self.unary_unary = None
81 self.unary_unary = lambda req, ctx: handle_unary_unary(
111 channel.unary_unary(_UNARY_UNARY).__call__(
118 channel.unary_unary(_UNARY_UNARY).with_call(
125 channel.unary_unary(_UNARY_UNARY).future(
D_empty_message_test.py59 self.unary_unary = None
70 self.unary_unary = handle_unary_unary
102 response = self._channel.unary_unary(_UNARY_UNARY)(_REQUEST)
D_local_credentials_test.py52 channel.unary_unary('/test/method')(b'abc',
71 channel.unary_unary('/test/method')(b'abc',
D_error_message_encoding_test.py47 def unary_unary(self, request, servicer_context): member in _MethodHandler
78 multi_callable = self._channel.unary_unary(_UNARY_UNARY)
D_signal_client.py56 multicallable = channel.unary_unary(UNARY_UNARY)
80 channel.unary_unary(UNARY_UNARY)(_MESSAGE, wait_for_ready=True)
D_xds_credentials_test.py70 response = channel.unary_unary("/test/method")(
85 response = channel.unary_unary("/test/method")(
D_metadata_test.py144 self.unary_unary = None
155 self.unary_unary = lambda x, y: handle_unary_unary(test, x, y)
192 multi_callable = self._channel.unary_unary(_UNARY_UNARY)
D_exit_scenarios.py101 self.unary_unary = None
121 self.unary_unary = hang_unary_unary
216 multi_callable = channel.unary_unary(method)
/third_party/flatbuffers/tests/MyGame/Example/
Dmonster_test_grpc_fb.py13 self.Store = channel.unary_unary(
28 self.GetMinMaxHitPoints = channel.unary_unary(
102 self.Store = channel.unary_unary(
117 self.GetMinMaxHitPoints = channel.unary_unary(
/third_party/grpc/src/python/grpcio_testing/grpc_testing/_channel/
D_channel.py35 def unary_unary(self, member in TestingChannel
75 return _channel_rpc.unary_unary(self._state, method_descriptor)

1234