【angular5项目积累总结】消息订阅服务

import { Injectable } from ‘@angular/core‘;
import { Subject } from ‘rxjs/Subject‘;
@Injectable()
export class CommonService {
    private notify = new Subject<any>();
    /**
     * Observable string streams
     */
    notifyObservable$ = this.notify.asObservable();

    constructor() { }

    public notifyOther(data: any) {
        if (data) {
            this.notify.next(data);
        }
    }
}

  constructor(
        private router: Router,
        private actRouter: ActivatedRoute,
        private appStoreService: AppStoreService,
        private comService: CommonService) {
         this.subscribeUpdate(comService);
    }

 subscribeUpdate(comService: CommonService) {
        this.comService.notifyObservable$.subscribe(data => {
            if (data == ‘refreshWebApp‘) {
                this.loadWebApp();
            }
        }, error => {
            console.log(`subscribe error:${error}`)
        })
    }