Home
last modified time | relevance | path

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

12

/third_party/grpc/src/csharp/Grpc.IntegrationTesting/
DInteropClient.cs256 var responseList = await call.ResponseStream.ToListAsync(); in RunServerStreamingAsync()
274 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
275 Assert.AreEqual(31415, call.ResponseStream.Current.Payload.Body.Length); in RunPingPongAsync()
283 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
284 Assert.AreEqual(9, call.ResponseStream.Current.Payload.Body.Length); in RunPingPongAsync()
292 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
293 Assert.AreEqual(2653, call.ResponseStream.Current.Payload.Body.Length); in RunPingPongAsync()
301 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
302 Assert.AreEqual(58979, call.ResponseStream.Current.Payload.Body.Length); in RunPingPongAsync()
306 Assert.IsFalse(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
[all …]
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()
DMetadataCredentialsTest.cs179 Assert.IsTrue(await call.ResponseStream.MoveNext()); in MetadataCredentials_Composed()
180 Assert.IsFalse(await call.ResponseStream.MoveNext()); in MetadataCredentials_Composed()
207 Assert.IsTrue(await call.ResponseStream.MoveNext()); in MetadataCredentials_ComposedPerCall()
208 Assert.IsFalse(await call.ResponseStream.MoveNext()); in MetadataCredentials_ComposedPerCall()
DUnobservedTaskExceptionTest.cs91 var firstResponse = await call.ResponseStream.MoveNext(); in NoUnobservedTaskExceptionForAbandonedStreamingResponse()
/third_party/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()
170 var result = await call.ResponseStream.ToListAsync(); in DivMany()
/third_party/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()
/third_party/grpc/src/csharp/Grpc.Core.Tests/
DClientServerTest.cs218 …CollectionAssert.AreEqual(new string[] { "A", "B", "C" }, await call.ResponseStream.ToListAsync()); in ServerStreamingCall()
231 Assert.IsFalse(await call.ResponseStream.MoveNext()); in ServerStreamingCall_EndOfStreamIsIdempotent()
232 Assert.IsFalse(await call.ResponseStream.MoveNext()); in ServerStreamingCall_EndOfStreamIsIdempotent()
246 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ServerStreamingCall_ErrorCanBeAwaitedTwice()
250 … var ex2 = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ServerStreamingCall_ErrorCanBeAwaitedTwice()
265 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ServerStreamingCall_TrailersFromMultipleSourcesGetConcatenated()
289 …CollectionAssert.AreEqual(new string[] { "A", "B", "C" }, await call.ResponseStream.ToListAsync()); in DuplexStreamingCall()
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()
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()
DCompressionTest.cs105 await call.ResponseStream.ToListAsync(); in WriteOptions_DuplexStreaming()
DMarshallingErrorsTest.cs100 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ResponseParsingError_StreamingResponse()
/third_party/grpc/src/proto/grpc/testing/
Decho.proto33 rpc ResponseStream(EchoRequest) returns (stream EchoResponse); rpc
46 rpc ResponseStream(EchoRequest) returns (stream EchoResponse); rpc
59 rpc ResponseStream(EchoRequest) returns (stream EchoResponse); rpc
/third_party/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()
/third_party/grpc/test/cpp/end2end/
Dserver_crash_test.cc68 Status ResponseStream(ServerContext* /*context*/, in ResponseStream() function in grpc::testing::__anon11d024890111::ServiceImpl
123 TEST_F(CrashTest, ResponseStream) { in TEST_F() argument
Dserver_crash_test_client.cc62 auto stream = stub->ResponseStream(&context, request); in main()
Dtest_service_impl.h308 Status ResponseStream(ServerContext* context, const EchoRequest* request, in ResponseStream() function
455 experimental::ServerWriteReactor<EchoResponse>* ResponseStream(
Dmock_test.cc112 stub_->ResponseStream(&context, request); in DoResponseStream()
268 Status ResponseStream(ServerContext* /*context*/, const EchoRequest* request, in ResponseStream() function in grpc::testing::__anonc912ef6c0111::TestServiceImpl
Dinterceptors_util.cc69 auto reader = stub->ResponseStream(&ctx, req); in MakeServerStreamingCall()
Dend2end_test.cc597 auto stream = stub_->ResponseStream(&context, request); in TestResponseStreamServerCancel()
980 TEST_P(End2endTest, ResponseStream) { in TEST_P() argument
987 auto stream = stub_->ResponseStream(&context, request); in TEST_P()
1006 auto stream = stub_->ResponseStream(&context, request); in TEST_P()
1030 auto stream = stub_->ResponseStream(&context, request); in TEST_P()
1233 auto stream = stub_->ResponseStream(&context, request); in TEST_P()
/third_party/grpc/src/csharp/Grpc.Examples/
DMathExamples.cs43 List<Num> result = await call.ResponseStream.ToListAsync(); in FibExample()
76 … Console.WriteLine("DivMany Result: " + string.Join("|", await call.ResponseStream.ToListAsync())); in DivManyExample()
/third_party/grpc/src/csharp/Grpc.Core.Api/
DAsyncServerStreamingCall.cs74 public IAsyncStreamReader<TResponse> ResponseStream property in Grpc.Core.AsyncServerStreamingCall
DAsyncDuplexStreamingCall.cs82 public IAsyncStreamReader<TResponse> ResponseStream property in Grpc.Core.AsyncDuplexStreamingCall
/third_party/grpc/src/proto/grpc/testing/duplicate/
Decho_duplicate.proto26 rpc ResponseStream(EchoRequest) returns (stream EchoResponse); rpc
/third_party/grpc/test/cpp/ios/CronetTests/
DTestHelper.h71 grpc::Status ResponseStream(

12