Home
last modified time | relevance | path

Searched defs:requestStream (Results 1 – 25 of 25) sorted by relevance

/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DTestServiceImpl.cs61 …StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<StreamingInputCallRequest> reque… in StreamingInputCall()
74 …public override async Task FullDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestSt… in FullDuplexCall()
89 …public override Task HalfDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, … in HalfDuplexCall()
DWorkerServiceImpl.cs42 …public override async Task RunServer(IAsyncStreamReader<ServerArgs> requestStream, IServerStreamWr… in RunServer()
66 …public override async Task RunClient(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWr… in RunClient()
DBenchmarkServiceGrpc.cs100 …tem.Threading.Tasks.Task StreamingCall(grpc::IAsyncStreamReader<global::Grpc.Testing.SimpleRequest… in StreamingCall()
112 …ng.SimpleResponse> StreamingFromClient(grpc::IAsyncStreamReader<global::Grpc.Testing.SimpleRequest… in StreamingFromClient()
138 …Threading.Tasks.Task StreamingBothWays(grpc::IAsyncStreamReader<global::Grpc.Testing.SimpleRequest… in StreamingBothWays()
DBenchmarkServiceImpl.cs44 …public override async Task StreamingCall(IAsyncStreamReader<SimpleRequest> requestStream, IServerS… in StreamingCall()
DSslCredentialsTest.cs102 …StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<StreamingInputCallRequest> reque… in StreamingInputCall()
DServerRunners.cs104 …public async Task StreamingCall(IAsyncStreamReader<byte[]> requestStream, IServerStreamWriter<byte… in StreamingCall()
DWorkerServiceGrpc.cs89 …l::System.Threading.Tasks.Task RunServer(grpc::IAsyncStreamReader<global::Grpc.Testing.ServerArgs>… in RunServer()
106 …l::System.Threading.Tasks.Task RunClient(grpc::IAsyncStreamReader<global::Grpc.Testing.ClientArgs>… in RunClient()
DTestGrpc.cs165 …CallResponse> StreamingInputCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingInputCallR… in StreamingInputCall()
179 …eading.Tasks.Task FullDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingOutputCall… in FullDuplexCall()
194 …eading.Tasks.Task HalfDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingOutputCall… in HalfDuplexCall()
/external/grpc-grpc/src/csharp/Grpc.Examples/
DMathServiceImpl.cs52 …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()
DMathGrpc.cs94 …l global::System.Threading.Tasks.Task DivMany(grpc::IAsyncStreamReader<global::Math.DivArgs> reque… in DivMany()
120 …stem.Threading.Tasks.Task<global::Math.Num> Sum(grpc::IAsyncStreamReader<global::Math.Num> request… in Sum()
/external/grpc-grpc/src/csharp/Grpc.Core/
DCalls.cs98 var requestStream = new ClientRequestStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
117 var requestStream = new ClientRequestStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
DAsyncDuplexStreamingCall.cs31 readonly IClientStreamWriter<TRequest> requestStream; field in Grpc.Core.AsyncDuplexStreamingCall
47 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall()
DAsyncClientStreamingCall.cs32 readonly IClientStreamWriter<TRequest> requestStream; field in Grpc.Core.AsyncClientStreamingCall
48 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall()
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideServer/
DRouteGuideImpl.cs67 …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.Core.Testing/
DTestCalls.cs46 IClientStreamWriter<TRequest> requestStream, Task<TResponse> responseAsync, in AsyncClientStreamingCall()
69 … IClientStreamWriter<TRequest> requestStream, IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall()
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/
DServerInterceptorTest.cs107 …nse> ClientStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream,… in ClientStreamingServerHandler()
119 …Task DuplexStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream,… in DuplexStreamingServerHandler()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DClientResponseObserver.java44 void beforeStart(final ClientCallStreamObserver<ReqT> requestStream); in beforeStart()
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuide/
DRouteGuideGrpc.cs118 …lobal::Routeguide.RouteSummary> RecordRoute(grpc::IAsyncStreamReader<global::Routeguide.Point> req… in RecordRoute()
133 …al::System.Threading.Tasks.Task RouteChat(grpc::IAsyncStreamReader<global::Routeguide.RouteNote> r… in RouteChat()
/external/exoplayer/tree/extensions/ima/src/test/java/com/google/android/exoplayer2/ext/ima/
DFakeAdsLoader.java77 public String requestStream(StreamRequest streamRequest) { in requestStream() method in FakeAdsLoader
/external/grpc-grpc/src/csharp/Grpc.Reflection/
DReflectionServiceImpl.cs66 …public override async Task ServerReflectionInfo(IAsyncStreamReader<ServerReflectionRequest> reques… in ServerReflectionInfo()
DReflectionGrpc.cs59 …ks.Task ServerReflectionInfo(grpc::IAsyncStreamReader<global::Grpc.Reflection.V1Alpha.ServerReflec… in ServerReflectionInfo()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DHttp2OkHttpTest.java125 StreamObserver<Messages.StreamingOutputCallRequest> requestStream = in receivedDataForFinishedStream() local
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DAbstractInteropTest.java822 StreamObserver<StreamingOutputCallRequest> requestStream = in fullDuplexCallShouldSucceed() local
862 StreamObserver<StreamingOutputCallRequest> requestStream = asyncStub.halfDuplexCall(recorder); in halfDuplexCallShouldSucceed() local
1028 StreamObserver<Messages.StreamingOutputCallRequest> requestStream = in exchangeMetadataStreamingCall() local
1447 StreamObserver<Messages.StreamingOutputCallRequest> requestStream = in customMetadata() local
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DServerCallHandler.cs303 …private Task UnimplementedMethod(IAsyncStreamReader<byte[]> requestStream, IServerStreamWriter<byt… in UnimplementedMethod()
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DProtoReflectionServiceTest.java596 public void beforeStart(final ClientCallStreamObserver<ServerReflectionRequest> requestStream) { in beforeStart()