Angular2 Observable - 如何从Observable的构造函数的外部调用下一个

Question

我正在构建一个暴露Observable的服务。在这个服务中，我接收外部函数调用，它应该触发Observable上的下一个调用，以便各种消费者获得订阅事件。在Observer构造函数中，我可以调用next，并且一切都很好，但是如何在构造函数的外部访问此外部触发器以便触发下一个调用？

private myObservable$: Observable<any>; 

在服务初始化我做

this.myObservable$ = new Observable(observer => { 
    observer.next("initial message"); 
} 

然后在相同服务的其他方法，我希望能够像

this.myObservable$.observer.next("next message"); 

以上显然是行不通的执行什么，但我怎样才能实现这个目标？

我假设我失去了一些东西基本因为必须有发射可观察到的初始构造之外更多的消息

Answer 1

你应该创建为

this.myObservable$ = new Subject(); 

然后一个Subject方式你可以在任何时候拨打：

this.myObservable$.next(...); 

或者使用订阅：

this.myObservable$.subscribe(...) 

Answer 2

两种方式：

1. 让myObservable $市民：

   public myObservable$: Observable; 
   

2. 封装观察到受试者中的数据流，并提供了一个帮手调用next：

   export class TestService { 
       public myObservable$: Observable; 
       private _myObservableSubject: Subject; 
   
       constructor() { 
       this._myObservableSubject = new Subject(); 
       this.myObservable$ = this._myObservableSubject.asObservable(); 
       } 
   
       public NextMessage(message?: string): void { 
       this._myObservableSubject.next(message); 
       } 
   }