Home
last modified time | relevance | path

Searched refs:cli_stream (Results 1 – 4 of 4) sorted by relevance

/external/grpc-grpc/test/cpp/end2end/
Draw_end2end_test.cc230 std::unique_ptr<ClientAsyncWriter<EchoRequest>> cli_stream( in TEST_F() local
238 cli_stream->Write(send_request_, tag(3)); in TEST_F()
244 cli_stream->Write(send_request_, tag(5)); in TEST_F()
250 cli_stream->WritesDone(tag(7)); in TEST_F()
258 cli_stream->Finish(&recv_status_, tag(10)); in TEST_F()
275 std::unique_ptr<ClientAsyncReader<EchoResponse>> cli_stream( in TEST_F() local
288 cli_stream->Read(&recv_response_, tag(4)); in TEST_F()
293 cli_stream->Read(&recv_response_, tag(6)); in TEST_F()
298 cli_stream->Read(&recv_response_, tag(8)); in TEST_F()
301 cli_stream->Finish(&recv_status_, tag(9)); in TEST_F()
[all …]
Dasync_end2end_test.cc512 std::unique_ptr<ClientAsyncWriter<EchoRequest>> cli_stream( in TEST_P() local
520 cli_stream->Write(send_request, tag(3)); in TEST_P()
525 cli_stream->Write(send_request, tag(5)); in TEST_P()
530 cli_stream->WritesDone(tag(7)); in TEST_P()
536 cli_stream->Finish(&recv_status, tag(10)); in TEST_P()
559 std::unique_ptr<ClientAsyncWriter<EchoRequest>> cli_stream( in TEST_P() local
565 cli_stream->Write(send_request, tag(3)); in TEST_P()
577 cli_stream->WriteLast(send_request, WriteOptions(), tag(5)); in TEST_P()
587 cli_stream->Finish(&recv_status, tag(9)); in TEST_P()
608 std::unique_ptr<ClientAsyncReader<EchoResponse>> cli_stream( in TEST_P() local
[all …]
Dfilter_end2end_test.cc270 std::unique_ptr<GenericClientAsyncReaderWriter> cli_stream = in TEST_F() local
272 cli_stream->StartCall(tag(1)); in TEST_F()
284 cli_stream->Write(*send_buffer, tag(3)); in TEST_F()
300 cli_stream->Read(&recv_buffer, tag(6)); in TEST_F()
305 cli_stream->WritesDone(tag(7)); in TEST_F()
314 cli_stream->Finish(&recv_status, tag(10)); in TEST_F()
Dgeneric_end2end_test.cc273 std::unique_ptr<GenericClientAsyncReaderWriter> cli_stream = in TEST_F() local
275 cli_stream->StartCall(tag(1)); in TEST_F()
287 cli_stream->Write(*send_buffer, tag(3)); in TEST_F()
303 cli_stream->Read(&recv_buffer, tag(6)); in TEST_F()
308 cli_stream->WritesDone(tag(7)); in TEST_F()
317 cli_stream->Finish(&recv_status, tag(10)); in TEST_F()