Skip to content

Commit 1f4e1f2

Browse files
committed
Make queue private and one-line initiatialization for it
1 parent 3a18003 commit 1f4e1f2

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

extensions/ql-vscode/src/remote-queries/variant-analysis-manager.ts

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ export class VariantAnalysisManager extends DisposableObject implements VariantA
3333
private readonly variantAnalyses = new Map<number, VariantAnalysis>();
3434
private readonly views = new Map<number, VariantAnalysisView>();
3535
private static readonly maxConcurrentDownloads = 3;
36-
public queue: PQueue;
36+
private readonly queue = new PQueue({ concurrency: VariantAnalysisManager.maxConcurrentDownloads });
3737

3838
constructor(
3939
private readonly ctx: ExtensionContext,
@@ -47,8 +47,6 @@ export class VariantAnalysisManager extends DisposableObject implements VariantA
4747

4848
this.variantAnalysisResultsManager = this.push(new VariantAnalysisResultsManager(cliServer, storagePath, logger));
4949
this.variantAnalysisResultsManager.onResultLoaded(this.onRepoResultLoaded.bind(this));
50-
51-
this.queue = new PQueue({ concurrency: VariantAnalysisManager.maxConcurrentDownloads });
5250
}
5351

5452
public async showView(variantAnalysisId: number): Promise<void> {
@@ -176,6 +174,10 @@ export class VariantAnalysisManager extends DisposableObject implements VariantA
176174
});
177175
}
178176

177+
public downloadsQueueSize(): number {
178+
return this.queue.pending;
179+
}
180+
179181
public async promptOpenVariantAnalysis() {
180182
const credentials = await Credentials.initialize(this.ctx);
181183
if (!credentials) { throw Error('Error authenticating with GitHub'); }

extensions/ql-vscode/src/vscode-tests/cli-integration/remote-queries/variant-analysis-manager.test.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -157,7 +157,7 @@ describe('Variant Analysis Manager', async function() {
157157
await variantAnalysisManager.enqueueDownload(scannedRepos[1], variantAnalysis, cancellationTokenSource.token);
158158
await variantAnalysisManager.enqueueDownload(scannedRepos[2], variantAnalysis, cancellationTokenSource.token);
159159

160-
expect(variantAnalysisManager.queue.pending).to.equal(0);
160+
expect(variantAnalysisManager.downloadsQueueSize()).to.equal(0);
161161
expect(getResultsSpy).to.have.been.calledThrice;
162162
});
163163
});

0 commit comments

Comments
 (0)