Как вернуть значение из функции, в которой есть подписная подписка?

Question

Я не знаю, как извлечь значение из Observable, которое будет возвращено функцией, в которой присутствует Observable. Мне нужно только то, что нужно вернуть, ничего больше.

Текущая версия, которая работает

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

мне это нужно работать, работать, чтобы вернуть значение, а затем:

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

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

Answer 1

Это не совсем правильная идея использования Observable

В компоненте вы должны объявить член класса, который будет содержать объект (то, что вы собираетесь использовать в компоненте)

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

Тогда Service будет возвращать вам Observable:

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

Component ш ульд подготовить себя, чтобы иметь возможность извлечь значение из него:

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

Вы должны присвоить значение из Observable переменной:

И ваш шаблон будет потреблять переменной name:

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

Другой способ использования Observable через async трубы http://briantroncone.com/?p=623

Примечание: Если это не то, что вы просите, пожалуйста, обновите ваш вопрос более подробно

Answer 2

Я понимаю, что этот вопрос был довольно давно, и вы, безусловно, есть правильное решение сейчас, но для тех, кто ищет этот Я бы предложил решить его с обещанием сохранить асинхронный шаблон. Более подробная версия будет создавать новый посыл:

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); 
     }) 
    } 
} 

На приемном конце вы будете затем «ждать» за обещание решить что-то вроде этого:

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

стройнее решение будет использовать .toPromise RxJS»() вместо:

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

принимающая сторона остается такой же, как и выше, конечно. Надеюсь, это поможет!

Answer 3

Наблюдаемые значения могут быть получены из любых мест. Первоначальная последовательность начинается с , толкает на специальный observer, который способен излучать в другом месте. Это достигается с помощью Тематический класс от Reactive Extensions (RxJS).

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

значение магазина на наблюдателя.

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

Для получения значения из других, подписываться на наблюдателя так:

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

Субъекты как Наблюдаемые и наблюдатели. Существуют и другие Subject types, такие как BehaviourSubject и ReplaySubject для других сценариев использования.

Не забудьте импортировать RxJS.

var Rx = require('rxjs'); 

Answer 4

Если вы хотите предварительно подписаться на ту же наблюдаемую, который будет возвращен, просто использовать

.Не():

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

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