| /third_party/grpc/src/csharp/Grpc.Core.Api/ |
| D | AsyncServerStreamingCall.cs | 30 readonly IAsyncStreamReader<TResponse> responseStream; field in Grpc.Core.AsyncServerStreamingCall
41 public AsyncServerStreamingCall(IAsyncStreamReader<TResponse> responseStream, in AsyncServerStreamingCall() argument
47 this.responseStream = responseStream; in AsyncServerStreamingCall()
60 public AsyncServerStreamingCall(IAsyncStreamReader<TResponse> responseStream, in AsyncServerStreamingCall() argument
67 this.responseStream = responseStream; in AsyncServerStreamingCall()
78 return responseStream;
|
| D | AsyncDuplexStreamingCall.cs | 32 readonly IAsyncStreamReader<TResponse> responseStream; field in Grpc.Core.AsyncDuplexStreamingCall
45 IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall() argument
52 this.responseStream = responseStream; in AsyncDuplexStreamingCall()
67 IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall() argument
75 this.responseStream = responseStream; in AsyncDuplexStreamingCall()
86 return responseStream;
|
| D | ServerMethods.cs | 46 …Request, TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStream, ServerCallCon…
55 …StreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> responseStream, ServerCallCon…
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | AsyncCallTest.cs | 391 var responseStream = new ClientResponseStream<string, string>(asyncCall); in ServerStreaming_NoResponse_Success1()
392 var readTask = responseStream.MoveNext(); in ServerStreaming_NoResponse_Success1()
407 var responseStream = new ClientResponseStream<string, string>(asyncCall); in ServerStreaming_NoResponse_Success2()
408 var readTask = responseStream.MoveNext(); in ServerStreaming_NoResponse_Success2()
421 var responseStream = new ClientResponseStream<string, string>(asyncCall); in ServerStreaming_NoResponse_ReadFailure()
422 var readTask = responseStream.MoveNext(); in ServerStreaming_NoResponse_ReadFailure()
434 var responseStream = new ClientResponseStream<string, string>(asyncCall); in ServerStreaming_MoreResponses_Success()
436 var readTask1 = responseStream.MoveNext(); in ServerStreaming_MoreResponses_Success()
439 Assert.AreEqual("response1", responseStream.Current); in ServerStreaming_MoreResponses_Success()
441 var readTask2 = responseStream.MoveNext(); in ServerStreaming_MoreResponses_Success()
[all …]
|
| D | AsyncCallServerTest.cs | 124 var responseStream = new ServerResponseStream<string, string>(asyncCallServer); in WriteAfterCancelNotificationFails()
129 … Assert.Throws(typeof(InvalidOperationException), () => responseStream.WriteAsync("request1")); in WriteAfterCancelNotificationFails()
137 var responseStream = new ServerResponseStream<string, string>(asyncCallServer); in WriteCompletionFailureThrows()
139 var writeTask = responseStream.WriteAsync("request1"); in WriteCompletionFailureThrows()
151 var responseStream = new ServerResponseStream<string, string>(asyncCallServer); in WriteAndWriteStatusCanRunConcurrently()
153 var writeTask = responseStream.WriteAsync("request1"); in WriteAndWriteStatusCanRunConcurrently()
171 var responseStream = new ServerResponseStream<string, string>(asyncCallServer); in WriteAfterWriteStatusThrowsInvalidOperationException()
174 …Assert.ThrowsAsync(typeof(InvalidOperationException), async () => await responseStream.WriteAsync(… in WriteAfterWriteStatusThrowsInvalidOperationException()
|
| /third_party/grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | WorkerServiceImpl.cs | 42 …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()
|
| D | TestServiceImpl.cs | 49 …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
|
| D | MetadataCredentialsTest.cs | 150 serviceImpl.StreamingOutputCallHandler = async (req, responseStream, context) => in MetadataCredentials_Composed()
158 await responseStream.WriteAsync(new StreamingOutputCallResponse()); in MetadataCredentials_Composed()
186 serviceImpl.StreamingOutputCallHandler = async (req, responseStream, context) => in MetadataCredentials_ComposedPerCall()
192 await responseStream.WriteAsync(new StreamingOutputCallResponse()); in MetadataCredentials_ComposedPerCall()
259 …allRequest request, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallCon… in StreamingOutputCall() argument
263 return StreamingOutputCallHandler(request, responseStream, context); in StreamingOutputCall()
265 return base.StreamingOutputCall(request, responseStream, context); in StreamingOutputCall()
|
| D | BenchmarkServiceImpl.cs | 44 …er<SimpleRequest> requestStream, IServerStreamWriter<SimpleResponse> responseStream, ServerCallCon… in StreamingCall() argument
49 await responseStream.WriteAsync(response); in StreamingCall()
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/ |
| D | ResponseHeadersTest.cs | 103 …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()
|
| D | CompressionTest.cs | 71 …= 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()
|
| D | MockServiceHelper.cs | 92 …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()
|
| D | ClientServerTest.cs | 211 …ndler = new ServerStreamingServerMethod<string, string>(async (request, responseStream, context) => in ServerStreamingCall()
213 await responseStream.WriteAllAsync(request.Split(new []{' '})); in ServerStreamingCall()
227 …gHandler = new ServerStreamingServerMethod<string, string>((request, responseStream, context) => T… in ServerStreamingCall_EndOfStreamIsIdempotent()
238 …mingHandler = new ServerStreamingServerMethod<string, string>((request, responseStream, context) => in ServerStreamingCall_ErrorCanBeAwaitedTwice()
257 …mingHandler = new ServerStreamingServerMethod<string, string>((request, responseStream, context) => in ServerStreamingCall_TrailersFromMultipleSourcesGetConcatenated()
278 …= new DuplexStreamingServerMethod<string, string>(async (requestStream, responseStream, context) => in DuplexStreamingCall()
282 await responseStream.WriteAsync(requestStream.Current); in DuplexStreamingCall()
|
| /third_party/grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerCallHandler.cs | 61 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall); in HandleCall()
65 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
120 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall); in HandleCall()
123 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
128 await handler(request, responseStream, context).ConfigureAwait(false); in HandleCall()
178 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall); in HandleCall()
182 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
236 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall); in HandleCall()
239 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
242 await handler(requestStream, responseStream, context).ConfigureAwait(false); in HandleCall()
[all …]
|
| /third_party/flatbuffers/tests/ |
| D | monster_test_grpc.js | 38 responseStream: false,
49 responseStream: true,
60 responseStream: false,
71 responseStream: true,
|
| D | monster_test_grpc.d.ts | 17 responseStream: boolean; // false property
27 responseStream: boolean; // true property
37 responseStream: boolean; // false property
47 responseStream: boolean; // true property
|
| /third_party/grpc/src/csharp/Grpc.Core.Testing/ |
| D | TestCalls.cs | 58 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()
|
| /third_party/grpc/src/csharp/Grpc.Examples/ |
| D | MathServiceImpl.cs | 36 …public override async Task Fib(FibArgs request, IServerStreamWriter<Num> responseStream, ServerCal… in Fib() argument
45 await responseStream.WriteAsync(fibEnumerator.Current); in Fib()
61 …ncStreamReader<DivArgs> requestStream, IServerStreamWriter<DivReply> responseStream, ServerCallCon… in DivMany() argument
63 …await requestStream.ForEachAsync(async divArgs => await responseStream.WriteAsync(DivInternal(divA… in DivMany()
|
| /third_party/grpc/examples/node/static_codegen/route_guide/ |
| D | route_guide_grpc_pb.js | 89 responseStream: false,
106 responseStream: true,
121 responseStream: false,
136 responseStream: true,
|
| /third_party/grpc/src/csharp/Grpc.Core/Interceptors/ |
| D | ServerServiceDefinitionExtensions.cs | 118 …r.AddMethod(method, (request, responseStream, context) => interceptor.ServerStreamingServerHandler… in AddMethod()
125 …od(method, (requestStream, responseStream, context) => interceptor.DuplexStreamingServerHandler(re… in AddMethod()
|
| /third_party/grpc/examples/csharp/RouteGuide/RouteGuideServer/ |
| D | RouteGuideImpl.cs | 54 …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()
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/Interceptors/ |
| D | Interceptor.cs | 372 …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);
|
| /third_party/grpc/src/csharp/Grpc.Core/ |
| D | Calls.cs | 84 var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
85 return new AsyncServerStreamingCall<TResponse>(responseStream,
128 var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
129 return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream,
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/Interceptors/ |
| D | ServerInterceptorTest.cs | 160 …Request, TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStream, ServerCallCon… in ServerStreamingServerHandler() argument
163 return continuation(request, responseStream, context); in ServerStreamingServerHandler()
166 …StreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> responseStream, ServerCallCon… in DuplexStreamingServerHandler() argument
169 return continuation(requestStream, responseStream, context); in DuplexStreamingServerHandler()
|
| /third_party/flatbuffers/grpc/examples/ts/greeter/src/ |
| D | greeter_grpc.js | 36 responseStream: false,
47 responseStream: true,
|