mirrors/arrow
0
0 Fork 0
mirror of https://github.com/apache/arrow.git synced 2026-10-29 09:05:47 +08:00
Code Activity

Fix unit tests

Browse Source
This commit is contained in:
Wes McKinney committed 2019-05-31 08:11:28 -05:00
1 parent b6e1739225
commit cc7789e8f0
1 file changed
+16
Download Patch File Download Diff File Expand all files Collapse all files
cpp/src/arrow/io/buffered-test.cc
+16
View File
@@ -575,6 +575,22 @@ TEST_F(TestBufferedInputStreamBound, UnboundedPeek) {
ASSERT_EQ(10, view.size());
ASSERT_EQ(50, stream_->bytes_buffered());
std::shared_ptr<Buffer> buf;
ASSERT_OK(stream_->Read(10, &buf));
// Peek into buffered bytes
ASSERT_OK(stream_->Peek(40, &view));
ASSERT_EQ(40, view.size());
ASSERT_EQ(40, stream_->bytes_buffered());
ASSERT_EQ(50, stream_->buffer_size());
// Peek past buffered bytes
ASSERT_OK(stream_->Peek(41, &view));
ASSERT_EQ(41, view.size());
ASSERT_EQ(41, stream_->bytes_buffered());
ASSERT_EQ(51, stream_->buffer_size());
// Peek to the end of the buffer
ASSERT_OK(stream_->Peek(246, &view));
ASSERT_EQ(246, view.size());
ASSERT_EQ(246, stream_->bytes_buffered());