| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | AsyncServerStreamingCall.cs | 30 readonly IAsyncStreamReader<TResponse> responseStream;
44 public AsyncServerStreamingCall(IAsyncStreamReader<TResponse> responseStream, in AsyncServerStreamingCall()
60 public IAsyncStreamReader<TResponse> ResponseStream
|
| D | AsyncDuplexStreamingCall.cs | 32 readonly IAsyncStreamReader<TResponse> responseStream;
48 IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall()
65 public IAsyncStreamReader<TResponse> ResponseStream
|
| D | ServerMethods.cs | 37 …e Task<TResponse> ClientStreamingServerMethod<TRequest, TResponse>(IAsyncStreamReader<TRequest> re…
55 …public delegate Task DuplexStreamingServerMethod<TRequest, TResponse>(IAsyncStreamReader<TRequest>…
|
| D | IAsyncStreamReader.cs | 53 public interface IAsyncStreamReader<T> : IAsyncEnumerator<T> interface
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | TestServiceImpl.cs | 61 …override async Task<StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<StreamingInp… in StreamingInputCall()
74 …public override async Task FullDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestSt… in FullDuplexCall()
89 …public override Task HalfDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, … in HalfDuplexCall()
|
| D | WorkerServiceImpl.cs | 42 …public override async Task RunServer(IAsyncStreamReader<ServerArgs> requestStream, IServerStreamWr… in RunServer()
66 …public override async Task RunClient(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWr… in RunClient()
|
| D | BenchmarkServiceGrpc.cs | 100 …public virtual global::System.Threading.Tasks.Task StreamingCall(grpc::IAsyncStreamReader<global::… in StreamingCall()
112 …ask<global::Grpc.Testing.SimpleResponse> StreamingFromClient(grpc::IAsyncStreamReader<global::Grpc… in StreamingFromClient()
138 …public virtual global::System.Threading.Tasks.Task StreamingBothWays(grpc::IAsyncStreamReader<glob… in StreamingBothWays()
|
| D | BenchmarkServiceImpl.cs | 44 …public override async Task StreamingCall(IAsyncStreamReader<SimpleRequest> requestStream, IServerS… in StreamingCall()
|
| D | SslCredentialsTest.cs | 102 …override async Task<StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<StreamingInp… in StreamingInputCall()
|
| D | ServerRunners.cs | 104 …public async Task StreamingCall(IAsyncStreamReader<byte[]> requestStream, IServerStreamWriter<byte… in StreamingCall()
|
| D | WorkerServiceGrpc.cs | 89 …public virtual global::System.Threading.Tasks.Task RunServer(grpc::IAsyncStreamReader<global::Grpc… in RunServer()
106 …public virtual global::System.Threading.Tasks.Task RunClient(grpc::IAsyncStreamReader<global::Grpc… in RunClient()
|
| D | TestGrpc.cs | 165 …:Grpc.Testing.StreamingInputCallResponse> StreamingInputCall(grpc::IAsyncStreamReader<global::Grpc… in StreamingInputCall()
179 …public virtual global::System.Threading.Tasks.Task FullDuplexCall(grpc::IAsyncStreamReader<global:… in FullDuplexCall()
194 …public virtual global::System.Threading.Tasks.Task HalfDuplexCall(grpc::IAsyncStreamReader<global:… in HalfDuplexCall()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Utils/ |
| D | AsyncStreamExtensions.cs | 33 …public static async Task ForEachAsync<T>(this IAsyncStreamReader<T> streamReader, Func<T, Task> as…
45 public static async Task<List<T>> ToListAsync<T>(this IAsyncStreamReader<T> streamReader)
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Testing/ |
| D | TestCalls.cs | 58 IAsyncStreamReader<TResponse> responseStream, Task<Metadata> responseHeadersAsync, in AsyncServerStreamingCall()
69 … IClientStreamWriter<TRequest> requestStream, IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall()
|
| /external/grpc-grpc/src/csharp/Grpc.Examples/ |
| D | MathServiceImpl.cs | 52 …public override async Task<Num> Sum(IAsyncStreamReader<Num> requestStream, ServerCallContext conte… in Sum()
63 …public override async Task DivMany(IAsyncStreamReader<DivArgs> requestStream, IServerStreamWriter<… in DivMany()
|
| D | MathGrpc.cs | 94 …public virtual global::System.Threading.Tasks.Task DivMany(grpc::IAsyncStreamReader<global::Math.D… in DivMany()
120 …al global::System.Threading.Tasks.Task<global::Math.Num> Sum(grpc::IAsyncStreamReader<global::Math… in Sum()
|
| /external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideServer/ |
| D | RouteGuideImpl.cs | 67 …public override async Task<RouteSummary> RecordRoute(IAsyncStreamReader<Point> requestStream, Serv… in RecordRoute()
106 …public override async Task RouteChat(IAsyncStreamReader<RouteNote> requestStream, IServerStreamWri… in RouteChat()
|
| /external/grpc-grpc/src/csharp/Grpc.Examples.Tests/ |
| D | MathClientMockableTest.cs | 80 var mockResponseStream = new Moq.Mock<IAsyncStreamReader<Num>>(); in ClientBaseServerStreamingCallCanBeMocked()
93 var mockResponseStream = new Moq.Mock<IAsyncStreamReader<DivReply>>(); in ClientBaseDuplexStreamingCallCanBeMocked()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Interceptors/ |
| D | Interceptor.cs | 346 … Task<TResponse> ClientStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> re…
398 …public virtual Task DuplexStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest>…
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/ |
| D | ServerInterceptorTest.cs | 107 … Task<TResponse> ClientStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> re… in ClientStreamingServerHandler()
119 …ic override Task DuplexStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> re… in DuplexStreamingServerHandler()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerRequestStream.cs | 26 internal class ServerRequestStream<TRequest, TResponse> : IAsyncStreamReader<TRequest>
|
| D | ClientResponseStream.cs | 26 internal class ClientResponseStream<TRequest, TResponse> : IAsyncStreamReader<TResponse>
|
| /external/grpc-grpc/examples/csharp/RouteGuide/RouteGuide/ |
| D | RouteGuideGrpc.cs | 118 …ding.Tasks.Task<global::Routeguide.RouteSummary> RecordRoute(grpc::IAsyncStreamReader<global::Rout… in RecordRoute()
133 …public virtual global::System.Threading.Tasks.Task RouteChat(grpc::IAsyncStreamReader<global::Rout… in RouteChat()
|
| /external/grpc-grpc/src/csharp/Grpc.Reflection/ |
| D | ReflectionGrpc.cs | 59 …ual global::System.Threading.Tasks.Task ServerReflectionInfo(grpc::IAsyncStreamReader<global::Grpc… in ServerReflectionInfo()
|
| D | ReflectionServiceImpl.cs | 66 …public override async Task ServerReflectionInfo(IAsyncStreamReader<ServerReflectionRequest> reques… in ServerReflectionInfo()
|