fix qvalue qrep

PeerDB-io · May 21, 2024 · 72aeba8 · 72aeba8
1 parent 83e505c
commit 72aeba8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/model/qrecord_copy_from_source.go b/flow/model/qrecord_copy_from_source.go
@@ -42,7 +42,7 @@ func NewQRecordCopyFromSource(
 func (src *QRecordCopyFromSource) Next() bool {
 	rec, ok := <-src.stream.Records
 	src.currentRecord = rec
-	return ok && src.Err() != nil
+	return ok || src.Err() != nil
 }
 
 func (src *QRecordCopyFromSource) Values() ([]interface{}, error) {