Home
last modified time | relevance | path

Searched refs:responses (Results 1 – 25 of 282) sorted by relevance

12345678910>>...12

/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/
D_python_plugin_test.py35 import tests.protoc_plugin.protos.responses.test_responses_pb2 as response_pb2
109 responses = []
116 responses.append(response)
117 for response in responses:
307 responses = service.stub.StreamingOutputCall(request)
311 expected_responses, responses):
319 responses = service.stub.StreamingOutputCall(
322 list(responses)
330 responses = service.stub.StreamingOutputCall(request)
331 next(responses)
[all …]
Dbeta_python_plugin_test.py177 responses = []
184 responses.append(response)
185 for response in responses:
432 responses = stub.StreamingOutputCall(request,
437 expected_responses, responses):
447 responses = stub.StreamingOutputCall(
450 list(responses)
458 responses = stub.StreamingOutputCall(request,
460 next(responses)
461 responses.cancel()
[all …]
/external/bouncycastle/bcprov/src/main/java/org/bouncycastle/asn1/ocsp/
DResponseData.java25 private ASN1Sequence responses; field in ResponseData
32 ASN1Sequence responses, in ResponseData() argument
38 this.responses = responses; in ResponseData()
52 ASN1Sequence responses, in ResponseData() argument
55 …this(V1, responderID, ASN1GeneralizedTime.getInstance(producedAt), responses, Extensions.getInstan… in ResponseData()
61 ASN1Sequence responses, in ResponseData() argument
64 this(V1, responderID, producedAt, responses, responseExtensions); in ResponseData()
95 this.responses = (ASN1Sequence)seq.getObjectAt(index++); in ResponseData()
143 return responses; in getResponses()
173 v.add(responses); in toASN1Primitive()
/external/grpc-grpc/src/python/grpcio_tests/tests/reflection/
D_reflection_servicer_test.py69 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
83 self.assertSequenceEqual(expected_responses, responses)
93 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
107 self.assertSequenceEqual(expected_responses, responses)
122 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
136 self.assertSequenceEqual(expected_responses, responses)
146 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
161 self.assertSequenceEqual(expected_responses, responses)
165 responses = tuple(self._stub.ServerReflectionInfo(iter(requests)))
172 self.assertSequenceEqual(expected_responses, responses)
/external/skia/modules/canvaskit/perf/
Danimation.bench.js45 Promise.all(promises).then((responses) => {
48 jsonStr = responses[0];
76 Promise.all(promises).then((responses) => {
79 jsonStr = responses[0];
102 Promise.all(promises).then((responses) => {
105 jsonStr = responses[0];
137 Promise.all(promises).then((responses) => {
140 jsonStr = responses[0];
/external/skqp/experimental/canvaskit/perf/
Danimation.bench.js63 Promise.all(promises).then((responses) => {
66 jsonStr = responses[0];
94 Promise.all(promises).then((responses) => {
97 jsonStr = responses[0];
120 Promise.all(promises).then((responses) => {
123 jsonStr = responses[0];
155 Promise.all(promises).then((responses) => {
158 jsonStr = responses[0];
/external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/
DShadowTypedArrayTest.java128 .addAttribute(R.attr.responses, "@array/greetings") in getTextArray_shouldReturnValues()
130 new int[]{R.attr.responses}); in getTextArray_shouldReturnValues()
137 .addAttribute(R.attr.responses, "@array/greetings") in hasValue_withValue()
139 new int[]{R.attr.responses}); in hasValue_withValue()
146 new int[]{R.attr.responses}); in hasValue_withoutValue()
153 .addAttribute(R.attr.responses, AttributeResource.NULL_VALUE) in hasValue_withNullValue()
155 new int[]{R.attr.responses}); in hasValue_withNullValue()
162 .addAttribute(R.attr.responses, "@array/greetings") in shouldEnumeratePresentValues()
165 new int[]{R.attr.scrollBars, R.attr.responses, R.attr.isSugary}); in shouldEnumeratePresentValues()
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/
DRecordingOkAuthenticator.java26 public final List<Response> responses = new ArrayList<>(); field in RecordingOkAuthenticator
35 if (responses.size() != 1) throw new IllegalStateException(); in onlyResponse()
36 return responses.get(0); in onlyResponse()
45 responses.add(response); in authenticate()
53 responses.add(response); in authenticateProxy()
/external/grpc-grpc/src/ruby/spec/generic/
Dclient_interceptors_spec.rb93 responses = stub.a_server_streaming_rpc(request)
94 responses.each do |r|
110 responses = stub.a_server_streaming_rpc(request)
111 responses.each do |r|
128 responses = stub.a_bidi_rpc(requests)
129 responses.each do |r|
145 responses = stub.a_bidi_rpc(requests)
146 responses.each do |r|
Dserver_interceptors_spec.rb111 responses = stub.a_server_streaming_rpc(request)
112 responses.each do |r|
129 responses = op.execute
130 responses.each do |r|
151 responses = stub.a_bidi_rpc(requests)
152 responses.each do |r|
169 responses = op.execute
170 responses.each do |r|
Dclient_stub_spec.rb584 @op, @server_initial_md, @server_trailing_md) do |responses|
585 responses.each { |r| GRPC.logger.info(r) }
592 @op, @server_initial_md, @server_trailing_md) do |responses|
593 responses.each { |r| GRPC.logger.info(r) }
810 responses = get_responses(stub)
821 expect { responses.next }.to raise_error(GRPC::BadStatus)
844 responses = get_responses(stub)
845 expect(responses.next).to eq('message')
848 expect { responses.next }.to raise_error(GRPC::BadStatus)
901 @op, @server_initial_md, @server_trailing_md) do |responses|
[all …]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
DRecordingCallback.java30 private final List<RecordedResponse> responses = new ArrayList<>(); field in RecordingCallback
33 responses.add(new RecordedResponse(request, null, null, null, e)); in onFailure()
39 responses.add(new RecordedResponse(response.request(), response, null, body, null)); in onResponse()
50 for (Iterator<RecordedResponse> i = responses.iterator(); i.hasNext(); ) { in await()
67 for (RecordedResponse recordedResponse : responses) { in assertNoResponse()
/external/tensorflow/tensorflow/lite/models/smartreply/demo/app/src/main/
Dsmartreply_jni.cc88 std::vector<PredictorResponse> responses; in Java_com_example_android_smartreply_SmartReplyClient_predictJNI() local
90 *storage->model, {storage->backoff_list}, &responses); in Java_com_example_android_smartreply_SmartReplyClient_predictJNI()
105 env, env->NewObjectArray(responses.size(), smart_reply_class, nullptr)); in Java_com_example_android_smartreply_SmartReplyClient_predictJNI()
109 for (int i = 0; i < responses.size(); i++) { in Java_com_example_android_smartreply_SmartReplyClient_predictJNI()
111 CheckNotNull(env, env->NewStringUTF(responses[i].GetText().data())); in Java_com_example_android_smartreply_SmartReplyClient_predictJNI()
116 responses[i].GetScore()); in Java_com_example_android_smartreply_SmartReplyClient_predictJNI()
/external/grpc-grpc/src/csharp/Grpc.Examples.Tests/
DMathClientServerTests.cs97 var responses = await call.ResponseStream.ToListAsync(); in Fib()
99 responses.Select((n) => n.Num_)); in Fib()
110 List<long> responses = new List<long>(); in FibWithCancel()
116 if (responses.Count == 0) in FibWithCancel()
120 responses.Add(call.ResponseStream.Current.Num_); in FibWithCancel()
126 Assert.IsTrue(responses.Count > 0); in FibWithCancel()
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/protos/service/
Dtest_service.proto18 import "tests/protoc_plugin/protos/responses/test_responses.proto";
27 // One request followed by a sequence of responses (streamed download).
38 // As one request could lead to multiple responses, this interface
43 // A sequence of requests followed by a sequence of responses.
45 // stream of responses are returned to the client when the server starts with
/external/grpc-grpc/src/objective-c/examples/RemoteTestClient/
Dtest.proto16 // of unary/streaming requests/responses.
35 // One request followed by a sequence of responses (streamed download).
46 // As one request could lead to multiple responses, this interface
51 // A sequence of requests followed by a sequence of responses.
53 // stream of responses are returned to the client when the server starts with
/external/grpc-grpc/src/objective-c/tests/RemoteTestClient/
Dtest.proto16 // of unary/streaming requests/responses.
35 // One request followed by a sequence of responses (streamed download).
46 // As one request could lead to multiple responses, this interface
51 // A sequence of requests followed by a sequence of responses.
53 // stream of responses are returned to the client when the server starts with
/external/grpc-grpc/src/ruby/spec/
Dclient_auth_spec.rb118 responses = @stub.a_server_streaming_rpc(EchoMsg.new)
119 responses.each { |r| GRPC.logger.info(r) }
123 responses = @stub.a_bidi_rpc([EchoMsg.new, EchoMsg.new])
124 responses.each { |r| GRPC.logger.info(r) }
/external/autotest/client/cros/cellular/mbim_compliance/
Dmbim_channel_unittest.py289 def _queue_responses(self, responses): argument
291 for response in responses:
295 def _expect_transaction(self, requests, responses=None): argument
309 if responses:
311 lambda _: self._queue_responses(responses))
316 def _verify_transaction_successful(self, requests, responses): argument
324 self.assertEqual(responses,
/external/robolectric-shadows/shadows/httpclient/src/main/java/org/robolectric/shadows/httpclient/
DFakeHttpLayer.java81 …c void addHttpResponseRule(RequestMatcher requestMatcher, List<? extends HttpResponse> responses) { in addHttpResponseRule() argument
82 addHttpResponseRule(new RequestMatcherResponseRule(requestMatcher, responses)); in addHttpResponseRule()
280 private List<? extends HttpResponse> responses; field in FakeHttpLayer.RequestMatcherResponseRule
297 …RequestMatcherResponseRule(RequestMatcher requestMatcher, List<? extends HttpResponse> responses) { in RequestMatcherResponseRule() argument
299 this.responses = responses; in RequestMatcherResponseRule()
314 if (responses.isEmpty()) { in getResponse()
317 return responses.remove(0); in getResponse()
/external/python/cpython3/Lib/test/
Dtest_urllib2_localnet.py396 def GetRequestHandler(responses): argument
420 response_code, headers, body = responses.pop(0)
476 def start_server(self, responses=None): argument
477 if responses is None:
478 responses = [(200, [], b"we don't care")]
479 handler = GetRequestHandler(responses)
489 def start_https_server(self, responses=None, **kwargs): argument
493 if responses is None:
494 responses = [(200, [], b"we care a bit")]
495 handler = GetRequestHandler(responses)
[all …]
/external/grpc-grpc/src/proto/grpc/testing/
Dtest.proto17 // of unary/streaming requests/responses.
40 // One request followed by a sequence of responses (streamed download).
51 // As one request could lead to multiple responses, this interface
56 // A sequence of requests followed by a sequence of responses.
58 // stream of responses are returned to the client when the server starts with
/external/grpc-grpc-java/interop-testing/src/main/proto/grpc/testing/
Dtest.proto15 // of unary/streaming requests/responses.
39 // One request followed by a sequence of responses (streamed download).
50 // As one request could lead to multiple responses, this interface
55 // A sequence of requests followed by a sequence of responses.
57 // stream of responses are returned to the client when the server starts with
/external/openssh/
Dauth-bsdauth.c98 bsdauth_respond(void *ctx, u_int numresponses, char **responses) in bsdauth_respond() argument
112 authok = auth_userresponse(authctxt->as, responses[0], 0); in bsdauth_respond()
114 debug3("bsdauth_respond: <%s> = <%d>", responses[0], authok); in bsdauth_respond()
/external/grpc-grpc-java/compiler/src/test/proto/grpc/testing/compiler/
Dtest.proto47 // One request followed by a sequence of responses (streamed download).
58 // As one request could lead to multiple responses, this interface
63 // A sequence of requests followed by a sequence of responses.
65 // stream of responses are returned to the client when the server starts with

12345678910>>...12