We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e994948 commit a4413f1Copy full SHA for a4413f1
1 file changed
src/join.rs
@@ -135,8 +135,8 @@ pub fn join_fastq(
135
let mut fq_iter1 = fq_reader1.records();
136
let mut fq_iter2 = fq_reader2.records();
137
loop {
138
- let pe_vec: Vec<_> = fq_iter1.by_ref().flatten().zip(fq_iter2.by_ref().flatten()).take(chunk).collect();
139
- //fq_iter1.take(chunk).flatten().zip(fq_iter2.take(chunk).flatten()).collect();
+ let pe_vec: Vec<_> = fq_iter1.by_ref().take(chunk).flatten().zip(fq_iter2.by_ref().take(chunk).flatten()).collect();
+ // fq_iter1.by_ref().flatten().zip(fq_iter2.by_ref().flatten()).take(chunk).collect(); slower, deprecated
140
if pe_vec.is_empty() {
141
break;
142
}
0 commit comments