Searched refs:asyncCall (Results 1 – 5 of 5) sorted by relevance
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | AsyncCallTest.cs | 35 AsyncCall<string, string> asyncCall; field in Grpc.Core.Internal.Tests.AsyncCallTest
45 asyncCall = new AsyncCall<string, string>(callDetails, fakeCall); in Init()
57 asyncCall.UnaryCallAsync("request1"); in AsyncUnary_CanBeStartedOnlyOnce()
59 () => asyncCall.UnaryCallAsync("abc")); in AsyncUnary_CanBeStartedOnlyOnce()
65 asyncCall.UnaryCallAsync("request1"); in AsyncUnary_StreamingOperationsNotAllowed()
67 async () => await asyncCall.ReadMessageAsync()); in AsyncUnary_StreamingOperationsNotAllowed()
69 () => asyncCall.SendMessageAsync("abc", new WriteFlags())); in AsyncUnary_StreamingOperationsNotAllowed()
75 var resultTask = asyncCall.UnaryCallAsync("request1"); in AsyncUnary_Success()
81 AssertUnaryResponseSuccess(asyncCall, fakeCall, resultTask); in AsyncUnary_Success()
87 var resultTask = asyncCall.UnaryCallAsync("request1"); in AsyncUnary_NonSuccessStatusCode()
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | Calls.cs | 44 var asyncCall = new AsyncCall<TRequest, TResponse>(call); field in Grpc.Core.Calls.TResponse
45 return asyncCall.UnaryCall(req);
60 var asyncCall = new AsyncCall<TRequest, TResponse>(call); field in Grpc.Core.Calls.TResponse
61 var asyncResult = asyncCall.UnaryCallAsync(req);
62 …UnaryCall<TResponse>(asyncResult, asyncCall.ResponseHeadersAsync, asyncCall.GetStatus, asyncCall.G…
78 var asyncCall = new AsyncCall<TRequest, TResponse>(call); field in Grpc.Core.Calls.TResponse
79 asyncCall.StartServerStreamingCall(req); in asyncCall.StartServerStreamingCall()
80 var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall);
81 …ngCall<TResponse>(responseStream, asyncCall.ResponseHeadersAsync, asyncCall.GetStatus, asyncCall.G…
96 var asyncCall = new AsyncCall<TRequest, TResponse>(call); field in Grpc.Core.Calls.TResponse
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerCallHandler.cs | 54 var asyncCall = new AsyncCallServer<TRequest, TResponse>( in HandleCall()
59 asyncCall.Initialize(newRpc.Call, cq); in HandleCall()
60 var finishedTask = asyncCall.ServerSideCallAsync(); in HandleCall()
61 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall); in HandleCall()
62 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall); in HandleCall()
66 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
85 …await asyncCall.SendStatusFromServerAsync(status, context.ResponseTrailers, responseWithFlags).Con… in HandleCall()
89 asyncCall.Cancel(); in HandleCall()
118 var asyncCall = new AsyncCallServer<TRequest, TResponse>( in HandleCall()
123 asyncCall.Initialize(newRpc.Call, cq); in HandleCall()
[all …]
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/ |
| D | ErrorHandlingClient.java | 71 asyncCall(); in run()
141 void asyncCall() { in asyncCall() method in ErrorHandlingClient
|
| D | DetailErrorSample.java | 91 asyncCall(); in run()
165 void asyncCall() { in asyncCall() method in DetailErrorSample
|