你可以将最后一个发出的值与Observable分开存储。然后在需要的时候阅读它。

let lastValue: number;

const subscription = new Service().start();
subscription
    .subscribe((data) => {
        lastValue = data;
    }
);

Subject或Observable没有当前值。当一个值被触发时，它被传递给订阅者，Observable就完成了对它的处理。

如果你想要一个当前值，请使用专门为此目的设计的BehaviorSubject。BehaviorSubject保留最后发出的值，并立即将其发出给新的订阅者。

它还有一个getValue()方法来获取当前值。

另一种方法，如果你想/可以使用async await(必须在async函数中)，你可以在现代Rxjs中做到这一点:

 async myFunction () {
     const currentValue = await firstValueFrom(
      of(0).pipe(
        withLatestFrom(this.yourObservable$),
        map((tuple) => tuple[1]),
        take(1)
      )
    );
    // do stuff with current value

 }

 

这将发出一个值“Right away”，因为withLatestFrom，然后将解析承诺。

我遇到过类似的情况，在Subject的价值到达后，迟来的订阅者才订阅它。

我发现ReplaySubject类似于BehaviorSubject，在这种情况下很有魅力。 这里有一个更好的解释链接:http://reactivex.io/rxjs/manual/overview.html#replaysubject

唯一的方法，你应该得到值“出”一个可观察对象/主题是与订阅!

如果你在使用getValue()你在做一些声明式的命令。它是一个逃生口，但是99.9%的情况下你不应该使用getValue()。getValue()会做一些有趣的事情:如果主题已经取消订阅，它会抛出一个错误，如果主题已经死亡，它会阻止你获得一个值，因为它是错误的，等等。但是，再一次地，它是在罕见情况下的一个逃生口。

有几种方法可以以“Rx-y”方式从Subject或Observable中获取最新的值:

Using BehaviorSubject: But actually subscribing to it. When you first subscribe to BehaviorSubject it will synchronously send the previous value it received or was initialized with. Using a ReplaySubject(N): This will cache N values and replay them to new subscribers. A.withLatestFrom(B): Use this operator to get the most recent value from observable B when observable A emits. Will give you both values in an array [a, b]. A.combineLatest(B): Use this operator to get the most recent values from A and B every time either A or B emits. Will give you both values in an array. shareReplay(): Makes an Observable multicast through a ReplaySubject, but allows you to retry the observable on error. (Basically it gives you that promise-y caching behavior). publishReplay(), publishBehavior(initialValue), multicast(subject: BehaviorSubject | ReplaySubject), etc: Other operators that leverage BehaviorSubject and ReplaySubject. Different flavors of the same thing, they basically multicast the source observable by funneling all notifications through a subject. You need to call connect() to subscribe to the source with the subject.

可以创建订阅，然后在获取第一个发出的项之后销毁订阅。在下面的例子中，pipe()是一个函数，它使用一个可观察对象作为输入，并返回另一个可观察对象作为输出，同时不修改第一个可观察对象。

用Angular 8.1.0包"rxjs": "6.5.3"， "rxjs-observable": "0.0.7"创建的示例

  ngOnInit() {

    ...

    // If loading with previously saved value
    if (this.controlValue) {

      // Take says once you have 1, then close the subscription
      this.selectList.pipe(take(1)).subscribe(x => {
        let opt = x.find(y => y.value === this.controlValue);
        this.updateValue(opt);
      });

    }
  }