alteropen/streamyfin
1
0
Fork 0
mirror of https://github.com/streamyfin/streamyfin.git synced 2026-03-27 11:41:53 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

# Fix queue being downloaded all at once

Browse Source
This commit is contained in:
herrrta
2024-12-06 19:51:50 -05:00
parent 63cf7eb622
commit 006e457d23
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
utils/atoms/queue.ts
View File

@@ -27,14 +27,17 @@ export const queueActions = {
setProcessing: (processing: boolean) => void
) => {
const [job, ...rest] = queue;
setQueue(rest);
console.info("Processing job", job);
setProcessing(true);
// Excute the function assiociated with the job.
await job.execute();
// Allow job to execute so that it gets added as a processes first BEFORE updating new queue
try {
await job.execute();
} finally {
setQueue(rest);
}
console.info("Job done", job);
@@ -56,7 +59,7 @@ export const useJobProcessor = () => {
const [settings] = useSettings();
useEffect(() => {
if (queue.length > 0 && settings && processes.length < settings?.remuxConcurrentLimit) {
if (!running && queue.length > 0 && settings && processes.length < settings?.remuxConcurrentLimit) {
console.info("Processing queue", queue);
queueActions.processJob(queue, setQueue, setRunning);
}