| /third_party/grpc/src/csharp/Grpc.Core.Api/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
|
| /third_party/grpc/src/csharp/Grpc.Core/ |
| D | Calls.cs | 41 …c static TResponse BlockingUnaryCall<TRequest, TResponse>(CallInvocationDetails<TRequest, TRespons…
42 where TRequest : class
45 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
57 …cUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(CallInvocationDetails<TRequest, TRespons…
58 where TRequest : class
61 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
64 Callbacks<TRequest, TResponse>.GetHeaders, Callbacks<TRequest, TResponse>.GetStatus,
65 Callbacks<TRequest, TResponse>.GetTrailers, Callbacks<TRequest, TResponse>.Cancel,
78 …<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(CallInvocationDetails<TRequest, TRespons…
79 where TRequest : class
[all …]
|
| 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 | 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()
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/ |
| D | CallInvoker.cs | 31 …Response BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C…
32 where TRequest : class
38 …<TResponse> AsyncUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C…
39 where TRequest : class
46 …> AsyncServerStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, C…
47 where TRequest : class
54 … abstract AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TRespon…
55 where TRequest : class
63 … abstract AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TRespon…
64 where TRequest : class
|
| D | ServiceBinderBase.cs | 41 public virtual void AddMethod<TRequest, TResponse>(
42 Method<TRequest, TResponse> method,
43 UnaryServerMethod<TRequest, TResponse> handler)
44 where TRequest : class
57 public virtual void AddMethod<TRequest, TResponse>(
58 Method<TRequest, TResponse> method,
59 ClientStreamingServerMethod<TRequest, TResponse> handler)
60 where TRequest : class
73 public virtual void AddMethod<TRequest, TResponse>(
74 Method<TRequest, TResponse> method,
[all …]
|
| 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.Hos…
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 | 83 public Builder AddMethod<TRequest, TResponse>(
84 Method<TRequest, TResponse> method,
85 UnaryServerMethod<TRequest, TResponse> handler)
86 where TRequest : class
102 public Builder AddMethod<TRequest, TResponse>(
103 Method<TRequest, TResponse> method,
104 ClientStreamingServerMethod<TRequest, TResponse> handler)
105 where TRequest : class
121 public Builder AddMethod<TRequest, TResponse>(
122 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 | AsyncDuplexStreamingCall.cs | 29 public sealed class AsyncDuplexStreamingCall<TRequest, TResponse> : IDisposable
31 readonly IClientStreamWriter<TRequest> requestStream;
44 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall()
66 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall()
93 public IClientStreamWriter<TRequest> RequestStream
|
| D | AsyncClientStreamingCall.cs | 30 public sealed class AsyncClientStreamingCall<TRequest, TResponse> : IDisposable
32 readonly IClientStreamWriter<TRequest> requestStream;
45 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall()
67 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall()
105 public IClientStreamWriter<TRequest> RequestStream
|
| /third_party/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 | 36 internal class UnaryServerCallHandler<TRequest, TResponse> : IServerCallHandler
37 where TRequest : class
40 …nly ILogger Logger = GrpcEnvironment.Logger.ForType<UnaryServerCallHandler<TRequest, TResponse>>();
42 readonly Method<TRequest, TResponse> method;
43 readonly UnaryServerMethod<TRequest, TResponse> handler;
45 …public UnaryServerCallHandler(Method<TRequest, TResponse> method, UnaryServerMethod<TRequest, TRes… in UnaryServerCallHandler() argument
53 var asyncCall = new AsyncCallServer<TRequest, TResponse>( in HandleCall()
60 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall); in HandleCall()
61 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall); in HandleCall()
64 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 | ServerServiceDefinitionExtensions.cs | 49 public override void AddMethod<TRequest, TResponse>( in AddMethod() argument
50 Method<TRequest, TResponse> method, in AddMethod()
51 UnaryServerMethod<TRequest, TResponse> handler) in AddMethod() argument
56 public override void AddMethod<TRequest, TResponse>( in AddMethod() argument
57 Method<TRequest, TResponse> method, in AddMethod()
58 ClientStreamingServerMethod<TRequest, TResponse> handler) in AddMethod() argument
63 public override void AddMethod<TRequest, TResponse>( in AddMethod() argument
64 Method<TRequest, TResponse> method, in AddMethod()
65 ServerStreamingServerMethod<TRequest, TResponse> handler) in AddMethod() argument
70 public override void AddMethod<TRequest, TResponse>( in AddMethod() argument
[all …]
|
| 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()
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/Internal/ |
| 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
|
| /third_party/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 | 148 …TResponse> UnaryServerHandler<TRequest, TResponse>(TRequest request, ServerCallContext context, Un… in UnaryServerHandler() argument
154 …rverHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, ServerCallContext con… in ClientStreamingServerHandler() argument
160 …r<TRequest, TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStream, ServerCall… in ServerStreamingServerHandler() argument
166 …TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> re… in DuplexStreamingServerHandler() argument
|
| /third_party/grpc/src/csharp/Grpc.Core/Interceptors/ |
| D | ServerServiceDefinitionExtensions.cs | 100 public override void AddMethod<TRequest, TResponse>( in AddMethod() argument
101 Method<TRequest, TResponse> method, in AddMethod()
102 UnaryServerMethod<TRequest, TResponse> handler) in AddMethod() argument
107 public override void AddMethod<TRequest, TResponse>( in AddMethod() argument
108 Method<TRequest, TResponse> method, in AddMethod()
109 ClientStreamingServerMethod<TRequest, TResponse> handler) in AddMethod() argument
114 public override void AddMethod<TRequest, TResponse>( in AddMethod() argument
115 Method<TRequest, TResponse> method, in AddMethod()
116 ServerStreamingServerMethod<TRequest, TResponse> handler) in AddMethod() argument
121 public override void AddMethod<TRequest, TResponse>( in AddMethod() argument
[all …]
|
| /third_party/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()
|