Wie man Wert von der Funktion zurückgibt, die Observable-Subskription innen hat?

Question

Ich weiß nicht, wie man Wert von Observable extrahiert, um von Funktion zurückgegeben werden, in der Observable vorhanden ist. Ich brauche nur einen Wert, um zurückgegeben zu werden, sonst nichts.

Aktuelle Version, die

function getValueFromObservable() { 
    this.store.subscribe(
     (data:any) => { 
      console.log(data) 
     } 
    ) 
} 
getValueFromObservable() 

Ich brauche dies funktioniert, funktionieren zurückzukehren Wert arbeitet, und dann:

function getValueFromObservable() { 
    this.store.subscribe(
     (data:any) => { 
      return data 
     } 
    ) 
} 
console.log(getValueFromObservable()) 

Was mache ich hier falsch?

Answer 1

Dies ist nicht genau richtige Vorstellung von Observable

In der Komponente Sie haben Klassenmitglied zu erklären, die ein Objekt halten werden (etwas, das Sie in Ihrer Komponente verwenden werden)

export class MyComponent { 
    name: string = ""; 
} 

Dann

getValueFromObservable():Observable<string> { 
    return this.store.map(res => res.json()); 
} 

Component sh: ein Service erhalten Sie eine Observable zurückkehren

OnInit(){ 
    this.yourServiceName.getValueFromObservable() 
    .subscribe(res => this.name = res.name) 
} 

Sie haben einen Wert von einem Observable zu einer Variablen zuzuweisen:

Und Ihre Vorlage wird variabel verbrauchen name:

<div> {{ name }} </div> 

Wert abrufen zu können, von ihm Ould selbst vorbereiten

Ein anderer Weg der Verwendung von Observable ist durch async Rohr http://briantroncone.com/?p=623

Hinweis: Wenn es nicht das, was Sie fragen, aktualisieren Sie bitte Ihre Frage mit mehr Details

Answer 2

Ich weiß, dass diese Frage ganz vor einer Weile war und Sie sicherlich mittlerweile eine richtige Lösung, aber für alle, für diese Suche Ich würde vorschlagen, es mit einem Versprechen zu lösen, um das asynchrone Muster zu behalten. Eine ausführlichere Version würde ein neues Versprechen erschaffen:

getValueFromObservable() 
    .then((data:any)=>{ 
    //... continue with anything depending on "data" after the Promise has resolved 
}) 

Eine schlankere Lösung:

function getValueFromObservable() { 
    return new Promise(resolve=>{ 
     this.store 
     .take(1) //useful if you need the data once and don't want to manually cancel the subscription again 
     .subscribe(
      (data:any) => { 
       console.log(data; 
       resolve(data); 
     }) 
    } 
} 

am empfangenden Ende haben Sie dann „wait“ für das Versprechen mit so etwas wie dieses Problem zu beheben

function getValueFromObservable() { 
    return this.store 
     .take(1) 
     .toPromise() 
} 

die Empfangsseite bleibt die gleiche wie oben natürlich: statt RxJS‘.toPromise() unter Verwendung wäre. Ich hoffe, das hilft!

Answer 3

Beobachtbare Werte können von beliebigen Standorten abgerufen werden. Die Quellsequenz ist zuerst geschoben auf einen speziellen Beobachter, der an anderer Stelle emittieren kann. Dies wird mit der Subject-Klasse von Reactive Extensions (RxJS) erreicht.

var subject = new Rx.AsyncSubject(); // store-last-value method 

Wert speichern auf den Beobachter.

subject.subscribe({ 
    next: (response) => { 
     //do stuff. The property name "response" references the value 
    } 
}); 

Themen sind beide Observablen und Beobachter:

subject.next(value); // store value 
subject.complete(); // publish only when sequence is completed 

Um den Wert von anderswo, abonnieren Sie den Beobachter wie so abzurufen. Es gibt andere Subject types wie BehaviourSubject und ReplaySubject für andere Verwendungsszenarien.

Vergessen Sie nicht, RxJS zu importieren.

var Rx = require('rxjs'); 

Answer 4

Wenn Sie möchten, auf die gleiche beobachtbare vorab abonnieren, der zurückgegeben wird, verwenden Sie einfach

.do():

function getValueFromObservable() { 
    return this.store.do(
     (data:any) => { 
      console.log("Line 1: " +data); 
     } 
    ); 
} 

getValueFromObservable().subscribe(
     (data:any) => { 
      console.log("Line 2: " +data) 
     } 
    );