X-Git-Url: https://git.proxmox.com/?a=blobdiff_plain;f=ceph%2Fsrc%2Fpybind%2Fmgr%2Fdashboard%2Ffrontend%2Fsrc%2Fapp%2Fshared%2Fservices%2Ftask-manager.service.ts;h=2ef8da4136c51a873adafba3076e2185965e5f0f;hb=1911f103e16ae0d04db10fb41db8217ef4c320d3;hp=d23b5b49fb9a542dff1c11ecaaedf91502bf6794;hpb=78f773100ed5d2ebc9d99e65a3d7e3a6f541a97e;p=ceph.git diff --git a/ceph/src/pybind/mgr/dashboard/frontend/src/app/shared/services/task-manager.service.ts b/ceph/src/pybind/mgr/dashboard/frontend/src/app/shared/services/task-manager.service.ts index d23b5b49f..2ef8da413 100644 --- a/ceph/src/pybind/mgr/dashboard/frontend/src/app/shared/services/task-manager.service.ts +++ b/ceph/src/pybind/mgr/dashboard/frontend/src/app/shared/services/task-manager.service.ts @@ -25,8 +25,8 @@ class TaskSubscription { export class TaskManagerService { subscriptions: Array = []; - constructor(summaryService: SummaryService) { - summaryService.subscribe((data: any) => { + init(summaryService: SummaryService) { + return summaryService.subscribe((data: any) => { if (!data) { return; } @@ -51,7 +51,7 @@ export class TaskManagerService { this.subscriptions.push(new TaskSubscription(name, metadata, onTaskFinished)); } - _getTask(subscription: TaskSubscription, tasks: Array): Task { + private _getTask(subscription: TaskSubscription, tasks: Array): Task { for (const task of tasks) { if (task.name === subscription.name && _.isEqual(task.metadata, subscription.metadata)) { return task;