Angular 2 - Liefern Daten direkt von einem Observable

Question

Ich habe meinen Kopf gegen diesen Versuch geschlagen, es herauszufinden, und keine Menge von Dokumentation, die ich lesen konnte, hat mir eine Antwort auf meine Frage gegeben.

Ich habe einen Dienst, der direkt zu einer API spricht und ein beobachtbares Ereignis zurücksendet, das ich unter normalen Umständen abonnieren und tun würde, was ich mit den Daten will, jedoch in einem sekundären Dienst, der die Anfragen vom erholsamen Dienst verwendet Ich muss Werte aus der Anfrage zurückgeben können.

getSomething() { 
    return this._restService.addRequest('object', 'method').run() 
     .subscribe(
      res => { 
       res; 
      }, 
      err => { 
       console.error(err); 
      } 
     ); 
} 

returnSomething() { 
    return this.getSomething(); 
} 

Im schnellen Beispiel oben, ich möchte wissen, ob es einen Weg gibt, ich res von getSomething() innerhalb returnSomething() zurückkehren kann. Wenn es auf diese Weise nicht möglich ist, was ist die Alternative? Ich werde hinzufügen, dass der _restService ziemlich stark darauf angewiesen ist und ich nicht wirklich damit anfangen will.

Answer 1

Da HTTP-Aufrufe und ähnliche async sind, erhalten Sie Observable anstelle eines synchronen Werts zurückgegeben. Sie müssen es abonnieren und im Callback erhalten Sie die Daten. Es gibt keinen Weg dahin.

Eine Möglichkeit wäre, Ihre Logik zu versetzen, in dem subscribe Anruf

getSomething() { 
    return this._restService.addRequest('object', 'method').run() 
     .subscribe(
      res => { 
       // do something here 
       res; 
      }, 
      err => { 
       console.error(err); 
      } 
     ); 
} 

Aber die Art, wie ich es gern tun, ist einen Rückruf an, von außerhalb der Logik zu injizieren (vielleicht eine Komponente, vielleicht ein anderer Dienst):

getSomething(callback: (data) => void) { 
    return this._restService.addRequest('object', 'method').run() 
     .subscribe(
      res => { 
       callback(res); 
      }, 
      err => { 
       console.error(err); 
      } 
     ); 
} 

und in Ihrer Komponente oder wo auch immer:

this._yourService.getSomething((data) => { 
    // do something here 
    console.log(data); 
}); 

Answer 2

Ich habe das nicht selbst verwenden, aber ich glaube, es sollte in der Theorie funktionieren (:

// service.ts 
getSomething() { 
    let subject: Subject = new Subject(); 
    this._restService.addRequest('object', 'method').run() 
    .subscribe(subject); 
    return subject; 
} 

// this can be removed (; 
returnSomething() { 
    return this.getSomething(); 
} 

// component.ts 
ngOnInit() { 
    this.service.returnSomething() 
    .subscribe(res => console.log(res), err => console.log(err)); 
} 

prüft subject docs für weitere Informationen. Sie können verschiedene Arten von Subjekt, zum Beispiel BehaviorSubjectvalue Eigenschaft haben können Sie auf ...

ngOnInit() { 
    // if you use BehaviorSubject 
    this.service.returnSomething().value 
} 

Hier ist die working plunker ...