Home
last modified time | relevance | path

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

12

/third_party/grpc/src/csharp/Grpc.Core.Tests/
DCompressionTest.cs92 Assert.IsTrue((call.RequestStream.WriteOptions.Flags & WriteFlags.NoCompress) != 0); in WriteOptions_DuplexStreaming()
94 call.RequestStream.WriteOptions = new WriteOptions(); in WriteOptions_DuplexStreaming()
95 await call.RequestStream.WriteAsync("A"); in WriteOptions_DuplexStreaming()
97 call.RequestStream.WriteOptions = null; in WriteOptions_DuplexStreaming()
98 await call.RequestStream.WriteAsync("B"); in WriteOptions_DuplexStreaming()
100 call.RequestStream.WriteOptions = new WriteOptions(WriteFlags.NoCompress); in WriteOptions_DuplexStreaming()
101 await call.RequestStream.WriteAsync("C"); in WriteOptions_DuplexStreaming()
103 await call.RequestStream.CompleteAsync(); in WriteOptions_DuplexStreaming()
DMarshallingErrorsTest.cs135 await call.RequestStream.WriteAsync("UNPARSEABLE_VALUE"); in RequestParsingError_StreamingRequest()
161 await call.RequestStream.WriteAsync("A"); in RequestSerializationError_ClientStreaming()
162 …Assert.ThrowsAsync<IOException>(async () => await call.RequestStream.WriteAsync("UNSERIALIZABLE_VA… in RequestSerializationError_ClientStreaming()
163 await call.RequestStream.WriteAsync("B"); in RequestSerializationError_ClientStreaming()
164 await call.RequestStream.CompleteAsync(); in RequestSerializationError_ClientStreaming()
DHalfcloseTest.cs76 await call.RequestStream.CompleteAsync(); in HalfcloseAfterFullclose_ClientStreamingCall()
79 …ThrowsAsync(typeof(InvalidOperationException), async () => await call.RequestStream.CompleteAsync(… in HalfcloseAfterFullclose_ClientStreamingCall()
DResponseHeadersTest.cs93 await call.RequestStream.CompleteAsync(); in ResponseHeadersAsync_ClientStreamingCall()
132 await call.RequestStream.WriteAllAsync(messages); in ResponseHeadersAsync_DuplexStreamingCall()
DContextPropagationTest.cs131 await call.RequestStream.CompleteAsync(); in PropagateDeadline()
154 await call.RequestStream.CompleteAsync(); in SuppressDeadlinePropagation()
DClientServerTest.cs201 await call.RequestStream.WriteAllAsync(new string[] { "A", "B", "C" }); in ClientStreamingCall()
288 await call.RequestStream.WriteAllAsync(new string[] { "A", "B", "C" }); in DuplexStreamingCall()
/third_party/grpc/src/csharp/Grpc.IntegrationTesting/
DInteropClient.cs235 await call.RequestStream.WriteAllAsync(bodySizes); in RunClientStreamingAsync()
268 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
277 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
286 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
295 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
304 await call.RequestStream.CompleteAsync(); in RunPingPongAsync()
316 await call.RequestStream.CompleteAsync(); in RunEmptyStreamAsync()
427 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunCancelAfterFirstResponseAsync()
461 …await call.RequestStream.WriteAsync(new StreamingOutputCallRequest { Payload = CreateZerosPayload(… in RunTimeoutOnSleepingServerAsync()
516 await call.RequestStream.WriteAsync(request); in RunCustomMetadataAsync()
[all …]
DClientRunners.cs263 await call.RequestStream.WriteAsync(request); in RunStreamingPingPongAsync()
274 await call.RequestStream.CompleteAsync(); in RunStreamingPingPongAsync()
291 await call.RequestStream.WriteAsync(request); in RunGenericStreamingAsync()
302 await call.RequestStream.CompleteAsync(); in RunGenericStreamingAsync()
DSslCredentialsTest.cs257 await call.RequestStream.CompleteAsync(); in CheckAuthContextIsPopulated()
/third_party/grpc/test/cpp/end2end/
Dexception_test.cc46 Status RequestStream(ServerContext* /*context*/, in RequestStream() function in grpc::testing::ExceptingServiceImpl
99 TEST_F(ExceptionTest, RequestStream) { in TEST_F() argument
105 auto stream = stub_->RequestStream(&context, &response); in TEST_F()
Dserver_early_return_test.cc51 Status RequestStream(ServerContext* context, in RequestStream() function in grpc::testing::__anon86206e540111::TestServiceImpl
190 auto stream = stub_->RequestStream(&context, &response); in DoRequestStream()
Dtest_service_impl.h258 Status RequestStream(ServerContext* context, in RequestStream() function
451 experimental::ServerReadReactor<EchoRequest>* RequestStream(
Dmock_test.cc88 stub_->RequestStream(&context, &response); in DoRequestStream()
255 Status RequestStream(ServerContext* /*context*/, in RequestStream() function in grpc::testing::__anonc912ef6c0111::TestServiceImpl
Dend2end_test.cc518 auto stream = stub_->RequestStream(&context, &response); in TestRequestStreamServerCancel()
907 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
924 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
938 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
954 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
971 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
1210 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
Dinterceptors_util.cc50 auto writer = stub->RequestStream(&ctx, &resp); in MakeClientStreamingCall()
/third_party/grpc/examples/csharp/RouteGuide/RouteGuideClient/
DProgram.cs125 await call.RequestStream.WriteAsync(point); in RecordRoute()
130 await call.RequestStream.CompleteAsync(); in RecordRoute()
181 await call.RequestStream.WriteAsync(request); in RouteChat()
183 await call.RequestStream.CompleteAsync(); in RouteChat()
/third_party/grpc/src/csharp/Grpc.Examples/
DMathExamples.cs59 await call.RequestStream.WriteAllAsync(numbers); in SumExample()
75 await call.RequestStream.WriteAllAsync(divArgsList); in DivManyExample()
92 await sumCall.RequestStream.WriteAllAsync(numbers); in DependentRequestsExample()
/third_party/grpc/src/proto/grpc/testing/
Decho.proto32 rpc RequestStream(stream EchoRequest) returns (EchoResponse); rpc
45 rpc RequestStream(stream EchoRequest) returns (EchoResponse); rpc
58 rpc RequestStream(stream EchoRequest) returns (EchoResponse); rpc
/third_party/grpc/src/csharp/Grpc.Reflection.Tests/
DReflectionClientServerTest.cs131 await call.RequestStream.WriteAsync(request); in SingleRequestAsync()
135 await call.RequestStream.CompleteAsync(); in SingleRequestAsync()
/third_party/grpc/src/csharp/Grpc.Examples.Tests/
DMathClientServerTests.cs151 await call.RequestStream.WriteAllAsync(numbers); in Sum()
169 await call.RequestStream.WriteAllAsync(divArgsList); in DivMany()
/third_party/grpc/src/csharp/Grpc.Core.Api/
DAsyncDuplexStreamingCall.cs93 public IClientStreamWriter<TRequest> RequestStream property in Grpc.Core.AsyncDuplexStreamingCall
DAsyncClientStreamingCall.cs105 public IClientStreamWriter<TRequest> RequestStream property in Grpc.Core.AsyncClientStreamingCall
/third_party/grpc/src/csharp/Grpc.Core.Tests/Interceptors/
DClientInterceptorTest.cs126 await call.RequestStream.WriteAllAsync(new string[] { "A", "B", "C" }); in CountNumberOfRequestsInClientInterceptors()
179 var requestStream = new WrappedClientStreamWriter<TRequest>(response.RequestStream, in AsyncClientStreamingCall()
/third_party/grpc/test/cpp/ios/CronetTests/
DTestHelper.h67 grpc::Status RequestStream(
DCppCronetEnd2EndTests.mm210 auto stream = stub->RequestStream(&context, &response);
226 auto stream = stub->RequestStream(&context, &response);
240 auto stream = stub->RequestStream(&context, &response);
344 auto stream = stub->RequestStream(&context, &response);

12