Home
last modified time | relevance | path

Searched refs:TResponse (Results 1 – 25 of 28) sorted by relevance

12

/external/grpc-grpc/src/csharp/Grpc.Core/Interceptors/
DInterceptor.cs52 …ublic delegate TResponse BlockingUnaryCallContinuation<TRequest, TResponse>(TRequest request, Clie…
54 where TResponse : class; class in Grpc.Core.Interceptors.Interceptor
78 … AsyncUnaryCall<TResponse> AsyncUnaryCallContinuation<TRequest, TResponse>(TRequest request, Clien…
80 where TResponse : class;
104 …eamingCall<TResponse> AsyncServerStreamingCallContinuation<TRequest, TResponse>(TRequest request, …
106 where TResponse : class;
129 …amingCall<TRequest, TResponse> AsyncClientStreamingCallContinuation<TRequest, TResponse>(ClientInt…
131 where TResponse : class;
152 …amingCall<TRequest, TResponse> AsyncDuplexStreamingCallContinuation<TRequest, TResponse>(ClientInt…
154 where TResponse : class;
[all …]
DCallInvokerExtensions.cs109 …ntInterceptorContext<TRequest, TResponse> GetNewContext<TRequest, TResponse>(ClientInterceptorCont…
111 where TResponse : class class in Grpc.Core.Interceptors.CallInvokerExtensions.MetadataInterceptor
114 …return new ClientInterceptorContext<TRequest, TResponse>(context.Method, context.Host, context.Opt…
117 …TResponse BlockingUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TReque… in BlockingUnaryCall()
122 …TResponse> AsyncUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest… in AsyncUnaryCall()
127 …TResponse> AsyncServerStreamingCall<TRequest, TResponse>(TRequest request, ClientInterceptorContex… in AsyncServerStreamingCall()
132 …TResponse> AsyncClientStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TRespo… in AsyncClientStreamingCall()
137 …TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TRespo… in AsyncDuplexStreamingCall()
DInterceptingCallInvoker.cs46 …public override TResponse BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> metho… in BlockingUnaryCall()
50 new ClientInterceptorContext<TRequest, TResponse>(method, host, options), in BlockingUnaryCall()
57 …public override AsyncUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(Method<TRequest, TRe… in AsyncUnaryCall()
61 new ClientInterceptorContext<TRequest, TResponse>(method, host, options), in AsyncUnaryCall()
68 … override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(Method… in AsyncServerStreamingCall()
72 new ClientInterceptorContext<TRequest, TResponse>(method, host, options), in AsyncServerStreamingCall()
79 …AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TResponse>(Method… in AsyncClientStreamingCall()
82 new ClientInterceptorContext<TRequest, TResponse>(method, host, options), in AsyncClientStreamingCall()
89 …AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(Method… in AsyncDuplexStreamingCall()
92 new ClientInterceptorContext<TRequest, TResponse>(method, host, options), in AsyncDuplexStreamingCall()
DClientInterceptorContext.cs29 public struct ClientInterceptorContext<TRequest, TResponse>
31 where TResponse : class
40 …public ClientInterceptorContext(Method<TRequest, TResponse> method, string host, CallOptions optio… in ClientInterceptorContext()
51 public Method<TRequest, TResponse> Method { get; }
/external/grpc-grpc/src/csharp/Grpc.Core/
DCalls.cs40 …public static TResponse BlockingUnaryCall<TRequest, TResponse>(CallInvocationDetails<TRequest, TRe…
42 where TResponse : class class in Grpc.Core.Calls
44 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
56 …public static AsyncUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(CallInvocationDetails<…
58 where TResponse : class class in Grpc.Core.Calls
60 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
62 …return new AsyncUnaryCall<TResponse>(asyncResult, asyncCall.ResponseHeadersAsync, asyncCall.GetSta…
74 …c AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(CallInvocation…
76 where TResponse : class class in Grpc.Core.Calls
78 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
[all …]
DCallInvoker.cs33 …public abstract TResponse BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> metho…
35 where TResponse : class;
40 …public abstract AsyncUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(Method<TRequest, TRe…
42 where TResponse : class;
48 … abstract AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(Method…
50 where TResponse : class;
56 …AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TResponse>(Method…
58 where TResponse : class;
65 …AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(Method…
67 where TResponse : class;
DDefaultCallInvoker.cs44 …public override TResponse BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> metho… in BlockingUnaryCall()
53 …public override AsyncUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(Method<TRequest, TRe… in AsyncUnaryCall()
63 … override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(Method… in AsyncServerStreamingCall()
73 …AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TResponse>(Method… in AsyncClientStreamingCall()
84 …AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(Method… in AsyncDuplexStreamingCall()
91 …d virtual CallInvocationDetails<TRequest, TResponse> CreateCall<TRequest, TResponse>(Method<TReque…
93 where TResponse : class class in Grpc.Core.DefaultCallInvoker
95 return new CallInvocationDetails<TRequest, TResponse>(channel, method, host, options);
DClientBase.cs164 …ntInterceptorContext<TRequest, TResponse> GetNewContext<TRequest, TResponse>(ClientInterceptorCont…
166 where TResponse : class class in Grpc.Core.ClientBase.ClientBaseConfiguration.ClientBaseConfigurationInterceptor
169 …return new ClientInterceptorContext<TRequest, TResponse>(context.Method, newHostAndCallOptions.Ite…
172 …TResponse BlockingUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TReque… in BlockingUnaryCall()
177 …TResponse> AsyncUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest… in AsyncUnaryCall()
182 …TResponse> AsyncServerStreamingCall<TRequest, TResponse>(TRequest request, ClientInterceptorContex… in AsyncServerStreamingCall()
187 …TResponse> AsyncClientStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TRespo… in AsyncClientStreamingCall()
192 …TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TRespo… in AsyncDuplexStreamingCall()
DServerServiceDefinition.cs82 public Builder AddMethod<TRequest, TResponse>(
83 Method<TRequest, TResponse> method,
84 UnaryServerMethod<TRequest, TResponse> handler)
86 where TResponse : class class in Grpc.Core.ServerServiceDefinition.Builder
100 public Builder AddMethod<TRequest, TResponse>(
101 Method<TRequest, TResponse> method,
102 ClientStreamingServerMethod<TRequest, TResponse> handler)
104 where TResponse : class class in Grpc.Core.ServerServiceDefinition.Builder
118 public Builder AddMethod<TRequest, TResponse>(
119 Method<TRequest, TResponse> method,
[all …]
DServerMethods.cs28 …public delegate Task<TResponse> UnaryServerMethod<TRequest, TResponse>(TRequest request, ServerCal…
30 where TResponse : class;
37 …public delegate Task<TResponse> ClientStreamingServerMethod<TRequest, TResponse>(IAsyncStreamReade…
39 where TResponse : class;
46 …ate Task ServerStreamingServerMethod<TRequest, TResponse>(TRequest request, IServerStreamWriter<TR…
48 where TResponse : class;
55 …exStreamingServerMethod<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerSt…
57 where TResponse : class;
DCallInvocationDetails.cs30 public struct CallInvocationDetails<TRequest, TResponse>
36 readonly Marshaller<TResponse> responseMarshaller;
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 …method, string host, Marshaller<TRequest> requestMarshaller, Marshaller<TResponse> responseMarshal… in CallInvocationDetails()
128 public Marshaller<TResponse> ResponseMarshaller
151 public CallInvocationDetails<TRequest, TResponse> WithOptions(CallOptions options) in WithOptions()
DAsyncUnaryCall.cs29 public sealed class AsyncUnaryCall<TResponse> : IDisposable
31 readonly Task<TResponse> responseAsync;
46 public AsyncUnaryCall(Task<TResponse> responseAsync, in AsyncUnaryCall()
62 public Task<TResponse> ResponseAsync
84 public TaskAwaiter<TResponse> GetAwaiter() in GetAwaiter()
DAsyncClientStreamingCall.cs30 public sealed class AsyncClientStreamingCall<TRequest, TResponse> : IDisposable
33 readonly Task<TResponse> responseAsync;
49 Task<TResponse> responseAsync, in AsyncClientStreamingCall()
66 public Task<TResponse> ResponseAsync
100 public TaskAwaiter<TResponse> GetAwaiter() in GetAwaiter()
DAsyncServerStreamingCall.cs28 public sealed class AsyncServerStreamingCall<TResponse> : IDisposable
30 readonly IAsyncStreamReader<TResponse> responseStream;
44 public AsyncServerStreamingCall(IAsyncStreamReader<TResponse> responseStream, in AsyncServerStreamingCall()
60 public IAsyncStreamReader<TResponse> ResponseStream
DAsyncDuplexStreamingCall.cs29 public sealed class AsyncDuplexStreamingCall<TRequest, TResponse> : IDisposable
32 readonly IAsyncStreamReader<TResponse> responseStream;
48 IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall()
65 public IAsyncStreamReader<TResponse> ResponseStream
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DServerCalls.cs28 …erCallHandler UnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> method, UnaryServerMethod…
30 where TResponse : class class in Grpc.Core.Internal.ServerCalls
32 return new UnaryServerCallHandler<TRequest, TResponse>(method, handler);
35 …lientStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, ClientStreamingServerM…
37 where TResponse : class class in Grpc.Core.Internal.ServerCalls
39 return new ClientStreamingServerCallHandler<TRequest, TResponse>(method, handler);
42 …erverStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, ServerStreamingServerM…
44 where TResponse : class class in Grpc.Core.Internal.ServerCalls
46 return new ServerStreamingServerCallHandler<TRequest, TResponse>(method, handler);
49 …uplexStreamingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, DuplexStreamingServerM…
[all …]
DServerCallHandler.cs37 internal class UnaryServerCallHandler<TRequest, TResponse> : IServerCallHandler
39 where TResponse : 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()
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 …]
DUnimplementedCallInvoker.cs35 …public override TResponse BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> metho… in BlockingUnaryCall()
40 …public override AsyncUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(Method<TRequest, TRe… in AsyncUnaryCall()
45 … override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(Method… in AsyncServerStreamingCall()
50 …AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TResponse>(Method… in AsyncClientStreamingCall()
55 …AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(Method… in AsyncDuplexStreamingCall()
DClientResponseStream.cs26 internal class ClientResponseStream<TRequest, TResponse> : IAsyncStreamReader<TResponse>
28 where TResponse : class
30 readonly AsyncCall<TRequest, TResponse> call;
31 TResponse current;
33 public ClientResponseStream(AsyncCall<TRequest, TResponse> call) in ClientResponseStream()
38 public TResponse Current
DServerResponseStream.cs26 …internal class ServerResponseStream<TRequest, TResponse> : IServerStreamWriter<TResponse>, IHasWri…
28 where TResponse : class
30 readonly AsyncCallServer<TRequest, TResponse> call;
33 public ServerResponseStream(AsyncCallServer<TRequest, TResponse> call) in ServerResponseStream()
38 public Task WriteAsync(TResponse message) in WriteAsync()
DAsyncCall.cs31 …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;
44 TaskCompletionSource<TResponse> unaryResponseTcs;
56 public AsyncCall(CallInvocationDetails<TRequest, TResponse> callDetails) in AsyncCall()
66 …public AsyncCall(CallInvocationDetails<TRequest, TResponse> callDetails, INativeCall injectedNativ… in AsyncCall()
76 public TResponse UnaryCall(TRequest msg) in UnaryCall()
86 unaryResponseTcs = new TaskCompletionSource<TResponse>(); in UnaryCall()
148 public Task<TResponse> UnaryCallAsync(TRequest msg) in UnaryCallAsync()
165 unaryResponseTcs = new TaskCompletionSource<TResponse>(); in UnaryCallAsync()
[all …]
DServerRequestStream.cs26 internal class ServerRequestStream<TRequest, TResponse> : IAsyncStreamReader<TRequest>
28 where TResponse : class
30 readonly AsyncCallServer<TRequest, TResponse> call;
33 public ServerRequestStream(AsyncCallServer<TRequest, TResponse> call) in ServerRequestStream()
/external/grpc-grpc/src/csharp/Grpc.Core.Testing/
DTestCalls.cs34 public static AsyncUnaryCall<TResponse> AsyncUnaryCall<TResponse> ( in AsyncUnaryCall()
35 … Task<TResponse> responseAsync, Task<Metadata> responseHeadersAsync, Func<Status> getStatusFunc, in AsyncUnaryCall()
38 …return new AsyncUnaryCall<TResponse>(responseAsync, responseHeadersAsync, getStatusFunc, getTraile… in AsyncUnaryCall()
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()
57 public static AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TResponse>( in AsyncServerStreamingCall()
58 IAsyncStreamReader<TResponse> responseStream, Task<Metadata> responseHeadersAsync, in AsyncServerStreamingCall()
61 …return new AsyncServerStreamingCall<TResponse>(responseStream, responseHeadersAsync, getStatusFunc… in AsyncServerStreamingCall()
68 …public static AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TRe… in AsyncDuplexStreamingCall()
[all …]
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/
DClientInterceptorTest.cs142 …TResponse BlockingUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TReque… in BlockingUnaryCall()
148 …TResponse> AsyncUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest… in AsyncUnaryCall()
154 …TResponse> AsyncServerStreamingCall<TRequest, TResponse>(TRequest request, ClientInterceptorContex… in AsyncServerStreamingCall()
160 …TResponse> AsyncClientStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TRespo… in AsyncClientStreamingCall()
166 …TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TRespo… in AsyncDuplexStreamingCall()
175 …TResponse> AsyncClientStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TRespo… in AsyncClientStreamingCall()
182 …unaryResponse => (TResponse)(object)counter.ToString() // Cast to object first is needed to satis… in AsyncClientStreamingCall()
184 …return new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, responseAsync, response.Re… in AsyncClientStreamingCall()
DServerInterceptorTest.cs101 …ride Task<TResponse> UnaryServerHandler<TRequest, TResponse>(TRequest request, ServerCallContext c… in UnaryServerHandler()
107 …TResponse> ClientStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestS… in ClientStreamingServerHandler()
113 … TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStream, ServerCallContext con… in ServerStreamingServerHandler()
119 …TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> responseStre… in DuplexStreamingServerHandler()

12