Observable.subscribe() works only once (ngrx\angular2)

Question

I'm subscribing to a store property in a component constructor

constructor(private someService: SomeService){
        someService.someObservable.subscribe((data: Some)=> {
            this.some = data;
            console.log('changed');
        });
}

In the service, the constructor looks like this:

constructor(private store: Store<any>){
        this.someObservable = <Observable<{}>>store.select('some');
}

I keep changing the state of this object, but the logging only appear once. What's also weird is that I'm accessing the this.some property directly in my template (without async pipe), and it updates perfectly! It seems like the this.some property is being updated, but the next() in the subscription isn't working.

help anyone? thanks!

Answer 1

In my very similar case the problem was that one of the subscription handlers was throwing an error. When an error is encountered the observable stream stops emitting new values.