| 557 | } |
| 558 | |
| 559 | void TestChunked() { |
| 560 | auto src = Buffer::FromString("1234567890abcdefghi"); |
| 561 | ASSERT_OK_AND_ASSIGN(auto expected, this->transform()(src)); |
| 562 | |
| 563 | auto stream = std::make_shared<TransformInputStream>( |
| 564 | std::make_shared<BufferReader>(src), this->transform()); |
| 565 | std::shared_ptr<Buffer> actual; |
| 566 | AccumulateReads(stream, 5, &actual); |
| 567 | AssertBufferEqual(*actual, *expected); |
| 568 | } |
| 569 | |
| 570 | void TestStressChunked() { |
| 571 | ASSERT_OK_AND_ASSIGN(auto unique_src, AllocateBuffer(1000)); |
no test coverage detected