Remove unused Everywhere thread attribute

This commit is contained in:
Alex Dima
2016-02-18 09:35:05 +01:00
parent e27dba1da3
commit 2ba8f083f7
6 changed files with 0 additions and 28 deletions

View File

@@ -32,10 +32,6 @@ export class NullThreadService extends abstractThreadService.AbstractThreadServi
return winjs.TPromise.as(null);
}
Everywhere(obj: IThreadSynchronizableObject<any>, methodName: string, target: Function, params: any[]): any {
return target.apply(obj, params);
}
addStatusListener(listener: IThreadServiceStatusListener): void {
// Nothing to do
}

View File

@@ -233,15 +233,6 @@ export class MainThreadService extends abstractThreadService.AbstractThreadServi
});
}
Everywhere(obj: IThreadSynchronizableObject<any>, methodName: string, target: Function, params: any[]): any {
this._afterWorkers().then(() => {
this._workerPool.forEach((w) => {
this._remoteCall(w, obj, methodName, params).done(null, errors.onUnexpectedError);
});
});
return target.apply(obj, params);
}
private _remoteCall(worker: Worker.WorkerClient, obj: IThreadSynchronizableObject<any>, methodName: string, params: any[]): TPromise<any> {
let id = obj.getId();
if (!id) {

View File

@@ -29,10 +29,6 @@ export class PluginHostThreadService extends abstractThreadService.AbstractThrea
return TPromise.as(null);
}
Everywhere(obj: IThreadSynchronizableObject<any>, methodName: string, target: Function, params: any[]): TPromise<any> {
return target.apply(obj, params);
}
addStatusListener(listener: IThreadServiceStatusListener): void {
// Nothing to do
}

View File

@@ -28,7 +28,6 @@ export interface IThreadService {
OneWorker(obj: IThreadSynchronizableObject<any>, methodName: string, target: Function, param: any[], affinity: ThreadAffinity): TPromise<any>;
AllWorkers(obj: IThreadSynchronizableObject<any>, methodName: string, target: Function, param: any[]): TPromise<any>;
Everywhere(obj: IThreadSynchronizableObject<any>, methodName: string, target: Function, param: any[]): any;
createInstance<T extends IThreadSynchronizableObject<any>>(ctor: instantiation.INewConstructorSignature0<T>): T;
createInstance<A1, T extends IThreadSynchronizableObject<any>>(ctor: instantiation.INewConstructorSignature1<A1, T>, a1: A1): T;

View File

@@ -73,9 +73,3 @@ export function AllWorkersAttr(type: Function, target: Function): void {
};
}
export function EverywhereAttr(type: Function, target: Function): void {
let methodName = findMember(type.prototype, target);
type.prototype[methodName] = function(...param: any[]) {
return findThreadService(this).Everywhere(this, methodName, target, param);
};
}

View File

@@ -73,10 +73,6 @@ export class WorkerThreadService extends abstractThreadService.AbstractThreadSer
return target.apply(obj, params);
}
Everywhere(obj: IThreadSynchronizableObject<any>, methodName: string, target: Function, params: any[]): TPromise<any> {
return target.apply(obj, params);
}
addStatusListener(listener: IThreadServiceStatusListener): void {
// Nothing to do
}