|
|
|
@ -175,7 +175,8 @@ class FilterEnd2endTest : public ::testing::Test { |
|
|
|
|
// The string needs to be long enough to test heap-based slice.
|
|
|
|
|
send_request.set_message("Hello world. Hello world. Hello world."); |
|
|
|
|
std::unique_ptr<GenericClientAsyncReaderWriter> call = |
|
|
|
|
generic_stub_->Call(&cli_ctx, kMethodName, &cli_cq_, tag(1)); |
|
|
|
|
generic_stub_->PrepareCall(&cli_ctx, kMethodName, &cli_cq_); |
|
|
|
|
call->StartCall(tag(1)); |
|
|
|
|
client_ok(1); |
|
|
|
|
std::unique_ptr<ByteBuffer> send_buffer = |
|
|
|
|
SerializeToByteBuffer(&send_request); |
|
|
|
@ -268,7 +269,8 @@ TEST_F(FilterEnd2endTest, SimpleBidiStreaming) { |
|
|
|
|
cli_ctx.set_compression_algorithm(GRPC_COMPRESS_MESSAGE_GZIP); |
|
|
|
|
send_request.set_message("Hello"); |
|
|
|
|
std::unique_ptr<GenericClientAsyncReaderWriter> cli_stream = |
|
|
|
|
generic_stub_->Call(&cli_ctx, kMethodName, &cli_cq_, tag(1)); |
|
|
|
|
generic_stub_->PrepareCall(&cli_ctx, kMethodName, &cli_cq_); |
|
|
|
|
cli_stream->StartCall(tag(1)); |
|
|
|
|
client_ok(1); |
|
|
|
|
|
|
|
|
|
generic_service_.RequestCall(&srv_ctx, &srv_stream, srv_cq_.get(), |
|
|
|
|