fix: Обновить логику обработки потоков в функции streamPaginatedText, чтобы предотвратить преждевременное завершение потока и обеспечить корректный подсчет общего количества элементов
Publish Fast Tabler Docker image / build-and-push-fast (push) Successful in 1m36s
Publish Fast Tabler Docker image / build-and-push-fast (push) Successful in 1m36s
This commit is contained in:
+1
-5
@@ -452,11 +452,7 @@ async function streamPaginatedText({ key, mapLine, q, offset = 0, limit = 0 }) {
|
|||||||
} else {
|
} else {
|
||||||
items.push(mapLine(line));
|
items.push(mapLine(line));
|
||||||
}
|
}
|
||||||
// Раннее завершение при достижении offset+limit
|
// Не прерываем поток раньше конца, чтобы корректно посчитать total
|
||||||
if (limit > 0 && sent >= limit) {
|
|
||||||
try { stream.destroy(); } catch {}
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
stream.on('end', () => {
|
stream.on('end', () => {
|
||||||
|
|||||||
Reference in New Issue
Block a user