Home
last modified time | relevance | path

Searched refs:_channel (Results 1 – 25 of 73) sorted by relevance

123

/third_party/grpc/src/python/grpcio_tests/tests/unit/
D_rpc_part_2_test.py37 unary_stream_multi_callable(self._channel))
42 unary_stream_non_blocking_multi_callable(self._channel))
49 self._channel.unary_unary('NoSuchMethod')(request)
58 multi_callable = unary_unary_multi_callable(self._channel)
69 multi_callable = unary_unary_multi_callable(self._channel)
83 multi_callable = unary_unary_multi_callable(self._channel)
100 multi_callable = unary_stream_multi_callable(self._channel)
115 multi_callable = stream_unary_multi_callable(self._channel)
130 multi_callable = stream_unary_multi_callable(self._channel)
147 multi_callable = stream_unary_multi_callable(self._channel)
[all …]
D_rpc_part_1_test.py40 multi_callable = stream_unary_multi_callable(self._channel)
63 multi_callable = stream_unary_multi_callable(self._channel)
89 stream_stream_multi_callable(self._channel))
93 stream_stream_non_blocking_multi_callable(self._channel))
98 multi_callable = unary_unary_multi_callable(self._channel)
120 multi_callable = unary_unary_multi_callable(self._channel)
142 unary_stream_multi_callable(self._channel))
146 unary_stream_non_blocking_multi_callable(self._channel))
153 multi_callable = stream_unary_multi_callable(self._channel)
170 multi_callable = stream_unary_multi_callable(self._channel)
[all …]
D_rpc_test.py245 self._channel = grpc.insecure_channel('localhost:%d' % port)
249 self._channel.close()
253 _unary_stream_multi_callable(self._channel))
258 _unary_stream_non_blocking_multi_callable(self._channel))
265 self._channel.unary_unary('NoSuchMethod')(request)
274 multi_callable = _unary_unary_multi_callable(self._channel)
285 multi_callable = _unary_unary_multi_callable(self._channel)
299 multi_callable = _unary_unary_multi_callable(self._channel)
316 multi_callable = _unary_stream_multi_callable(self._channel)
331 multi_callable = _stream_unary_multi_callable(self._channel)
[all …]
D_invalid_metadata_test.py57 self._channel = grpc.insecure_channel('localhost:8080')
58 self._unary_unary = _unary_unary_multi_callable(self._channel)
59 self._unary_stream = _unary_stream_multi_callable(self._channel)
60 self._stream_unary = _stream_unary_multi_callable(self._channel)
61 self._stream_stream = _stream_stream_multi_callable(self._channel)
64 self._channel.close()
111 multi_callable = _stream_unary_multi_callable(self._channel)
D_empty_message_test.py95 self._channel = grpc.insecure_channel('localhost:%d' % port)
99 self._channel.close()
102 response = self._channel.unary_unary(_UNARY_UNARY)(_REQUEST)
106 response_iterator = self._channel.unary_stream(_UNARY_STREAM)(_REQUEST)
111 response = self._channel.stream_unary(_STREAM_UNARY)(iter(
116 response_iterator = self._channel.stream_stream(_STREAM_STREAM)(iter(
D_abort_test.py101 self._channel = grpc.insecure_channel('localhost:%d' % port)
104 self._channel.close()
109 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_metadata_test.py21 from grpc import _channel
98 user_agent.startswith('primary-agent ' + _channel._USER_AGENT))
184 self._channel = grpc.insecure_channel('localhost:%d' % port,
189 self._channel.close()
192 multi_callable = self._channel.unary_unary(_UNARY_UNARY)
203 multi_callable = self._channel.unary_stream(_UNARY_STREAM)
215 multi_callable = self._channel.stream_unary(_STREAM_UNARY)
227 multi_callable = self._channel.stream_stream(_STREAM_STREAM)
D_interceptor_test.py365 self._channel = grpc.insecure_channel('localhost:%d' % port)
370 self._channel.close()
385 channel = grpc.intercept_channel(self._channel, interceptor)
399 multi_callable = _stream_stream_multi_callable(self._channel)
411 defective_channel = grpc.intercept_channel(self._channel, interceptor)
428 self._channel, _append_request_header_interceptor('secret', '42'))
454 self._channel, _LoggingInterceptor('c1', self._record),
474 self._channel, _LoggingInterceptor('c1', self._record),
495 self._channel, _LoggingInterceptor('c1', self._record),
517 self._channel, _LoggingInterceptor('c1', self._record),
[all …]
D_invocation_defects_test.py191 self._channel = grpc.insecure_channel('localhost:%d' % port)
195 self._channel.close()
199 multi_callable = _stream_unary_multi_callable(self._channel)
212 multi_callable = _stream_unary_multi_callable(self._channel)
225 multi_callable = _stream_stream_multi_callable(self._channel)
239 multi_callable = _stream_stream_multi_callable(self._channel)
253 multi_callable = _defective_handler_multi_callable(self._channel)
/third_party/grpc/src/python/grpcio/grpc/aio/
D_channel.py67 _channel: cygrpc.AioChannel
85 self._channel = channel
123 self._channel, self._method,
129 wait_for_ready, self._channel, self._method,
155 wait_for_ready, self._channel, self._method,
161 wait_for_ready, self._channel, self._method,
186 credentials, wait_for_ready, self._channel,
192 credentials, wait_for_ready, self._channel, self._method,
217 credentials, wait_for_ready, self._channel,
223 credentials, wait_for_ready, self._channel, self._method,
[all …]
/third_party/grpc/src/python/grpcio/grpc/experimental/aio/
D_channel.py67 _channel: cygrpc.AioChannel
85 self._channel = channel
122 self._channel, self._method,
128 wait_for_ready, self._channel, self._method,
153 wait_for_ready, self._channel, self._method,
159 wait_for_ready, self._channel, self._method,
183 credentials, wait_for_ready, self._channel,
189 credentials, wait_for_ready, self._channel, self._method,
213 credentials, wait_for_ready, self._channel,
219 credentials, wait_for_ready, self._channel, self._method,
[all …]
/third_party/grpc/src/python/grpcio_tests/tests_aio/unit/
Dserver_test.py214 self._channel = aio.insecure_channel(addr)
217 await self._channel.close()
221 unary_unary_call = self._channel.unary_unary(_SIMPLE_UNARY_UNARY)
226 unary_stream_call = self._channel.unary_stream(_UNARY_STREAM_ASYNC_GEN)
238 unary_stream_call = self._channel.unary_stream(
249 unary_stream_call = self._channel.unary_stream(
262 stream_unary_call = self._channel.stream_unary(_STREAM_UNARY_ASYNC_GEN)
274 stream_unary_call = self._channel.stream_unary(
287 stream_unary_call = self._channel.stream_unary(
300 stream_stream_call = self._channel.stream_stream(
[all …]
Dchannel_ready_test.py37 self._channel = aio.insecure_channel(f"{address}:{self._port}")
41 await self._channel.close()
46 self._channel.channel_ready())
50 self._channel, grpc.ChannelConnectivity.TRANSIENT_FAILURE)
63 await asyncio.wait_for(self._channel.channel_ready(),
Dabort_test.py91 self._channel = aio.insecure_channel(address)
94 await self._channel.close()
98 method = self._channel.unary_unary(_UNARY_UNARY_ABORT)
112 method = self._channel.unary_unary(_SUPPRESS_ABORT)
123 method = self._channel.unary_unary(_REPLACE_ABORT)
134 method = self._channel.unary_stream(_ABORT_AFTER_REPLY)
Dcompression_test.py111 self._channel = aio.insecure_channel(self._address)
114 await self._channel.close()
137 multicallable = self._channel.unary_unary(_TEST_UNARY_UNARY)
147 multicallable = self._channel.unary_unary(_TEST_UNARY_UNARY)
154 multicallable = self._channel.stream_stream(_TEST_SET_COMPRESSION)
162 multicallable = self._channel.unary_unary(
169 multicallable = self._channel.stream_stream(
/third_party/grpc/src/python/grpcio_testing/grpc_testing/_channel/
D__init__.py15 from grpc_testing._channel import _channel
16 from grpc_testing._channel import _channel_state
22 return _channel.TestingChannel(time, _channel_state.State())
/third_party/grpc/src/csharp/Grpc.HealthCheck.Tests/
DTestResponseStreamWriter.cs28 private readonly Channel<HealthCheckResponse> _channel; field in Grpc.HealthCheck.Tests.TestResponseStreamWriter
33 …_channel = System.Threading.Channels.Channel.CreateBounded<HealthCheckResponse>(new BoundedChannel… in TestResponseStreamWriter()
44 public ChannelReader<HealthCheckResponse> WrittenMessagesReader => _channel.Reader;
55 await _channel.Writer.WriteAsync(message); in WriteAsync()
68 _channel.Writer.Complete(); in Complete()
/third_party/grpc/src/python/grpcio/grpc/beta/
D_client_adaptations.py291 self._channel = channel
304 return _blocking_unary_unary(self._channel, self._group, self._method,
311 return _future_unary_unary(self._channel, self._group, self._method,
331 self._channel = channel
339 return _unary_stream(self._channel, self._group, self._method, timeout,
359 self._channel = channel
372 return _blocking_stream_unary(self._channel, self._group, self._method,
384 return _future_stream_unary(self._channel, self._group, self._method,
403 self._channel = channel
415 return _stream_stream(self._channel, self._group, self._method, timeout,
[all …]
Dutilities.py33 self._channel = channel
62 self._channel.unsubscribe(self._update)
77 self._channel.unsubscribe(self._update)
124 self._channel.subscribe(self._update, try_to_connect=True)
129 self._channel.unsubscribe(self._update)
/third_party/grpc/src/python/grpcio_tests/tests_aio/status/
Dgrpc_status_test.py112 self._channel = aio.insecure_channel('localhost:%d' % port)
116 await self._channel.close()
119 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.py121 self._channel = grpc.insecure_channel('localhost:%d' % port)
125 self._channel.close()
128 _, 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_aio/interop/
Dlocal_interop_test.py100 self._channel = aio.insecure_channel(address)
101 self._stub = test_pb2_grpc.TestServiceStub(self._channel)
104 await self._channel.close()
123 self._channel = aio.secure_channel(address, channel_credentials,
125 self._stub = test_pb2_grpc.TestServiceStub(self._channel)
128 await self._channel.close()
/third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/
D_channel_test.py24 def _channel(): function
35 channel = _channel()
53 channel = _channel()
61 channel = _channel()
/third_party/grpc/src/python/grpcio/grpc/
D_utilities.py66 self._channel = channel
95 self._channel.unsubscribe(self._update)
112 self._channel.unsubscribe(self._update)
158 self._channel.subscribe(self._update, try_to_connect=True)
163 self._channel.unsubscribe(self._update)
/third_party/grpc/examples/python/errors/test/
D_error_handling_example_test.py39 self._channel = grpc.insecure_channel('localhost:%d' % port)
42 self._channel.close()
46 stub = helloworld_pb2_grpc.GreeterStub(self._channel)

123