Угловое 2: Как вызвать функцию после того, как получить ответ от подписки http.post

Question

Мне нужно вызвать метод после того, как получить данные из запроса HTTP POST

услуги: request.service.TS

get_categories(number){ 
this.http.post(url, body, {headers: headers, withCredentials:true}) 
    .subscribe( 
     response => { 
     this.total = response.json(); 

     }, error => { 
    } 
); 

} 

компонент: categories.TS

search_categories() { 

this.get_categories(1); 
//I need to call a Method here after get the data from response.json() !! e.g.: send_catagories(); 
} 

работает только если я изменяю:

услуги: request.service.TS

get_categories(number){ 
this.http.post(url, body, {headers: headers, withCredentials:true}) 
    .subscribe( 
     response => { 
     this.total = response.json(); 
     this.send_catagories(); //here works fine 

     }, error => { 
    } 
); 

} 

Но мне нужно вызвать метод send_catagories() внутри компонента после вызова this.get_categories(1); как этот

компонента: categories.TS

search_categories() { 

this.get_categories(1); 
this.send_catagories(response); 
} 

Что я делаю неправильно?

Answer 1

Обновление ваш метод get_categories() до r eturn общее (завернутые в наблюдаемой):

// Note that .subscribe() is gone and I've added a return. 
get_categories(number) { 
    return this.http.post(url, body, {headers: headers, withCredentials:true}) 
    .map(response => response.json()); 
} 

В search_categories(), вы можете подписаться на наблюдаемый возвращаемый get_categories() (или вы могли бы сохранить преобразуя его, приковав больше RxJS операторов):

// send_categories() is now called after get_categories(). 
search_categories() { 
    this.get_categories(1) 
    // The .subscribe() method accepts 3 callbacks 
    .subscribe(
     // The 1st callback handles the data emitted by the observable. 
     // In your case, it's the JSON data extracted from the response. 
     // That's where you'll find your total property. 
     (jsonData) => { 
     this.send_categories(jsonData.total); 
     }, 
     // The 2nd callback handles errors. 
     (err) => console.error(err), 
     // The 3rd callback handles the "complete" event. 
    () => console.log("observable complete") 
    ); 
} 

Обратите внимание, что вы подписывайтесь только по номеру, в конце.

Как я уже говорил в комментариях .subscribe() метод любой наблюдаемой принимает 3 обратных вызовов, как это:

obs.subscribe(
    nextCallback, 
    errorCallback, 
    completeCallback 
); 

Они должны быть приняты в этом порядке. Вам не нужно проходить все три. Много раз nextCallback реализуется только:

obs.subscribe(nextCallback); 

Answer 2

Вы можете добавить функцию обратного вызова в свой список параметров get_category (...).

Ex:

get_categories(number, callback){ 
this.http.post(url, body, {headers: headers, withCredentials:true}) 
    .subscribe( 
     response => { 
     this.total = response.json(); 
     callback(); 

     }, error => { 
    } 
); 

} 

И тогда вы можете просто позвонить get_category (...), как это:

this.get_category(1, name_of_function); 

Answer 3

get_categories(number){ 
return this.http.post(url, body, {headers: headers, withCredentials:true}) 
     .map(t=> { 
      this.total = t.json(); 
      return total; 
     }).share(); 
);  
} 

затем

this.get_category(1).subscribe(t=> { 
     this.callfunc(); 
}); 

Answer 4

Вы можете закодировать как лямбда-выражения в качестве третьего параметра (по полной) методу подписки. Здесь я повторно устанавливаю переменную departmentModel в значения по умолчанию.

saveData(data:DepartmentModel){ 
    return this.ds.sendDepartmentOnSubmit(data). 
    subscribe(response=>this.status=response, 
    ()=>{}, 
    ()=>this.departmentModel={DepartmentId:0}); 
}