Home
last modified time | relevance | path

Searched refs:responseStream (Results 1 – 25 of 44) sorted by relevance

12

/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/
DAsyncCallTest.cs387 var responseStream = new ClientResponseStream<string, string>(asyncCall); in ServerStreaming_NoResponse_Success1()
388 var readTask = responseStream.MoveNext(); in ServerStreaming_NoResponse_Success1()
403 var responseStream = new ClientResponseStream<string, string>(asyncCall); in ServerStreaming_NoResponse_Success2()
404 var readTask = responseStream.MoveNext(); in ServerStreaming_NoResponse_Success2()
417 var responseStream = new ClientResponseStream<string, string>(asyncCall); in ServerStreaming_NoResponse_ReadFailure()
418 var readTask = responseStream.MoveNext(); in ServerStreaming_NoResponse_ReadFailure()
430 var responseStream = new ClientResponseStream<string, string>(asyncCall); in ServerStreaming_MoreResponses_Success()
432 var readTask1 = responseStream.MoveNext(); in ServerStreaming_MoreResponses_Success()
435 Assert.AreEqual("response1", responseStream.Current); in ServerStreaming_MoreResponses_Success()
437 var readTask2 = responseStream.MoveNext(); in ServerStreaming_MoreResponses_Success()
[all …]
DAsyncCallServerTest.cs121 var responseStream = new ServerResponseStream<string, string>(asyncCallServer); in WriteAfterCancelNotificationFails()
126 … Assert.Throws(typeof(InvalidOperationException), () => responseStream.WriteAsync("request1")); in WriteAfterCancelNotificationFails()
134 var responseStream = new ServerResponseStream<string, string>(asyncCallServer); in WriteCompletionFailureThrows()
136 var writeTask = responseStream.WriteAsync("request1"); in WriteCompletionFailureThrows()
148 var responseStream = new ServerResponseStream<string, string>(asyncCallServer); in WriteAndWriteStatusCanRunConcurrently()
150 var writeTask = responseStream.WriteAsync("request1"); in WriteAndWriteStatusCanRunConcurrently()
168 var responseStream = new ServerResponseStream<string, string>(asyncCallServer); in WriteAfterWriteStatusThrowsInvalidOperationException()
171 …Assert.ThrowsAsync(typeof(InvalidOperationException), async () => await responseStream.WriteAsync(… in WriteAfterWriteStatusThrowsInvalidOperationException()
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DServerCallHandler.cs62 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall); in HandleCall()
66 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
126 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall); in HandleCall()
129 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
134 await handler(request, responseStream, context).ConfigureAwait(false); in HandleCall()
160 … TResponse>(method, (request, responseStream, context) => interceptor.ServerStreamingServerHandler… in Intercept()
189 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall); in HandleCall()
193 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
252 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall); in HandleCall()
255 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
[all …]
/external/grpc-grpc/src/csharp/Grpc.Core/
DAsyncServerStreamingCall.cs30 readonly IAsyncStreamReader<TResponse> responseStream; field in Grpc.Core.AsyncServerStreamingCall
44 public AsyncServerStreamingCall(IAsyncStreamReader<TResponse> responseStream, in AsyncServerStreamingCall() argument
50 this.responseStream = responseStream; in AsyncServerStreamingCall()
64 return responseStream;
DAsyncDuplexStreamingCall.cs32 readonly IAsyncStreamReader<TResponse> responseStream; field in Grpc.Core.AsyncDuplexStreamingCall
48 IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall() argument
55 this.responseStream = responseStream; in AsyncDuplexStreamingCall()
69 return responseStream;
DCalls.cs80 var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
81 …return new AsyncServerStreamingCall<TResponse>(responseStream, asyncCall.ResponseHeadersAsync, asy…
118 var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
119 …return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream, asyncCall.…
DServerMethods.cs46 …Request, TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStream, ServerCallCon…
55 …StreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> responseStream, ServerCallCon…
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DWorkerServiceImpl.cs42 …mReader<ServerArgs> requestStream, IServerStreamWriter<ServerStatus> responseStream, ServerCallCon… in RunServer() argument
48 await responseStream.WriteAsync(new ServerStatus in RunServer()
58 await responseStream.WriteAsync(new ServerStatus in RunServer()
66 …mReader<ClientArgs> requestStream, IServerStreamWriter<ClientStatus> responseStream, ServerCallCon… in RunClient() argument
72 await responseStream.WriteAsync(new ClientStatus in RunClient()
80 await responseStream.WriteAsync(new ClientStatus in RunClient()
DTestServiceImpl.cs49 …allRequest request, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallCon… in StreamingOutputCall() argument
57 await responseStream.WriteAsync(response); in StreamingOutputCall()
74 …est> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallCon… in FullDuplexCall() argument
84 await responseStream.WriteAsync(response); in FullDuplexCall()
89 …est> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallCon… in HalfDuplexCall() argument
DBenchmarkServiceImpl.cs44 …er<SimpleRequest> requestStream, IServerStreamWriter<SimpleResponse> responseStream, ServerCallCon… in StreamingCall() argument
49 await responseStream.WriteAsync(response); in StreamingCall()
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DResponseHeadersTest.cs103 …ndler = new ServerStreamingServerMethod<string, string>(async (request, responseStream, context) => in ResponseHeadersAsync_ServerStreamingCall()
106 await responseStream.WriteAsync("PASS"); in ResponseHeadersAsync_ServerStreamingCall()
119 …= new DuplexStreamingServerMethod<string, string>(async (requestStream, responseStream, context) => in ResponseHeadersAsync_DuplexStreamingCall()
124 await responseStream.WriteAsync(requestStream.Current); in ResponseHeadersAsync_DuplexStreamingCall()
173 …ndler = new ServerStreamingServerMethod<string, string>(async (request, responseStream, context) => in WriteResponseHeaders_NotAllowedAfterWrite()
175 await responseStream.WriteAsync("A"); in WriteResponseHeaders_NotAllowedAfterWrite()
184 await responseStream.WriteAsync("B"); in WriteResponseHeaders_NotAllowedAfterWrite()
DCompressionTest.cs71 …= new DuplexStreamingServerMethod<string, string>(async (requestStream, responseStream, context) => in WriteOptions_DuplexStreaming()
79 await responseStream.WriteAsync("X"); in WriteOptions_DuplexStreaming()
81 responseStream.WriteOptions = null; in WriteOptions_DuplexStreaming()
82 await responseStream.WriteAsync("Y"); in WriteOptions_DuplexStreaming()
84 responseStream.WriteOptions = new WriteOptions(WriteFlags.NoCompress); in WriteOptions_DuplexStreaming()
85 await responseStream.WriteAsync("Z"); in WriteOptions_DuplexStreaming()
DMockServiceHelper.cs92 …ethod(serverStreamingMethod, (request, responseStream, context) => serverStreamingHandler(request,… in MockServiceHelper()
93 …lexStreamingMethod, (requestStream, responseStream, context) => duplexStreamingHandler(requestStre… in MockServiceHelper()
110 …mingHandler = new ServerStreamingServerMethod<string, string>((request, responseStream, context) => in MockServiceHelper()
116 …ndler = new DuplexStreamingServerMethod<string, string>((requestStream, responseStream, context) => in MockServiceHelper()
DClientServerTest.cs191 …ndler = new ServerStreamingServerMethod<string, string>(async (request, responseStream, context) => in ServerStreamingCall()
193 await responseStream.WriteAllAsync(request.Split(new []{' '})); in ServerStreamingCall()
207 …gHandler = new ServerStreamingServerMethod<string, string>((request, responseStream, context) => T… in ServerStreamingCall_EndOfStreamIsIdempotent()
218 …mingHandler = new ServerStreamingServerMethod<string, string>((request, responseStream, context) => in ServerStreamingCall_ErrorCanBeAwaitedTwice()
237 …mingHandler = new ServerStreamingServerMethod<string, string>((request, responseStream, context) => in ServerStreamingCall_TrailersFromMultipleSourcesGetConcatenated()
258 …= new DuplexStreamingServerMethod<string, string>(async (requestStream, responseStream, context) => in DuplexStreamingCall()
262 await responseStream.WriteAsync(requestStream.Current); in DuplexStreamingCall()
/external/grpc-grpc/src/csharp/Grpc.Core.Testing/
DTestCalls.cs58 IAsyncStreamReader<TResponse> responseStream, Task<Metadata> responseHeadersAsync, in AsyncServerStreamingCall() argument
61 …return new AsyncServerStreamingCall<TResponse>(responseStream, responseHeadersAsync, getStatusFunc… in AsyncServerStreamingCall()
69 … IClientStreamWriter<TRequest> requestStream, IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall() argument
73 …return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream, responseHe… in AsyncDuplexStreamingCall()
/external/grpc-grpc/src/csharp/Grpc.Examples/
DMathServiceImpl.cs38 …public override async Task Fib(FibArgs request, IServerStreamWriter<Num> responseStream, ServerCal… in Fib() argument
47 await responseStream.WriteAsync(fibEnumerator.Current); in Fib()
63 …ncStreamReader<DivArgs> requestStream, IServerStreamWriter<DivReply> responseStream, ServerCallCon… in DivMany() argument
65 …await requestStream.ForEachAsync(async divArgs => await responseStream.WriteAsync(DivInternal(divA… in DivMany()
/external/grpc-grpc/examples/node/static_codegen/route_guide/
Droute_guide_grpc_pb.js89 responseStream: false,
106 responseStream: true,
121 responseStream: false,
136 responseStream: true,
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideServer/
DRouteGuideImpl.cs54 …nc Task ListFeatures(Rectangle request, IServerStreamWriter<Feature> responseStream, ServerCallCon… in ListFeatures() argument
59 await responseStream.WriteAsync(response); in ListFeatures()
106 …treamReader<RouteNote> requestStream, IServerStreamWriter<RouteNote> responseStream, ServerCallCon… in RouteChat() argument
114 await responseStream.WriteAsync(prevNote); in RouteChat()
/external/apache-http/android/src/android/net/http/
DAndroidHttpClient.java219 InputStream responseStream = entity.getContent(); in getUngzippedContent() local
220 if (responseStream == null) return responseStream; in getUngzippedContent()
222 if (header == null) return responseStream; in getUngzippedContent()
224 if (contentEncoding == null) return responseStream; in getUngzippedContent()
225 if (contentEncoding.contains("gzip")) responseStream in getUngzippedContent()
226 = new GZIPInputStream(responseStream); in getUngzippedContent()
227 return responseStream; in getUngzippedContent()
/external/grpc-grpc/src/csharp/Grpc.Core/Interceptors/
DInterceptor.cs372 …Request, TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStream, ServerCallCon…
376 return continuation(request, responseStream, context);
398 …StreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> responseStream, ServerCallCon…
402 return continuation(requestStream, responseStream, context);
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/
DServerInterceptorTest.cs113 …Request, TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStream, ServerCallCon… in ServerStreamingServerHandler() argument
116 return continuation(request, responseStream, context); in ServerStreamingServerHandler()
119 …StreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> responseStream, ServerCallCon… in DuplexStreamingServerHandler() argument
122 return continuation(requestStream, responseStream, context); in DuplexStreamingServerHandler()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java242 private final StreamObserver<StreamingOutputCallResponse> responseStream;
279 public ResponseDispatcher(StreamObserver<StreamingOutputCallResponse> responseStream) {
281 this.responseStream = responseStream;
320 responseStream.onError(cause);
335 responseStream.onCompleted();
337 responseStream.onNext(chunk.toResponse());
346 responseStream.onError(e);
/external/volley/src/main/java/com/android/volley/toolbox/
DBaseHttpStack.java82 InputStream responseStream = response.getContent(); in performRequest() local
83 if (responseStream != null) { in performRequest()
85 entity.setContent(responseStream); in performRequest()
/external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/util/
DAsyncHttpURLConnection.java104 InputStream responseStream = connection.getInputStream(); in sendHttpMessage() local
105 String response = drainStream(responseStream); in sendHttpMessage()
106 responseStream.close(); in sendHttpMessage()
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideClient/
DProgram.cs87 var responseStream = call.ResponseStream; in ListFeatures()
90 while (await responseStream.MoveNext()) in ListFeatures()
92 Feature feature = responseStream.Current; in ListFeatures()

12