从订阅 angular2 传递结果

Question

我创建了一个返回对象数组的服务。如何将服务的结果传递给另一个函数进行进一步处理。

我的订阅

showFeed(){
  this.service.getCompanies().subscribe((companies) => {
     //console.log(companies);
     console.log(companies.rss.channel.item);
     this.items = companies.rss.channel.item;
  });
}

//How do I pass the result of showFeed() to addItem()
additem(){
    this.hostnamesMap={} // hostname as key, and an array of items as value
    this.items.map((item) => {
        var wordCount = item.link.split("/");
        var result = wordCount[0] + "//" + wordCount[2];
        if(!this.hostnamesMap[result]) { // create an entry of not existing
            this.hostnamesMap[result] = [item];
        } else { // add item to already existing entry
            this.hostnamesMap[result].push(item);
        }
    }); 
}

Answer 1

喜欢这个

addItem(){
  var todosss = this._todos.subscribe(val => console.log(val)); 
}

注意todosss是subscription，您可以致电todosss.dispose()取消订阅

或者不使用 Rx。

showFeed() {
  this.service.getCompanies().subscribe((companies) => {
  // ...
  this.items = companies.rss.channel.item;
  this.additem(); // call additem() here
});

additem(){
  this.hostnamesMap={} // hostname as key, and an array of items as value
  this.items.map((item) => {
   var wordCount = item.link.split("/");
   var result = wordCount[0] + "//" + wordCount[2];
   if(!this.hostnamesMap[result]){ // create an entry of not existing
     this.hostnamesMap[result] = [item];
   }else{ // add item to already existing entry
     this.hostnamesMap[result].push(item);
   }
  }); 
}