Home
last modified time | relevance | path

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

12

/external/grpc-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()
DContextPropagationTest.cs131 await call.RequestStream.CompleteAsync(); in PropagateDeadline()
154 await call.RequestStream.CompleteAsync(); in SuppressDeadlinePropagation()
DResponseHeadersTest.cs93 await call.RequestStream.CompleteAsync(); in ResponseHeadersAsync_ClientStreamingCall()
132 await call.RequestStream.WriteAllAsync(messages); in ResponseHeadersAsync_DuplexStreamingCall()
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DInteropClient.cs232 await call.RequestStream.WriteAllAsync(bodySizes); in RunClientStreamingAsync()
265 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
274 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
283 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
292 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunPingPongAsync()
301 await call.RequestStream.CompleteAsync(); in RunPingPongAsync()
313 await call.RequestStream.CompleteAsync(); in RunEmptyStreamAsync()
424 await call.RequestStream.WriteAsync(new StreamingOutputCallRequest in RunCancelAfterFirstResponseAsync()
458 …await call.RequestStream.WriteAsync(new StreamingOutputCallRequest { Payload = CreateZerosPayload(… in RunTimeoutOnSleepingServerAsync()
514 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.cs90 await call.RequestStream.CompleteAsync(); in AuthContextIsPopulated()
/external/grpc-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::__anon1cb3fe010111::TestServiceImpl
190 auto stream = stub_->RequestStream(&context, &response); in DoRequestStream()
Dtest_service_impl.h57 Status RequestStream(ServerContext* context,
Dmock_test.cc87 stub_->RequestStream(&context, &response); in DoRequestStream()
172 Status RequestStream(ServerContext* context, in RequestStream() function in grpc::testing::__anonecd97ab90111::TestServiceImpl
Dend2end_test.cc388 auto stream = stub_->RequestStream(&context, &response); in TestRequestStreamServerCancel()
738 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
755 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
769 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
785 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
802 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
1002 auto stream = stub_->RequestStream(&context, &response); in TEST_P()
/external/grpc-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()
/external/grpc-grpc/src/csharp/Grpc.Examples/
DMathExamples.cs59 await call.RequestStream.WriteAllAsync(numbers); in SumExample()
74 await call.RequestStream.WriteAllAsync(divArgsList); in DivManyExample()
91 await sumCall.RequestStream.WriteAllAsync(numbers); in DependendRequestsExample()
/external/rust/crates/grpcio/src/call/
Dserver.rs265 pub struct RequestStream<T> { struct
271 impl<T> RequestStream<T> { implementation
272 fn new(call: Arc<Mutex<ShareCall>>, de: DeserializeFn<T>) -> RequestStream<T> { in new()
273 RequestStream { in new()
281 impl<T> Stream for RequestStream<T> { implementation
298 impl<T> Drop for RequestStream<T> { implementation
725 F: FnMut(RpcContext<'_>, RequestStream<P>, ClientStreamingSink<Q>), in execute_client_streaming()
731 let req_s = RequestStream::new(call.clone(), de); in execute_client_streaming()
772 F: FnMut(RpcContext<'_>, RequestStream<P>, DuplexSink<Q>), in execute_duplex_streaming()
778 let req_s = RequestStream::new(call.clone(), de); in execute_duplex_streaming()
/external/rust/crates/grpcio-sys/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
/external/grpc-grpc/src/csharp/Grpc.Reflection.Tests/
DReflectionClientServerTest.cs131 await call.RequestStream.WriteAsync(request); in SingleRequestAsync()
135 await call.RequestStream.CompleteAsync(); in SingleRequestAsync()
/external/grpc-grpc/src/csharp/Grpc.Examples.Tests/
DMathClientServerTests.cs153 await call.RequestStream.WriteAllAsync(numbers); in Sum()
171 await call.RequestStream.WriteAllAsync(divArgsList); in DivMany()
/external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
DEchoTestServiceClient.php51 public function RequestStream($metadata = [], $options = []) { function in Grpc\\Testing\\EchoTestServiceClient
/external/grpc-grpc/src/csharp/Grpc.Core/
DAsyncDuplexStreamingCall.cs76 public IClientStreamWriter<TRequest> RequestStream property in Grpc.Core.AsyncDuplexStreamingCall
DAsyncClientStreamingCall.cs88 public IClientStreamWriter<TRequest> RequestStream property in Grpc.Core.AsyncClientStreamingCall
/external/grpc-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()
/external/rust/crates/grpcio/src/
Dlib.rs53 RequestStream, RpcContext, ServerStreamingSink, ServerStreamingSinkFailure, UnarySink,
/external/grpc-grpc/src/proto/grpc/testing/
Decho.proto24 rpc RequestStream(stream EchoRequest) returns (EchoResponse); rpc

12