#ifdef UNSAFE_BUFFERS_BUILD
#pragma allow_unsafe_buffers
#endif
#include <stdint.h>
#include <list>
#include <map>
#include <memory>
#include <string>
#include "base/logging.h"
#include "base/memory/raw_ptr.h"
#include "base/strings/strcat.h"
#include "base/synchronization/waitable_event.h"
#include "build/build_config.h"
#include "components/grpc_support/include/bidirectional_stream_c.h"
#include "components/grpc_support/test/get_stream_engine.h"
#include "net/base/net_errors.h"
#include "net/test/quic_simple_test_server.h"
#include "net/test/test_data_directory.h"
#include "testing/gtest/include/gtest/gtest.h"
#include "url/gurl.h"
namespace {
bidirectional_stream_header kTestHeaders[] = …;
const bidirectional_stream_header_array kTestHeadersArray = …;
}
namespace grpc_support {
class BidirectionalStreamTest : public ::testing::TestWithParam<bool> { … };
class TestBidirectionalStreamCallback { … };
TestBidirectionalStreamCallback::WriteData::WriteData(std::string_view data,
bool flush_after)
: … { … }
TestBidirectionalStreamCallback::WriteData::~WriteData() { … }
TEST_P(BidirectionalStreamTest, CoalescedHeadersAreSplit) { … }
TEST_P(BidirectionalStreamTest, StartExampleBidiStream) { … }
TEST_P(BidirectionalStreamTest, SimplePutWithEmptyWriteDataAtTheEnd) { … }
TEST_P(BidirectionalStreamTest, SimpleGetWithFlush) { … }
TEST_P(BidirectionalStreamTest, SimplePostWithFlush) { … }
TEST_P(BidirectionalStreamTest, SimplePostWithFlushTwice) { … }
TEST_P(BidirectionalStreamTest, SimplePostWithFlushAfterOneWrite) { … }
TEST_P(BidirectionalStreamTest, TestDelayedFlush) { … }
TEST_P(BidirectionalStreamTest, CancelOnRead) { … }
TEST_P(BidirectionalStreamTest, CancelOnResponse) { … }
TEST_P(BidirectionalStreamTest, CancelOnSucceeded) { … }
TEST_P(BidirectionalStreamTest, ReadFailsBeforeRequestStarted) { … }
TEST_P(BidirectionalStreamTest,
DISABLED_StreamFailBeforeReadIsExecutedOnNetworkThread) { … }
TEST_P(BidirectionalStreamTest, WriteFailsBeforeRequestStarted) { … }
TEST_P(BidirectionalStreamTest, StreamFailAfterStreamReadyCallback) { … }
TEST_P(BidirectionalStreamTest,
DISABLED_StreamFailBeforeWriteIsExecutedOnNetworkThread) { … }
TEST_P(BidirectionalStreamTest, FailedResolution) { … }
INSTANTIATE_TEST_SUITE_P(…);
}