如何从内部有可观察订阅的功能返回价值？

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

如果您想预订阅将返回的同一个可观察对象，只需使用

.do（）：

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

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

Answer 2

使用Observable

在组件中，你必须声明类成员，它将容纳一个对象（你将在组件中使用的东西）

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

然后一个服务将返回一个可观察的：

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

组件应做好准备，以便能够从中检索值：

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

您必须将可观察值中的值分配给变量：

您的模板将使用变量name：

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

另一种使用可观察的方法是通过async管道http://briantroncone.com/?p=623

注意：如果不是您要问的问题，请更新您的问题并提供更多详细信息

Answer 3

编辑：更新代码，以反映RXJS最新版本中对管道工作方式所做的更改。所有操作符（以我的示例为例）现在都被包装到pipe（）操作符中。

我意识到这个问题是很久以前的事了，现在你肯定已经有了一个合适的解决方案，但是对于任何想要解决这个问题的人，我建议你promise保持异步模式。

更详细的版本将创建一个新的promise：

function getValueFromObservable() {
    return new Promise(resolve=>{
        this.store.pipe(
           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);
         })
    })
}

在接收端，您将“等待”promise以如下方式解决：

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

更精简的解决方案是使用RxJS'. toPromise（）代替：

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

接收方当然保持与上述相同。