Skip to content

Commit 7d592ac

Browse files
committed
style(sftp): wrap pipelined transfer statements
1 parent 8377df8 commit 7d592ac

2 files changed

Lines changed: 8 additions & 2 deletions

File tree

‎ui/koko/stores/fileTransfer.ts‎

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -457,7 +457,11 @@ export const useFileTransferStore = defineStore("file-transfer", () => {
457457
}
458458
while (inFlightWrites.length) await ackWrite();
459459
} finally {
460-
if (prefetch) await prefetch.then(() => undefined, () => undefined);
460+
if (prefetch)
461+
await prefetch.then(
462+
() => undefined,
463+
() => undefined
464+
);
461465
await Promise.allSettled(inFlightWrites.map((item) => item.promise));
462466
}
463467

‎ui/koko/tests/sftp/fileTransferStore.test.ts‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -416,7 +416,9 @@ describe("file transfer store recovery actions", () => {
416416
expect(store.tasks.find((item) => item.id === queuedTask!.id)).toMatchObject({
417417
status: "paused"
418418
});
419-
expect(store.tasks.find((item) => item.id === queuedTask!.id)?.confirmedBytes).toBeGreaterThanOrEqual(chunkSize);
419+
expect(store.tasks.find((item) => item.id === queuedTask!.id)?.confirmedBytes).toBeGreaterThanOrEqual(
420+
chunkSize
421+
);
420422
});
421423
expect(destination.writeChunk).toHaveBeenCalledTimes(2);
422424
} finally {

0 commit comments

Comments
 (0)