RxJs从可观测数据中获取值

Question

在组件中：

singleEvent$: Observable<Event>;

在init上，我可以观察到

this.singleEvent$ = this._eventService.events$
  .map(function (events) {
    let eventObject = events.find(item => item.id === eventid);
    let eventClass: Event = new Event(eventObject);
    return eventClass;
  });

如何获取当前值，如event.name？

Answer 1

您可以使用observable.pipe（take（1））.subscribe将observable限制为仅获取一个值，并停止侦听更多值。

let firstName: string; 

        this.insureFirstName
            .pipe(take(1))  //this will limit the observable to only one value
            .subscribe((firstName: string) => {
                this.firstName = firstName; asssgning value 
            });
        console.log(this.firstName); //accessing the value

Answer 2

再加上Günter Zöbauer的答案，如果你想同步获得你的可观察对象内部的价值，那么行为主体可能就是你想要的。

行为主体是一个始终具有值的可观察对象，您可以调用myBe行为主体ubject.get值（）或my行为主体ubject.value来同步检索行为主体当前持有的值。

因为它本身也是一个可观察的对象，所以您仍然可以订阅BehaviorSubject，以异步响应它所持有的值的更改（例如，myBehaviorSubject.subscribe（事件=

以下是与给定示例相匹配的一些用法，用于从给定服务在组件中创建BehaviorSubject：

@Component({
  //...
})
export class YourComponent implements OnInit {
  singleEvent$: BehaviorSubject<Event>;

  constructor(private eventService: EventService){}

  ngOnInit(){
    const eventid = 'id'; // <-- actual id could go here
    this.eventService.events$
      .pipe(
        map(events => {
          let eventObject = events.find(item => item.id === eventid);
          let eventClass: Event = new Event(eventObject);
          return eventClass;
        })
      )
      .subscribe(event => {
        if(!this.singleEvent$){
          this.singleEvent$ = new BehaviorSubject(event);
        } else {
          this.singleEvent$.next(event);
        }
      });
  }
}

Answer 3

要从可观察对象获取数据，您需要订阅：

this.singleEvents$.subscribe(event => this.event = event);

在模板中，您可以使用异步管道直接绑定到可观测对象：

{{singleEvents$ | async}}