Skip to content

Commit 4a53d16

Browse files
committed
change rangeProvider signal to done getter
1 parent 3daa89d commit 4a53d16

File tree

2 files changed

+5
-16
lines changed

2 files changed

+5
-16
lines changed

src/get/manager/DownloadManger.ts

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -49,10 +49,8 @@ export class DownloadManger {
4949
}
5050

5151
async assignWorkToWorker (worker: DownloadWorker, workerIndex: number): Promise<void> {
52-
const doneSignal = this.rangeProvider.doneSignal
53-
5452
while (true) {
55-
if (doneSignal.aborted) {
53+
if (this.rangeProvider.done) {
5654
return
5755
}
5856

src/get/range/rangeProvider.ts

Lines changed: 4 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,6 @@ export class RangeProvider {
1010
private readonly segmentStrategy = defaultSegmentStrategy
1111
private readonly selectRangeStrategy = defaultSelectRangeStrategy
1212

13-
private readonly doneController = new AbortController()
14-
1513
constructor (
1614
contentLength: number,
1715
segmentStrategy?: (contentLength: number) => Range[],
@@ -47,9 +45,6 @@ export class RangeProvider {
4745
controller.abort()
4846

4947
this.downloaderCounter.delete(rangeIndex)
50-
if (this.downloaderCounter.size === 0) {
51-
this.rangesDone()
52-
}
5348
}
5449

5550
getRange (): {
@@ -80,15 +75,11 @@ export class RangeProvider {
8075
return controller
8176
}
8277

83-
private rangesDone (): void {
84-
this.doneController.abort()
85-
}
86-
87-
get doneSignal (): AbortSignal {
88-
return this.doneController.signal
89-
}
90-
9178
get maxRangeIndex (): RangeIndex {
9279
return this.ranges.length - 1
9380
}
81+
82+
get done (): boolean {
83+
return this.downloaderCounter.size === 0
84+
}
9485
}

0 commit comments

Comments
 (0)