使い方だけメモ。 @Injectable() export class Service { dataSource = new Subject<any>; dataStreams = this.dataSource.asObservable(); getData { this.http.get(url) .subscribe((data: any) => { // データソースのnextに値を入れる度に // ストリームのsub</any>…