Skip to content

Commit 458a9cf

Browse files
committed
wip
1 parent b5b3d97 commit 458a9cf

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

include/sparrow_ipc/serialize_utils.hpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,8 @@ namespace sparrow_ipc
103103
}
104104

105105
// Calculate schema message size (only once)
106-
std::size_t total_size = calculate_schema_message_size(record_batches[0]);
106+
auto it = std::ranges::begin(record_batches);
107+
std::size_t total_size = calculate_schema_message_size(*it);
107108

108109
// Calculate record batch message sizes
109110
for (const auto& record_batch : record_batches)

include/sparrow_ipc/serializer.hpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ namespace sparrow_ipc
3535

3636
serializer(const sparrow::record_batch& rb, output_stream& stream);
3737

38-
template <std::ranges::input_range R>
38+
template <std::ranges::random_access_range R>
3939
requires std::same_as<std::ranges::range_value_t<R>, sparrow::record_batch>
4040
serializer(const R& record_batches, output_stream& stream)
4141
: m_pstream(&stream)

0 commit comments

Comments
 (0)