| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| WorkerServiceImpl.cs | 42 public override async Task RunServer(IAsyncStreamReader<ServerArgs> requestStream, IServerStreamWriter<ServerStatus> responseStream, ServerCallContext context)
48 await responseStream.WriteAsync(new ServerStatus
58 await responseStream.WriteAsync(new ServerStatus
66 public override async Task RunClient(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWriter<ClientStatus> responseStream, ServerCallContext context)
72 await responseStream.WriteAsync(new ClientStatus
80 await responseStream.WriteAsync(new ClientStatus
|
| TestServiceImpl.cs | 49 public override async Task StreamingOutputCall(StreamingOutputCallRequest request, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
57 await responseStream.WriteAsync(response);
74 public override async Task FullDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
84 await responseStream.WriteAsync(response);
89 public override Task HalfDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
|
| BenchmarkServiceImpl.cs | 44 public override async Task StreamingCall(IAsyncStreamReader<SimpleRequest> requestStream, IServerStreamWriter<SimpleResponse> responseStream, ServerCallContext context)
49 await responseStream.WriteAsync(response);
|
| /external/volley/src/main/java/com/android/volley/toolbox/ |
| BaseHttpStack.java | 82 InputStream responseStream = response.getContent();
83 if (responseStream != null) {
85 entity.setContent(responseStream);
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| AsyncDuplexStreamingCall.cs | 32 readonly IAsyncStreamReader<TResponse> responseStream;
42 /// <param name="responseStream">Stream of response values.</param>
48 IAsyncStreamReader<TResponse> responseStream,
55 this.responseStream = responseStream;
65 public IAsyncStreamReader<TResponse> ResponseStream
69 return responseStream;
|
| AsyncServerStreamingCall.cs | 30 readonly IAsyncStreamReader<TResponse> responseStream;
39 /// <param name="responseStream">Stream of response values.</param>
44 public AsyncServerStreamingCall(IAsyncStreamReader<TResponse> responseStream,
50 this.responseStream = responseStream;
60 public IAsyncStreamReader<TResponse> ResponseStream
64 return responseStream;
|
| Calls.cs | 80 var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall);
81 return new AsyncServerStreamingCall<TResponse>(responseStream, asyncCall.ResponseHeadersAsync, asyncCall.GetStatus, asyncCall.GetTrailers, asyncCall.Cancel);
118 var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall);
119 return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream, asyncCall.ResponseHeadersAsync, asyncCall.GetStatus, asyncCall.GetTrailers, asyncCall.Cancel);
|
| ServerMethods.cs | 46 public delegate Task ServerStreamingServerMethod<TRequest, TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStream, ServerCallContext context)
55 public delegate Task DuplexStreamingServerMethod<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> responseStream, ServerCallContext context)
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| CompressionTest.cs | 71 helper.DuplexStreamingHandler = new DuplexStreamingServerMethod<string, string>(async (requestStream, responseStream, context) =>
79 await responseStream.WriteAsync("X");
81 responseStream.WriteOptions = null;
82 await responseStream.WriteAsync("Y");
84 responseStream.WriteOptions = new WriteOptions(WriteFlags.NoCompress);
85 await responseStream.WriteAsync("Z");
105 await call.ResponseStream.ToListAsync();
|
| ResponseHeadersTest.cs | 103 helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>(async (request, responseStream, context) =>
106 await responseStream.WriteAsync("PASS");
113 CollectionAssert.AreEqual(new[] { "PASS" }, await call.ResponseStream.ToListAsync());
119 helper.DuplexStreamingHandler = new DuplexStreamingServerMethod<string, string>(async (requestStream, responseStream, context) =>
124 await responseStream.WriteAsync(requestStream.Current);
135 CollectionAssert.AreEqual(messages, await call.ResponseStream.ToListAsync());
173 helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>(async (request, responseStream, context) =>
175 await responseStream.WriteAsync("A");
184 await responseStream.WriteAsync("B");
188 var responses = await call.ResponseStream.ToListAsync()
[all...] |
| MockServiceHelper.cs | 92 .AddMethod(serverStreamingMethod, (request, responseStream, context) => serverStreamingHandler(request, responseStream, context))
93 .AddMethod(duplexStreamingMethod, (requestStream, responseStream, context) => duplexStreamingHandler(requestStream, responseStream, context))
110 serverStreamingHandler = new ServerStreamingServerMethod<string, string>((request, responseStream, context) =>
116 duplexStreamingHandler = new DuplexStreamingServerMethod<string, string>((requestStream, responseStream, context) =>
|
| ClientServerTest.cs | 191 helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>(async (request, responseStream, context) =>
193 await responseStream.WriteAllAsync(request.Split(new []{' '}));
198 CollectionAssert.AreEqual(new string[] { "A", "B", "C" }, await call.ResponseStream.ToListAsync());
207 helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>((request, responseStream, context) => TaskUtils.CompletedTask);
211 Assert.IsFalse(await call.ResponseStream.MoveNext());
212 Assert.IsFalse(await call.ResponseStream.MoveNext());
218 helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>((request, responseStream, context) =>
226 var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext());
230 var ex2 = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext());
237 helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>((request, responseStream, context) =
[all...] |
| ShutdownHookPendingCallTest.cs | 44 helper.DuplexStreamingHandler = new DuplexStreamingServerMethod<string, string>(async (requestStream, responseStream, context) =>
|
| /external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/util/ |
| AsyncHttpURLConnection.java | 104 InputStream responseStream = connection.getInputStream();
105 String response = drainStream(responseStream);
106 responseStream.close();
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| AsyncCallTest.cs | 387 var responseStream = new ClientResponseStream<string, string>(asyncCall);
388 var readTask = responseStream.MoveNext();
403 var responseStream = new ClientResponseStream<string, string>(asyncCall);
404 var readTask = responseStream.MoveNext();
417 var responseStream = new ClientResponseStream<string, string>(asyncCall);
418 var readTask = responseStream.MoveNext();
430 var responseStream = new ClientResponseStream<string, string>(asyncCall);
432 var readTask1 = responseStream.MoveNext();
435 Assert.AreEqual("response1", responseStream.Current);
437 var readTask2 = responseStream.MoveNext()
[all...] |
| AsyncCallServerTest.cs | 121 var responseStream = new ServerResponseStream<string, string>(asyncCallServer);
126 Assert.Throws(typeof(InvalidOperationException), () => responseStream.WriteAsync("request1"));
134 var responseStream = new ServerResponseStream<string, string>(asyncCallServer);
136 var writeTask = responseStream.WriteAsync("request1");
148 var responseStream = new ServerResponseStream<string, string>(asyncCallServer);
150 var writeTask = responseStream.WriteAsync("request1");
168 var responseStream = new ServerResponseStream<string, string>(asyncCallServer);
171 Assert.ThrowsAsync(typeof(InvalidOperationException), async () => await responseStream.WriteAsync("request1"));
|
| /external/grpc-grpc/src/csharp/Grpc.Examples/ |
| MathServiceImpl.cs | 38 public override async Task Fib(FibArgs request, IServerStreamWriter<Num> responseStream, ServerCallContext context)
47 await responseStream.WriteAsync(fibEnumerator.Current);
63 public override async Task DivMany(IAsyncStreamReader<DivArgs> requestStream, IServerStreamWriter<DivReply> responseStream, ServerCallContext context)
65 await requestStream.ForEachAsync(async divArgs => await responseStream.WriteAsync(DivInternal(divArgs)));
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| ServerCallHandler.cs | 62 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall);
66 var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken);
126 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall);
129 var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken);
134 await handler(request, responseStream, context).ConfigureAwait(false);
160 return new ServerStreamingServerCallHandler<TRequest, TResponse>(method, (request, responseStream, context) => interceptor.ServerStreamingServerHandler(request, responseStream, context, handler));
189 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall);
193 var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken);
252 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall)
[all...] |
| /external/apache-http/android/src/android/net/http/ |
| AndroidHttpClient.java | 219 InputStream responseStream = entity.getContent();
220 if (responseStream == null) return responseStream;
222 if (header == null) return responseStream;
224 if (contentEncoding == null) return responseStream;
225 if (contentEncoding.contains("gzip")) responseStream
226 = new GZIPInputStream(responseStream);
227 return responseStream;
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Testing/ |
| TestCalls.cs | 58 IAsyncStreamReader<TResponse> responseStream, Task<Metadata> responseHeadersAsync,
61 return new AsyncServerStreamingCall<TResponse>(responseStream, responseHeadersAsync, getStatusFunc, getTrailersFunc, disposeAction);
69 IClientStreamWriter<TRequest> requestStream, IAsyncStreamReader<TResponse> responseStream,
73 return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream, responseHeadersAsync, getStatusFunc, getTrailersFunc, disposeAction);
|
| /external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideServer/ |
| RouteGuideImpl.cs | 54 public override async Task ListFeatures(Rectangle request, IServerStreamWriter<Feature> responseStream, ServerCallContext context)
59 await responseStream.WriteAsync(response);
106 public override async Task RouteChat(IAsyncStreamReader<RouteNote> requestStream, IServerStreamWriter<RouteNote> responseStream, ServerCallContext context)
114 await responseStream.WriteAsync(prevNote);
|
| /external/grpc-grpc/examples/node/static_codegen/route_guide/ |
| route_guide_grpc_pb.js | 89 responseStream: false,
106 responseStream: true,
121 responseStream: false,
136 responseStream: true,
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/ |
| ServerInterceptorTest.cs | 113 public override Task ServerStreamingServerHandler<TRequest, TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStream, ServerCallContext context, ServerStreamingServerMethod<TRequest, TResponse> continuation)
116 return continuation(request, responseStream, context);
119 public override Task DuplexStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> responseStream, ServerCallContext context, DuplexStreamingServerMethod<TRequest, TResponse> continuation)
122 return continuation(requestStream, responseStream, context);
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| TestServiceImpl.java | 242 private final StreamObserver<StreamingOutputCallResponse> responseStream;
277 * directly on {@code responseStream} after it is provided to the {@link ResponseDispatcher}.
279 public ResponseDispatcher(StreamObserver<StreamingOutputCallResponse> responseStream) {
281 this.responseStream = responseStream;
320 responseStream.onError(cause);
335 responseStream.onCompleted();
337 responseStream.onNext(chunk.toResponse());
342 // Stream was cancelled by client, responseStream.onError() might be called already or
346 responseStream.onError(e)
[all...] |
| /external/grpc-grpc/examples/node/static_codegen/ |
| helloworld_grpc_pb.js | 51 responseStream: false,
|
