From 753f9c9e5fb1707ffdbac4f3c790c0218343e1f2 Mon Sep 17 00:00:00 2001
From: Jonas Knobloch <jonas.knobloch@t-online.de>
Date: Tue, 21 Apr 2026 19:45:42 +0200
Subject: Fix iterator termination

* Check error after reading each shard
---
 dataset/parquet.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/dataset/parquet.go b/dataset/parquet.go
index 4b3d858..81454f8 100644
--- a/dataset/parquet.go
+++ b/dataset/parquet.go
@@ -72,16 +72,16 @@ func (p *ParquetReader) Texts() iter.Seq2[int, string] {
 
 		for _, name := range p.shards {
 			for text := range p.read(name) {
-				if p.err != nil {
-					return
-				}
-
 				if !yield(n, text) {
 					return
 				}
 
 				n++
 			}
+
+			if p.err != nil {
+				return
+			}
 		}
 	}
 }
-- 
cgit v1.3.1