Usługa Angular2 Observable BehaviorSubject nie działa

Question

Próbuję utworzyć własną usługę obserwowalną, ale po otrzymaniu początkowych danych z usługi wszelkie aktualizacje usługi nie są propagowane do żadnych subskrybentów. Usługa wygląda następująco:

import { Injectable } from '@angular/core'; 
import { Observable, BehaviorSubject } from 'rxjs/Rx'; 

@Injectable() 
export class DataService { 
    keys : number[] = [4,5,1,3,2]; 
    private data :BehaviorSubject<number[]> = new BehaviorSubject(this.keys); 

    constructor() {}; 

    public setKey(i:number, val:number) :void { 
    this.keys[i]=val; 
    this.data.next(this.keys); 
    } 
    public getData() :Observable<number[]> { 
    return new Observable(fn => this.data.subscribe(fn)); 
    } 
    public getKeys() :number[] { 
    return this.keys; 
    } 
} 

składnik korzystający z usługi dostaje dane początkowe dobrze. ten komponent pobiera swoje dane w konstruktorze:

constructor(public dataService: DataService) { 
    dataService.getData().subscribe(data => { 
     console.log("Gotcha!"); 
     this.data.datasets[0].data = data) 
    }); 
}; 

co daje jeden komunikat Gotcha w logu konsoli. Ale po aktualizacji danych z setKey (2,3) gdzie indziej, oczekiwałem, że this.data.next (this.keys); wysyłanie danych do wszystkich subskrybentów, a dane będą aktualizowane odpowiednio w tym komponencie. ale żadne dane nie są wysyłane do subskrybentów.

Myślałem, że wymyśliłem obserwowalne, ale proszę nie bądź przyjazny, jeśli brakuje mi tu punktu;) wszelkie wskazówki we właściwym kierunku będą bardzo mile widziane!

Answer 1

Za każdym razem, gdy emitujesz wartość, powinieneś utworzyć nowy obiekt zamiast emitować ten sam zmutowany obiekt. To ochroni Cię przed problemami z wykrywaniem zmian. Lepiej jest zawsze przypisać nowy obiekt do this.keys, kiedy go zmienisz.

this.data.next([...this.keys]); 

Można użyć asObservable() tutaj

public getData(): Observable<number[]> { 
    return this.data.asObservable(); 
} 

Należy również sprawdzić, co Günter Zöchbauer powiedział. Czy świadczysz usługę jako singleton?

Answer 2

W pewnym momencie stanąłem wobec tego samego problemu. Prawdopodobnie przyczyną jest to, że twoja usługa nie jest pojedynczą, tzn. Że każdy subskrybent otrzymuje nową instancję. W przeciwieństwie do Angular 1, usługi A2 nie są pojedynczymi.

Jeśli chcesz mieć jedną instancję usługi współużytkowaną przez wiele usług/komponentów, umieść ją w providers swojego rodzica @Component lub @NgModule.

@NgModule({ 
    declarations: [], 
    imports: [], 
    bootstrap: [AppComponent], 
    providers: [DataService] 
}) 
export class AppModule { 
}