Update reads.cpp

vgl-hub · Dec 26, 2024 · f30d128 · f30d128
1 parent c059edc
commit f30d128
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/reads.cpp b/src/reads.cpp
@@ -739,13 +739,15 @@ void InReads::writeToStream() {
 
     std::vector<std::pair<std::vector<InRead*>,uint32_t>> readBatchesCpy;
 
-    while (streamOutput || batchCounter-1 < readBatches.size()) {
+    while (streamOutput || batchCounter < readBatches.size()) {
 
         {
             std::unique_lock<std::mutex> lck(mtx);
             writerMutexCondition.wait(lck, [this, batchCounter] {
                 return readBatches.size()>batchCounter;
             });
+            if (!streamOutput || batchCounter == readBatches.size())
+                return;
             readBatchesCpy = {readBatches.begin() + batchCounter, readBatches.end()};
         }