lobo/srf
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

handle multiple recorditerator.next() without processing fields

Browse source
This commit is contained in:
Emil Lerch 2026-03-09 09:45:05 -07:00
parent 3f7953be74
commit bb4a5e0bf3
Signed by: lobo
GPG key ID: A7B62D657EF764F8
1 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/srf.zig
View file

@ -589,6 +589,7 @@ pub const RecordIterator = struct {
field_delimiter: u8 = ',', field_delimiter: u8 = ',',
end_of_record_reached: bool = false, end_of_record_reached: bool = false,
field_iterator: ?FieldIterator = null,
/// Takes the next line, trimming leading whitespace and ignoring comments /// Takes the next line, trimming leading whitespace and ignoring comments
/// Directives (comments starting with #!) are preserved /// Directives (comments starting with #!) are preserved
@ -614,6 +615,11 @@ pub const RecordIterator = struct {
// TODO: we need to capture the fieldIterator here and make sure it's run // TODO: we need to capture the fieldIterator here and make sure it's run
// to the ground to keep our state intact // to the ground to keep our state intact
const state = self.state; const state = self.state;
if (state.field_iterator) |f| {
// We need to finish the fields on the previous record
while (try f.next()) |_| {}
state.field_iterator = null;
}
if (state.current_line == null) { if (state.current_line == null) {
if (state.options.diagnostics) |d| if (state.options.diagnostics) |d|
if (d.errors.items.len > 0) return ParseError.ParseFailed; if (d.errors.items.len > 0) return ParseError.ParseFailed;
@ -653,7 +659,8 @@ pub const RecordIterator = struct {
} }
} }
state.end_of_record_reached = false; state.end_of_record_reached = false;
return .{ .ri = self }; state.field_iterator = .{ .ri = self };
return state.field_iterator.?;
} }
pub const FieldIterator = struct { pub const FieldIterator = struct {