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

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

一个类似的答案被否决了。但我认为我可以证明我在这里提出的建议适用于有限的情况。

虽然一个可观察对象确实没有当前值，但通常它会有一个立即可用的值。例如，对于redux / flux / akita存储，您可以根据一些可观察的数据从中央存储请求数据，这些值通常会立即可用。

如果是这种情况，那么当您订阅时，该值将立即返回。

假设你有一个对服务的调用，在完成时你想从你的商店中获得一些东西的最新值，这可能不会发出:

你可以尝试这样做(你应该尽可能地把事情“放在管道里”):

 serviceCallResponse$.pipe(withLatestFrom(store$.select(x => x.customer)))
                     .subscribe(([ serviceCallResponse, customer] => {

                        // we have serviceCallResponse and customer 
                     });

这样做的问题是它会阻塞，直到第二个可观察对象发出一个值，而这可能永远不会发生。

我发现自己最近只需要在一个值立即可用的情况下评估一个可观察到的值，更重要的是，我需要能够检测到它是否可用。我最后是这样做的:

 serviceCallResponse$.pipe()
                     .subscribe(serviceCallResponse => {

                        // immediately try to subscribe to get the 'available' value
                        // note: immediately unsubscribe afterward to 'cancel' if needed
                        let customer = undefined;

                        // whatever the secondary observable is
                        const secondary$ = store$.select(x => x.customer);

                        // subscribe to it, and assign to closure scope
                        sub = secondary$.pipe(take(1)).subscribe(_customer => customer = _customer);
                        sub.unsubscribe();

                        // if there's a delay or customer isn't available the value won't have been set before we get here
                        if (customer === undefined) 
                        {
                           // handle, or ignore as needed
                           return throwError('Customer was not immediately available');
                        }
                     });

请注意，对于以上所有内容，我都使用subscribe来获取值(正如@Ben讨论的那样)。没有使用.value属性，即使我有一个行为主体。

有两种方法可以实现这一点。

BehaviorSubject有一个getValue()方法，您可以在特定的时间点获取值。 你可以直接订阅BehaviorSubject，也可以将订阅的值传递给类成员、字段或属性。

我不会同时推荐这两种方法。

在第一种方法中，它是一种方便的方法，您可以随时获取值，您可以将其称为该时间点的当前快照。问题是你可以在你的代码中引入竞争条件，你可以在许多不同的地方和不同的时间调用这个方法，这很难调试。

第二种方法是大多数开发人员在他们想要订阅时使用的原始值，您可以跟踪订阅，以及何时取消订阅以避免进一步的内存泄漏，如果您真的非常想将其绑定到一个变量，并且没有其他方法来连接它，则可以使用这种方法。

我建议，再看看你的用例，你在哪里使用它?例如，当你调用任何API时，你想要确定用户是否登录，你可以结合其他观察数据:

const data$ = apiRequestCall$().pipe(
 // Latest snapshot from BehaviorSubject.
 withLatestFrom(isLoggedIn),
 // Allow call only if logged in.
 filter(([request, loggedIn]) => loggedIn)
 // Do something else..
);

在angular的情况下，你可以通过管道数据$ | async直接使用它到UI。

虽然这听起来有点夸张，但这只是另一个“可能”的解决方案，可以保持Observable类型并减少样板文件……

你总是可以创建一个扩展getter来获取Observable的当前值。

要做到这一点，你需要在global.d.t types声明文件中扩展Observable<T>接口。然后在observable.extension.ts文件中实现扩展getter，最后将类型和扩展文件都包含到应用程序中。

你可以参考这个StackOverflow的答案来了解如何将这些扩展包含到你的Angular应用中。

// global.d.ts
declare module 'rxjs' {
  interface Observable<T> {
    /**
     * _Extension Method_ - Returns current value of an Observable.
     * Value is retrieved using _first()_ operator to avoid the need to unsubscribe.
     */
    value: Observable<T>;
  }
}

// observable.extension.ts
Object.defineProperty(Observable.prototype, 'value', {
  get <T>(this: Observable<T>): Observable<T> {
    return this.pipe(
      filter(value => value !== null && value !== undefined),
      first());
  },
});

// using the extension getter example
this.myObservable$.value
  .subscribe(value => {
    // whatever code you need...
  });

我在子组件中遇到了同样的问题，最初它必须拥有Subject的当前值，然后订阅Subject以侦听更改。我只是在服务中维护当前值，以便组件可以访问它，例如:

import {Storage} from './storage';
import {Injectable} from 'angular2/core';
import {Subject}    from 'rxjs/Subject';

@Injectable()
export class SessionStorage extends Storage {

  isLoggedIn: boolean;

  private _isLoggedInSource = new Subject<boolean>();
  isLoggedIn = this._isLoggedInSource.asObservable();
  constructor() {
    super('session');
    this.currIsLoggedIn = false;
  }
  setIsLoggedIn(value: boolean) {
    this.setItem('_isLoggedIn', value, () => {
      this._isLoggedInSource.next(value);
    });
    this.isLoggedIn = value;
  }
}

需要当前值的组件可以直接从服务中访问它，即:

sessionStorage.isLoggedIn

不确定这是否是正确的做法:)

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

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