Skip to content

Commit 29feec6

Browse files
(fix) remove the fallback delay form the sender
1 parent c7b6c1b commit 29feec6

File tree

2 files changed

+6
-8
lines changed

2 files changed

+6
-8
lines changed

src/commands/recv.js

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -57,26 +57,24 @@ export async function run(outDir, opts, ctx = {}) {
5757
} catch {}
5858
});
5959

60-
const waitForSenderReady = ({ fallbackMs = 2_000 } = {}) =>
60+
const waitForSenderReady = () =>
6161
new Promise((resolve) => {
6262
if (sawSenderReadySignal) {
6363
resolve(true);
6464
return;
6565
}
66+
6667
let settled = false;
67-
let timer = null;
68-
const finish = (ready) => {
68+
const onReady = () => {
6969
if (settled) return;
7070
settled = true;
71-
clearTimeout(timer);
7271
if (notifySenderReady === onReady) {
7372
notifySenderReady = null;
7473
}
75-
resolve(ready);
74+
resolve(true);
7675
};
77-
const onReady = () => finish(true);
76+
7877
notifySenderReady = onReady;
79-
timer = setTimeout(() => finish(false), fallbackMs);
8078
});
8179

8280
let totalBytes = 0;

src/commands/send.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ export async function run(paths, opts, ctx = {}) {
120120
} catch (err) {
121121
getLogger().debug("send: failed to announce telemetry ice-connected", err);
122122
}
123-
123+
getLogger().debug("send: Zipping the contents...");
124124
if (tarPromise) {
125125
const { pack, totalSizeTar } = await tarPromise;
126126
sourceStream = pack;

0 commit comments

Comments
 (0)