Home
last modified time | relevance | path

Searched refs:ResponseStream (Results 1 – 25 of 26) sorted by relevance

12

/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DInteropClient.cs253 var responseList = await call.ResponseStream.ToListAsync(); in RunServerStreamingAsync()
271 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
272 Assert.AreEqual(31415, call.ResponseStream.Current.Payload.Body.Length); in RunPingPongAsync()
280 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
281 Assert.AreEqual(9, call.ResponseStream.Current.Payload.Body.Length); in RunPingPongAsync()
289 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
290 Assert.AreEqual(2653, call.ResponseStream.Current.Payload.Body.Length); in RunPingPongAsync()
298 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
299 Assert.AreEqual(58979, call.ResponseStream.Current.Payload.Body.Length); in RunPingPongAsync()
303 Assert.IsFalse(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
[all …]
DMetadataCredentialsTest.cs113 Assert.IsTrue(await call.ResponseStream.MoveNext()); in MetadataCredentials_Composed()
114 Assert.IsFalse(await call.ResponseStream.MoveNext()); in MetadataCredentials_Composed()
136 Assert.IsTrue(await call.ResponseStream.MoveNext()); in MetadataCredentials_ComposedPerCall()
137 Assert.IsFalse(await call.ResponseStream.MoveNext()); in MetadataCredentials_ComposedPerCall()
DGeneratedServiceBaseTest.cs81 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in UnimplementedByDefault_ServerStreamingCall()
90 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in UnimplementedByDefault_DuplexStreamingCall()
DClientRunners.cs264 await call.ResponseStream.MoveNext(); in RunStreamingPingPongAsync()
275 Assert.IsFalse(await call.ResponseStream.MoveNext()); in RunStreamingPingPongAsync()
292 await call.ResponseStream.MoveNext(); in RunGenericStreamingAsync()
303 Assert.IsFalse(await call.ResponseStream.MoveNext()); in RunGenericStreamingAsync()
/external/grpc-grpc/src/csharp/Grpc.Examples.Tests/
DMathClientServerTests.cs97 var responses = await call.ResponseStream.ToListAsync(); in Fib()
114 while (await call.ResponseStream.MoveNext()) in FibWithCancel()
120 responses.Add(call.ResponseStream.Current.Num_); in FibWithCancel()
138 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.ToListAsync()); in FibWithDeadline()
172 var result = await call.ResponseStream.ToListAsync(); in DivMany()
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DClientServerTest.cs198 …CollectionAssert.AreEqual(new string[] { "A", "B", "C" }, await call.ResponseStream.ToListAsync()); in ServerStreamingCall()
211 Assert.IsFalse(await call.ResponseStream.MoveNext()); in ServerStreamingCall_EndOfStreamIsIdempotent()
212 Assert.IsFalse(await call.ResponseStream.MoveNext()); in ServerStreamingCall_EndOfStreamIsIdempotent()
226 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ServerStreamingCall_ErrorCanBeAwaitedTwice()
230 … var ex2 = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ServerStreamingCall_ErrorCanBeAwaitedTwice()
245 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ServerStreamingCall_TrailersFromMultipleSourcesGetConcatenated()
269 …CollectionAssert.AreEqual(new string[] { "A", "B", "C" }, await call.ResponseStream.ToListAsync()); in DuplexStreamingCall()
DCallCancellationTest.cs163 await call.ResponseStream.MoveNext(); in ServerStreamingCall_CancelClientSideRead()
164 Assert.AreEqual("abc", call.ResponseStream.Current); in ServerStreamingCall_CancelClientSideRead()
167 var moveNextTask = call.ResponseStream.MoveNext(cts.Token); in ServerStreamingCall_CancelClientSideRead()
DResponseHeadersTest.cs113 CollectionAssert.AreEqual(new[] { "PASS" }, await call.ResponseStream.ToListAsync()); in ResponseHeadersAsync_ServerStreamingCall()
135 CollectionAssert.AreEqual(messages, await call.ResponseStream.ToListAsync()); in ResponseHeadersAsync_DuplexStreamingCall()
188 var responses = await call.ResponseStream.ToListAsync(); in WriteResponseHeaders_NotAllowedAfterWrite()
DCompressionTest.cs105 await call.ResponseStream.ToListAsync(); in WriteOptions_DuplexStreaming()
DMarshallingErrorsTest.cs100 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ResponseParsingError_StreamingResponse()
/external/grpc-grpc/src/csharp/Grpc.Reflection.Tests/
DReflectionClientServerTest.cs132 Assert.IsTrue(await call.ResponseStream.MoveNext()); in SingleRequestAsync()
134 var response = call.ResponseStream.Current; in SingleRequestAsync()
136 Assert.IsFalse(await call.ResponseStream.MoveNext()); in SingleRequestAsync()
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideClient/
DProgram.cs87 var responseStream = call.ResponseStream; in ListFeatures()
168 while (await call.ResponseStream.MoveNext()) in RouteChat()
170 var note = call.ResponseStream.Current; in RouteChat()
/external/grpc-grpc/test/cpp/end2end/
Dserver_crash_test.cc68 Status ResponseStream(ServerContext* context, const EchoRequest* request, in ResponseStream() function in grpc::testing::__anon96d95d380111::ServiceImpl
122 TEST_F(CrashTest, ResponseStream) { in TEST_F() argument
Dserver_crash_test_client.cc68 auto stream = stub->ResponseStream(&context, request); in main()
Dtest_service_impl.h61 Status ResponseStream(ServerContext* context, const EchoRequest* request,
Dmock_test.cc111 stub_->ResponseStream(&context, request); in DoResponseStream()
185 Status ResponseStream(ServerContext* context, const EchoRequest* request, in ResponseStream() function in grpc::testing::__anon7521e91b0111::TestServiceImpl
Dend2end_test.cc462 auto stream = stub_->ResponseStream(&context, request); in TestResponseStreamServerCancel()
811 TEST_P(End2endTest, ResponseStream) { in TEST_P() argument
818 auto stream = stub_->ResponseStream(&context, request); in TEST_P()
837 auto stream = stub_->ResponseStream(&context, request); in TEST_P()
861 auto stream = stub_->ResponseStream(&context, request); in TEST_P()
1022 auto stream = stub_->ResponseStream(&context, request); in TEST_P()
Dtest_service_impl.cc220 Status TestServiceImpl::ResponseStream(ServerContext* context, in ResponseStream() function in grpc::testing::TestServiceImpl
Dhybrid_end2end_test.cc341 auto stream = stub_->ResponseStream(&context, request); in SendSimpleServerStreaming()
364 auto stream = stub->ResponseStream(&context, request); in SendSimpleServerStreamingToDupService()
/external/grpc-grpc/src/csharp/Grpc.Examples/
DMathExamples.cs43 List<Num> result = await call.ResponseStream.ToListAsync(); in FibExample()
75 … Console.WriteLine("DivMany Result: " + string.Join("|", await call.ResponseStream.ToListAsync())); in DivManyExample()
/external/grpc-grpc/src/csharp/Grpc.Core/
DAsyncServerStreamingCall.cs60 public IAsyncStreamReader<TResponse> ResponseStream property in Grpc.Core.AsyncServerStreamingCall
DAsyncDuplexStreamingCall.cs65 public IAsyncStreamReader<TResponse> ResponseStream property in Grpc.Core.AsyncDuplexStreamingCall
/external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
DEchoTestServiceClient.php62 public function ResponseStream(\Grpc\Testing\EchoRequest $argument, function in Grpc\\Testing\\EchoTestServiceClient
/external/grpc-grpc/src/proto/grpc/testing/duplicate/
Decho_duplicate.proto26 rpc ResponseStream(EchoRequest) returns (stream EchoResponse); rpc
/external/grpc-grpc/src/proto/grpc/testing/
Decho.proto25 rpc ResponseStream(EchoRequest) returns (stream EchoResponse); rpc

12