Microsoft/vscode
1
0
Fork 0
mirror of https://github.com/microsoft/vscode.git synced 2026-04-28 04:23:32 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge commit 'refs/pull/59988/head' of github.com:Microsoft/vscode into pr/59988

Browse Source
This commit is contained in:
Joao Moreno
2019-01-04 16:30:25 +01:00
parent a1279d336b 7761add538
commit 32d22dbace
3 changed files with 24 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
extensions/git/src/autofetch.ts
View File

@@ -17,16 +17,19 @@ function isRemoteOperation(operation: Operation): boolean {
export class AutoFetcher {
private static readonly Period = 3 * 60 * 1000 /* three minutes */;
private static DidInformUser = 'autofetch.didInformUser';
private _onDidChange = new EventEmitter<boolean>();
private _onDidChange = new EventEmitter<boolean | number>();
private onDidChange = this._onDidChange.event;
private _enabled: boolean = false;
get enabled(): boolean { return this._enabled; }
set enabled(enabled: boolean) { this._enabled = enabled; this._onDidChange.fire(enabled); }
private _timeout: number = workspace.getConfiguration('git').get<number>('autofetchPeriod', 3) * 60 * 1000;
private get timeout(): number { return this._timeout; }
private set timeout(minutes: number) { this._timeout = minutes * 60 * 1000; this._onDidChange.fire(minutes); }
private disposables: Disposable[] = [];
constructor(private repository: Repository, private globalState: Memento) {
@@ -70,19 +73,19 @@ export class AutoFetcher {
private onConfiguration(): void {
const gitConfig = workspace.getConfiguration('git');
const minutes = gitConfig.get<number>('autofetchPeriod', 3);
const autofetch = gitConfig.get<boolean>('autofetch');
if (gitConfig.get<boolean>('autofetch') === false) {
this.disable();
} else {
this.enable();
if (this.timeout !== minutes) {
this.timeout = minutes;
}
if (this.enabled !== autofetch) {
autofetch ? this.enable() : this.disable();
}
}
enable(): void {
if (this.enabled) {
return;
}
this.enabled = true;
this.run();
}
@@ -111,9 +114,9 @@ export class AutoFetcher {
return;
}
const timeout = new Promise(c => setTimeout(c, AutoFetcher.Period));
const whenDisabled = eventToPromise(filterEvent(this.onDidChange, enabled => !enabled));
await Promise.race([timeout, whenDisabled]);
const timeout = new Promise(c => setTimeout(c, this.timeout));
const onChanged = eventToPromise(filterEvent(this.onDidChange, () => true));
await Promise.race([timeout, onChanged]);
}
}