Я использую наблюдаемые для вызова моей компонентной функции из моего сервиса. Вот мой сервисный код:
private trades = new Subject<any>();
// Observable string streams
tradeMethodCalled$ = this.trades.asObservable();
constructor(private http:Http) { }
getAllTrades() {
let headers = new Headers();
console.log('here');
headers.append('Content-Type', 'application/json');
this.http.get('http://localhost:50005/api/trading/trades',{
headers: headers
}).pipe(map((res : any)=>res.json()))
.subscribe(
(res) => {
this.payload = res[0].state.data;
console.log('success');
console.log(this.payload);
this.trades.next();
}
);
}
Вот мой код компонента
export class LandingPageComponent implements OnInit {
trades;
party;
constructor(public service: CordaContentService,private routes : ActivatedRoute) {
this.service.tradeMethodCalled$.subscribe(
() => {
console.log(this.trades + "here");
routes.params.subscribe(val => {
this.trades=this.service.gettrades();
console.log(this.trades);
})
});
}
что я делаю неправильно?Моя компонентная функция не срабатывает, я использую угловой 6.Пожалуйста, предоставьте ясное решение