| 55 | } |
| 56 | |
| 57 | void NextBuffer(const char** begin, const char** end) { |
| 58 | EXPECT_EQ(*begin, *end); |
| 59 | *begin = *end = nullptr; |
| 60 | if (data_pos_ >= data_.size()) { |
| 61 | if (repeats_ == 0) return; |
| 62 | data_pos_ = 0; |
| 63 | --repeats_; |
| 64 | } |
| 65 | *begin = data_.data() + data_pos_; |
| 66 | size_t len = min(stream_size_, data_.size() - data_pos_); |
| 67 | *end = *begin + len; |
| 68 | data_pos_ += len; |
| 69 | } |
| 70 | |
| 71 | const vector<string>& schema() const { return schema_; } |
| 72 |