diff options
author | vempo <vitaliy.emporopulo@amdocs.com> | 2018-07-24 17:34:04 +0300 |
---|---|---|
committer | vempo <vitaliy.emporopulo@amdocs.com> | 2018-07-25 11:39:10 +0300 |
commit | a52d50e788792a63e97a9176ab319d53db7a2853 (patch) | |
tree | b1c2222cacf4b8192aea16d1e0315b1f005c5347 /deprecated-workflow-designer/sdc-workflow-designer-ui/src/app/services/broadcast.service.ts | |
parent | 3c2665debb400aef7f0ed9e235698d2ff9f859db (diff) |
Replaced old implementation at root
Old project files and directories has been moved
under 'deprecated-workflow-designer'. The old project
is not built by the CI anymore, but can be still built manually.
New modules/directories have been moved up and integrated with
the CI system.
Change-Id: I1528c792bcbcce9e50bfc294a1328a20e72c91cf
Issue-ID: SDC-1559
Signed-off-by: vempo <vitaliy.emporopulo@amdocs.com>
Diffstat (limited to 'deprecated-workflow-designer/sdc-workflow-designer-ui/src/app/services/broadcast.service.ts')
-rw-r--r-- | deprecated-workflow-designer/sdc-workflow-designer-ui/src/app/services/broadcast.service.ts | 75 |
1 files changed, 75 insertions, 0 deletions
diff --git a/deprecated-workflow-designer/sdc-workflow-designer-ui/src/app/services/broadcast.service.ts b/deprecated-workflow-designer/sdc-workflow-designer-ui/src/app/services/broadcast.service.ts new file mode 100644 index 00000000..410ae9b0 --- /dev/null +++ b/deprecated-workflow-designer/sdc-workflow-designer-ui/src/app/services/broadcast.service.ts @@ -0,0 +1,75 @@ +/** + * Copyright (c) 2017 ZTE Corporation. + * All rights reserved. This program and the accompanying materials + * are made available under the terms of the Eclipse Public License v1.0 + * and the Apache License 2.0 which both accompany this distribution, + * and are available at http://www.eclipse.org/legal/epl-v10.html + * and http://www.apache.org/licenses/LICENSE-2.0 + * + * Contributors: + * ZTE - initial API and implementation and/or initial documentation + */ +import { Injectable } from '@angular/core'; +import { Subject } from 'rxjs/Subject'; + +import { PlanModel } from '../model/plan-model'; +import { RestConfig } from '../model/rest-config'; +import { Swagger } from '../model/swagger'; +import { SequenceFlow } from '../model/workflow/sequence-flow'; +import { WorkflowNode } from '../model/workflow/workflow-node'; +import { WorkflowElement } from '../model/workflow/workflow-element'; + +/** + * BroadcastService + * All of the observable subject should be registered to this service. + * It provider a broadcast method to broadcast data. the broadcast method would catch error while broadcasting. + */ +@Injectable() +export class BroadcastService { + public openRight = new Subject<boolean>(); + public openRight$ = this.openRight.asObservable(); + + public saveRight = new Subject<boolean>(); + public saveRight$ = this.saveRight.asObservable(); + + public initModel = new Subject<PlanModel>(); + public initModel$ = this.initModel.asObservable(); + + public showProperty = new Subject<WorkflowElement>(); + public showProperty$ = this.showProperty.asObservable(); + + public planModel = new Subject<PlanModel>(); + public planModel$ = this.planModel.asObservable(); + + public updateModelToscaConfig = new Subject<any[]>(); + public updateModelToscaConfig$ = this.updateModelToscaConfig.asObservable(); + + public updateModelRestConfig = new Subject<RestConfig[]>(); + public updateModelRestConfig$ = this.updateModelRestConfig.asObservable(); + + public updateNodeTypeConfig = new Subject<any[]>(); + public updateNodeTypeConfig$ = this.updateNodeTypeConfig.asObservable(); + + public saveEvent = new Subject<PlanModel>(); + public saveEvent$ = this.saveEvent.asObservable(); + + public selectedElement = new Subject<WorkflowElement[]>(); + public selectedElement$ = this.selectedElement.asObservable(); + + public swagger = new Subject<any>(); + public swagger$ = this.swagger.asObservable(); + + /** + * broadcast datas + * this method will catch the exceptions for the broadcast + * @param subject will broadcast data + * @param data will be broadcasted + */ + public broadcast(subject: Subject<any>, data: any) { + try { + subject.next(data); + } catch (err) { + console.error(err); + } + } +} |