|
@@ -263,6 +263,12 @@
|
|
public onTaskSuccess: (task: IAssetTask) => void;
|
|
public onTaskSuccess: (task: IAssetTask) => void;
|
|
public onTaskError: (task: IAssetTask) => void;
|
|
public onTaskError: (task: IAssetTask) => void;
|
|
|
|
|
|
|
|
+ //Observables
|
|
|
|
+
|
|
|
|
+ public onTaskSuccessObservable = new Observable<IAssetTask>();
|
|
|
|
+ public onTaskErrorObservable = new Observable<IAssetTask>();
|
|
|
|
+ public onTasksDoneObservable = new Observable<IAssetTask[]>();
|
|
|
|
+
|
|
public useDefaultLoadingScreen = true;
|
|
public useDefaultLoadingScreen = true;
|
|
|
|
|
|
constructor(scene: Scene) {
|
|
constructor(scene: Scene) {
|
|
@@ -336,11 +342,13 @@
|
|
if (this.onTaskSuccess) {
|
|
if (this.onTaskSuccess) {
|
|
this.onTaskSuccess(task);
|
|
this.onTaskSuccess(task);
|
|
}
|
|
}
|
|
|
|
+ this.onTaskSuccessObservable.notifyObservers(task);
|
|
this._decreaseWaitingTasksCount();
|
|
this._decreaseWaitingTasksCount();
|
|
}, () => {
|
|
}, () => {
|
|
if (this.onTaskError) {
|
|
if (this.onTaskError) {
|
|
this.onTaskError(task);
|
|
this.onTaskError(task);
|
|
}
|
|
}
|
|
|
|
+ this.onTaskErrorObservable.notifyObservers(task);
|
|
this._decreaseWaitingTasksCount();
|
|
this._decreaseWaitingTasksCount();
|
|
});
|
|
});
|
|
}
|
|
}
|
|
@@ -357,6 +365,7 @@
|
|
if (this.onFinish) {
|
|
if (this.onFinish) {
|
|
this.onFinish(this.tasks);
|
|
this.onFinish(this.tasks);
|
|
}
|
|
}
|
|
|
|
+ this.onTasksDoneObservable.notifyObservers(this.tasks);
|
|
return this;
|
|
return this;
|
|
}
|
|
}
|
|
|
|
|