| /external/grpc-grpc/src/csharp/Grpc.Core/Interceptors/ |
| D | Interceptor.cs | 52 …TResponse BlockingUnaryCallContinuation<TRequest, TResponse>(TRequest request, ClientInterceptorCo…
53 where TRequest : class
78 …l<TResponse> AsyncUnaryCallContinuation<TRequest, TResponse>(TRequest request, ClientInterceptorCo…
79 where TRequest : class
104 …e> AsyncServerStreamingCallContinuation<TRequest, TResponse>(TRequest request, ClientInterceptorCo…
105 where TRequest : class
129 …ClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCallContinuation<TRequest, TResponse>…
130 where TRequest : class
152 …DuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCallContinuation<TRequest, TResponse>…
153 where TRequest : class
[all …]
|
| D | CallInvokerExtensions.cs | 109 …rivate ClientInterceptorContext<TRequest, TResponse> GetNewContext<TRequest, TResponse>(ClientInte…
110 where TRequest : class
114 …return new ClientInterceptorContext<TRequest, TResponse>(context.Method, context.Host, context.Opt…
117 …UnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> con… in BlockingUnaryCall() argument
122 …ncUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> c… in AsyncUnaryCall() argument
127 …ngCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> contex… in AsyncServerStreamingCall() argument
132 …TRequest, TResponse> AsyncClientStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TReque… in AsyncClientStreamingCall() argument
137 …TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TReque… in AsyncDuplexStreamingCall() argument
|
| D | InterceptingCallInvoker.cs | 46 …Response BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C… in BlockingUnaryCall() argument
50 new ClientInterceptorContext<TRequest, TResponse>(method, host, options), in BlockingUnaryCall()
57 …<TResponse> AsyncUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C… in AsyncUnaryCall() argument
61 new ClientInterceptorContext<TRequest, TResponse>(method, host, options), in AsyncUnaryCall()
68 …> AsyncServerStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C… in AsyncServerStreamingCall() argument
72 new ClientInterceptorContext<TRequest, TResponse>(method, host, options), in AsyncServerStreamingCall()
79 … override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TRespon… in AsyncClientStreamingCall() argument
82 new ClientInterceptorContext<TRequest, TResponse>(method, host, options), in AsyncClientStreamingCall()
89 … override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TRespon… in AsyncDuplexStreamingCall() argument
92 new ClientInterceptorContext<TRequest, TResponse>(method, host, options), in AsyncDuplexStreamingCall()
|
| D | ClientInterceptorContext.cs | 29 public struct ClientInterceptorContext<TRequest, TResponse>
30 where TRequest : class struct
40 …public ClientInterceptorContext(Method<TRequest, TResponse> method, string host, CallOptions optio… in ClientInterceptorContext() argument
51 public Method<TRequest, TResponse> Method { get; } argument
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | Calls.cs | 40 …c static TResponse BlockingUnaryCall<TRequest, TResponse>(CallInvocationDetails<TRequest, TRespons…
41 where TRequest : class
44 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
56 …cUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(CallInvocationDetails<TRequest, TRespons…
57 where TRequest : class
60 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
74 …<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(CallInvocationDetails<TRequest, TRespons…
75 where TRequest : class
78 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
80 var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall);
[all …]
|
| D | CallInvoker.cs | 33 …Response BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C…
34 where TRequest : class
40 …<TResponse> AsyncUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C…
41 where TRequest : class
48 …> AsyncServerStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C…
49 where TRequest : class
56 … abstract AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TRespon…
57 where TRequest : class
65 … abstract AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TRespon…
66 where TRequest : class
|
| D | DefaultCallInvoker.cs | 44 …Response BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C… in BlockingUnaryCall() argument
53 …<TResponse> AsyncUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C… in AsyncUnaryCall() argument
63 …> AsyncServerStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C… in AsyncServerStreamingCall() argument
73 … override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TRespon… in AsyncClientStreamingCall() argument
84 … override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TRespon… in AsyncDuplexStreamingCall() argument
91 …protected virtual CallInvocationDetails<TRequest, TResponse> CreateCall<TRequest, TResponse>(Metho…
92 where TRequest : class
95 return new CallInvocationDetails<TRequest, TResponse>(channel, method, host, options);
|
| D | ClientBase.cs | 164 …rivate ClientInterceptorContext<TRequest, TResponse> GetNewContext<TRequest, TResponse>(ClientInte…
165 where TRequest : class
169 …return new ClientInterceptorContext<TRequest, TResponse>(context.Method, newHostAndCallOptions.Ite…
172 …UnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> con… in BlockingUnaryCall() argument
177 …ncUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> c… in AsyncUnaryCall() argument
182 …ngCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> contex… in AsyncServerStreamingCall() argument
187 …TRequest, TResponse> AsyncClientStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TReque… in AsyncClientStreamingCall() argument
192 …TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TReque… in AsyncDuplexStreamingCall() argument
|
| D | ServerServiceDefinition.cs | 82 public Builder AddMethod<TRequest, TResponse>(
83 Method<TRequest, TResponse> method,
84 UnaryServerMethod<TRequest, TResponse> handler)
85 where TRequest : class
100 public Builder AddMethod<TRequest, TResponse>(
101 Method<TRequest, TResponse> method,
102 ClientStreamingServerMethod<TRequest, TResponse> handler)
103 where TRequest : class
118 public Builder AddMethod<TRequest, TResponse>(
119 Method<TRequest, TResponse> method,
[all …]
|
| D | ServerMethods.cs | 28 …public delegate Task<TResponse> UnaryServerMethod<TRequest, TResponse>(TRequest request, ServerCal…
29 where TRequest : class
37 …elegate Task<TResponse> ClientStreamingServerMethod<TRequest, TResponse>(IAsyncStreamReader<TReque…
38 where TRequest : class
46 …public delegate Task ServerStreamingServerMethod<TRequest, TResponse>(TRequest request, IServerStr…
47 where TRequest : class
55 …public delegate Task DuplexStreamingServerMethod<TRequest, TResponse>(IAsyncStreamReader<TRequest>…
56 where TRequest : class
|
| D | CallInvocationDetails.cs | 30 public struct CallInvocationDetails<TRequest, TResponse>
35 readonly Marshaller<TRequest> requestMarshaller;
45 …public CallInvocationDetails(Channel channel, Method<TRequest, TResponse> method, CallOptions opti… in CallInvocationDetails()
57 …public CallInvocationDetails(Channel channel, Method<TRequest, TResponse> method, string host, Cal… in CallInvocationDetails()
71 …vocationDetails(Channel channel, string method, string host, Marshaller<TRequest> requestMarshalle… in CallInvocationDetails()
117 public Marshaller<TRequest> RequestMarshaller
151 public CallInvocationDetails<TRequest, TResponse> WithOptions(CallOptions options) in WithOptions()
|
| D | AsyncDuplexStreamingCall.cs | 29 public sealed class AsyncDuplexStreamingCall<TRequest, TResponse> : IDisposable
31 readonly IClientStreamWriter<TRequest> requestStream;
47 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall()
76 public IClientStreamWriter<TRequest> RequestStream
|
| D | AsyncClientStreamingCall.cs | 30 public sealed class AsyncClientStreamingCall<TRequest, TResponse> : IDisposable
32 readonly IClientStreamWriter<TRequest> requestStream;
48 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall()
88 public IClientStreamWriter<TRequest> RequestStream
|
| D | Method.cs | 74 public class Method<TRequest, TResponse> : IMethod
79 readonly Marshaller<TRequest> requestMarshaller;
91 …public Method(MethodType type, string serviceName, string name, Marshaller<TRequest> requestMarsha… in Method()
137 public Marshaller<TRequest> RequestMarshaller
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerCalls.cs | 28 …tatic IServerCallHandler UnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, UnaryS…
29 where TRequest : class
32 return new UnaryServerCallHandler<TRequest, TResponse>(method, handler);
35 …llHandler ClientStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, ClientStrea…
36 where TRequest : class
39 return new ClientStreamingServerCallHandler<TRequest, TResponse>(method, handler);
42 …llHandler ServerStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, ServerStrea…
43 where TRequest : class
46 return new ServerStreamingServerCallHandler<TRequest, TResponse>(method, handler);
49 …llHandler DuplexStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, DuplexStrea…
[all …]
|
| D | ServerCallHandler.cs | 37 internal class UnaryServerCallHandler<TRequest, TResponse> : IServerCallHandler
38 where TRequest : class
41 …nly ILogger Logger = GrpcEnvironment.Logger.ForType<UnaryServerCallHandler<TRequest, TResponse>>();
43 readonly Method<TRequest, TResponse> method;
44 readonly UnaryServerMethod<TRequest, TResponse> handler;
46 …public UnaryServerCallHandler(Method<TRequest, TResponse> method, UnaryServerMethod<TRequest, TRes… in UnaryServerCallHandler() argument
54 var asyncCall = new AsyncCallServer<TRequest, TResponse>( in HandleCall()
61 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall); in HandleCall()
62 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall); in HandleCall()
65 AsyncCallServer<TRequest,TResponse>.ResponseWithFlags? responseWithFlags = null; in HandleCall()
[all …]
|
| D | UnimplementedCallInvoker.cs | 35 …Response BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C… in BlockingUnaryCall() argument
40 …<TResponse> AsyncUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C… in AsyncUnaryCall() argument
45 …> AsyncServerStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C… in AsyncServerStreamingCall() argument
50 … override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TRespon… in AsyncClientStreamingCall() argument
55 … override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TRespon… in AsyncDuplexStreamingCall() argument
|
| D | ServerRequestStream.cs | 26 internal class ServerRequestStream<TRequest, TResponse> : IAsyncStreamReader<TRequest>
27 where TRequest : class
30 readonly AsyncCallServer<TRequest, TResponse> call;
31 TRequest current;
33 public ServerRequestStream(AsyncCallServer<TRequest, TResponse> call) in ServerRequestStream() argument
38 public TRequest Current
|
| D | ClientRequestStream.cs | 25 internal class ClientRequestStream<TRequest, TResponse> : IClientStreamWriter<TRequest>
27 readonly AsyncCall<TRequest, TResponse> call;
30 public ClientRequestStream(AsyncCall<TRequest, TResponse> call) in ClientRequestStream() argument
36 public Task WriteAsync(TRequest message) in WriteAsync()
|
| D | ServerResponseStream.cs | 26 …internal class ServerResponseStream<TRequest, TResponse> : IServerStreamWriter<TResponse>, IHasWri…
27 where TRequest : class
30 readonly AsyncCallServer<TRequest, TResponse> call;
33 public ServerResponseStream(AsyncCallServer<TRequest, TResponse> call) in ServerResponseStream() argument
|
| D | ClientResponseStream.cs | 26 internal class ClientResponseStream<TRequest, TResponse> : IAsyncStreamReader<TResponse>
27 where TRequest : class
30 readonly AsyncCall<TRequest, TResponse> call;
33 public ClientResponseStream(AsyncCall<TRequest, TResponse> call) in ClientResponseStream() argument
|
| D | AsyncCall.cs | 31 …internal class AsyncCall<TRequest, TResponse> : AsyncCallBase<TRequest, TResponse>, IUnaryResponse…
33 … static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<AsyncCall<TRequest, TResponse>>();
35 readonly CallInvocationDetails<TRequest, TResponse> details;
56 public AsyncCall(CallInvocationDetails<TRequest, TResponse> callDetails) in AsyncCall() argument
66 …public AsyncCall(CallInvocationDetails<TRequest, TResponse> callDetails, INativeCall injectedNativ… in AsyncCall() argument
76 public TResponse UnaryCall(TRequest msg) in UnaryCall()
148 public Task<TResponse> UnaryCallAsync(TRequest msg) in UnaryCallAsync()
224 public void StartServerStreamingCall(TRequest msg) in StartServerStreamingCall()
295 public Task SendMessageAsync(TRequest msg, WriteFlags writeFlags) in SendMessageAsync()
388 public CallInvocationDetails<TRequest, TResponse> Details
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/ |
| D | ClientInterceptorTest.cs | 142 …UnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> con… in BlockingUnaryCall() argument
148 …ncUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> c… in AsyncUnaryCall() argument
154 …ngCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> contex… in AsyncServerStreamingCall() argument
160 …TRequest, TResponse> AsyncClientStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TReque… in AsyncClientStreamingCall() argument
166 …TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TReque… in AsyncDuplexStreamingCall() argument
175 …TRequest, TResponse> AsyncClientStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TReque… in AsyncClientStreamingCall() argument
179 var requestStream = new WrappedClientStreamWriter<TRequest>(response.RequestStream, in AsyncClientStreamingCall()
184 …return new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, responseAsync, response.Re… in AsyncClientStreamingCall()
|
| D | ServerInterceptorTest.cs | 101 …TResponse> UnaryServerHandler<TRequest, TResponse>(TRequest request, ServerCallContext context, Un… in UnaryServerHandler() argument
107 …rverHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, ServerCallContext con… in ClientStreamingServerHandler() argument
113 …r<TRequest, TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStream, ServerCall… in ServerStreamingServerHandler() argument
119 …TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> re… in DuplexStreamingServerHandler() argument
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Testing/ |
| D | TestCalls.cs | 45 …public static AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TRe… in AsyncClientStreamingCall()
46 IClientStreamWriter<TRequest> requestStream, Task<TResponse> responseAsync, in AsyncClientStreamingCall()
50 …return new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, responseAsync, responseHea… in AsyncClientStreamingCall()
68 …public static AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TRe… in AsyncDuplexStreamingCall()
69 … IClientStreamWriter<TRequest> requestStream, IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall()
73 …return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream, responseHe… in AsyncDuplexStreamingCall()
|