Home
last modified time | relevance | path

Searched refs:unary_stream (Results 1 – 25 of 46) sorted by relevance

12

/third_party/grpc/src/python/grpcio/grpc/experimental/
D__init__.py106 return handler._replace(unary_stream=wrapper(handler.unary_stream))
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/unit/
D_empty_message_test.py60 self.unary_stream = None
68 self.unary_stream = handle_unary_stream
106 response_iterator = self._channel.unary_stream(_UNARY_STREAM)(_REQUEST)
D_exit_scenarios.py102 self.unary_stream = None
117 self.unary_stream = hang_partial_unary_stream
119 self.unary_stream = hang_unary_stream
221 multi_callable = channel.unary_stream(method)
D_invocation_defects_test.py97 unary_stream, stream_unary, stream_stream): argument
103 self.unary_stream = unary_stream
160 return channel.unary_stream(_UNARY_STREAM,
D_signal_client.py69 per_process_rpc_future = channel.unary_stream(UNARY_STREAM)(
93 for _ in channel.unary_stream(UNARY_STREAM)(_MESSAGE,
D_rpc_test_helpers.py158 unary_stream, stream_unary, stream_stream): argument
164 self.unary_stream = unary_stream
207 return channel.unary_stream(_UNARY_STREAM,
213 return channel.unary_stream(_UNARY_STREAM_NON_BLOCKING,
D_metadata_test.py145 self.unary_stream = None
153 self.unary_stream = lambda x, y: handle_unary_stream(test, x, y)
203 multi_callable = self._channel.unary_stream(_UNARY_STREAM)
D_metadata_flags_test.py68 self.unary_stream = None
78 self.unary_stream = lambda req, ctx: handle_unary_stream(
133 response_iterator = channel.unary_stream(_UNARY_STREAM).__call__(
D_resource_exhausted_test.py103 self.unary_stream = None
112 self.unary_stream = lambda x, y: handle_unary_stream(trigger, x, y)
179 multi_callable = self._channel.unary_stream(_UNARY_STREAM)
D_compression_test.py141 self.unary_stream = None
151 self.unary_stream = _make_handle_unary_stream(pre_response_callback)
234 multi_callable = channel.unary_stream(_UNARY_STREAM)
D_error_message_encoding_test.py43 self.unary_stream = None
D_interceptor_test.py134 unary_stream, stream_unary, stream_stream): argument
140 self.unary_stream = unary_stream
175 return channel.unary_stream(_UNARY_STREAM,
/third_party/grpc/src/python/grpcio_testing/grpc_testing/_channel/
D_channel.py41 def unary_stream(self, member in TestingChannel
78 return _channel_rpc.unary_stream(self._state, method_descriptor)
D_channel_rpc.py105 def unary_stream(channel_state, method_descriptor): function
/third_party/flatbuffers/tests/MyGame/Example/
Dmonster_test_grpc_fb.py18 self.Retrieve = channel.unary_stream(
107 self.Retrieve = channel.unary_stream(
/third_party/flatbuffers/grpc/examples/python/greeter/models/
Dgreeter_grpc_fb.py19 self.SayManyHellos = channel.unary_stream(
/third_party/grpc/src/python/grpcio_tests/tests/unit/beta/
D_beta_features_test.py59 def unary_stream(self, request, context): member in _Servicer
148 utilities.unary_stream_inline(self._servicer.unary_stream),
281 utilities.unary_stream_inline(self._servicer.unary_stream),
/third_party/grpc/src/python/grpcio_tests/tests_aio/unit/
Dtimeout_test.py121 multicallable = self._client.unary_stream(_TEST_SLEEPY_UNARY_STREAM)
128 multicallable = self._client.unary_stream(_TEST_SLEEPY_UNARY_STREAM)
/third_party/grpc/src/python/grpcio_testing/grpc_testing/_server/
D_service.py78 def unary_stream(implementation, rpc, request, servicer_context): function
/third_party/grpc/examples/python/data_transmission/
Ddemo_pb2_grpc.py28 self.ServerStreamingMethod = channel.unary_stream(
/third_party/grpc/examples/python/multiplex/
Droute_guide_pb2_grpc.py22 self.ListFeatures = channel.unary_stream(
/third_party/grpc/examples/python/route_guide/
Droute_guide_pb2_grpc.py22 self.ListFeatures = channel.unary_stream(
/third_party/grpc/src/python/grpcio/grpc/
D_simple_stubs.py250 def unary_stream( function
319 multicallable = channel.unary_stream(method, request_serializer,
/third_party/grpc/src/python/grpcio/grpc/experimental/aio/
D_base_channel.py287 def unary_stream( member in Channel
/third_party/grpc/src/python/grpcio/grpc/aio/
D_base_channel.py291 def unary_stream( member in Channel

12