如何在不调用 next 的情况下设置新的 BehaviorSubject 值？答案

【问题标题】：How can I set a new BehaviorSubject value without calling next?如何在不调用 next 的情况下设置新的 BehaviorSubject 值？
【发布时间】：2019-06-28 11:43:06
【问题描述】：

我需要在不触发对任何订阅的下一次调用的情况下设置我的 BehaviorSubject 的值。

我试过这样做：

this.mySubject = new BehaviorSubject(newVal);

但这也会删除所有订阅。

this.mySubject.value = newVal;

不起作用，因为 .value 是只读的。

有没有办法做到这一点？

编辑：对于那些问我为什么需要这样做的人......

这是一个 Ionic 4 应用程序，因此有一个根列表页面，它调用 2 个其他子页面（一个详细视图和一个编辑页面）。进入视图页面的第一个导航需要选择的模型。列表页面将此模型的初始值设置为 BehaviorSubject，然后导航到视图页面。但是，这个初始值的设置会触发列表的刷新，这是我不想做的。我只想初始化该值，然后在编辑页面更改它的情况下进行监听，然后刷新我的列表。

【问题讨论】：

呃？你为什么想这么做？主题的全部目的是在其值更改时向其所有订阅者发出...
嘿，请阅读核心贡献者 ben lesh 的这篇关于 BehaviourSubject 的帖子：stackoverflow.com/a/45227115/7247920 .. 基本上，你根本不应该使用 value ;-)
@Jota.Toledo 更新了问题，解释了我为什么需要这样做。

标签： angular rxjs behaviorsubject

【解决方案1】：

我很想知道为什么您实际上想要这样做，但您可以考虑的一个选项是在您的值中包含一个标志，该标志指示是否应该传播更新，然后让您的所有订阅都来自过滤后的主题视图。

this.mySubject.next({propagate: false, value: 42});

makeObservable() {
   return this.mySubject.pipe(filter(x => x.propagate));
}

【讨论】：

基本上我有一个大型数据集，模型更改时将从服务器刷新。这是一个 Ionic 应用程序，因此这是调用 2 个其他子页面（详细视图和编辑页面）的根页面。进入视图页面的第一个导航需要选择的模型。列表页面设置此模型的初始值，然后导航到视图页面。但是，这个初始值的设置会触发数据的刷新，我不想这样做。在列表页面中设置一个在初始化时为 false 的标志可能同样容易，因此它不会刷新。
我也想过和你一样的解决方案。
简单而优雅，很好的答案@Jesse Carter

【解决方案2】：

BehaviorSubject 没有那么复杂。您可以创建自己的实现:)

import { Subject } from './Subject';
import { Subscriber } from './Subscriber';
import { Subscription } from './Subscription';
import { SubscriptionLike } from './types';
import { ObjectUnsubscribedError } from './util/ObjectUnsubscribedError';

/**
 * A variant of Subject that requires an initial value and emits its current
 * value whenever it is subscribed to.
 *
 * @class BehaviorSubject<T>
 */
export class BehaviorSubject<T> extends Subject<T> {

  constructor(private _value: T) {
    super();
  }

  get value(): T {
    return this.getValue();
  }

  /** @deprecated This is an internal implementation detail, do not use. */
  _subscribe(subscriber: Subscriber<T>): Subscription {
    const subscription = super._subscribe(subscriber);
    if (subscription && !(<SubscriptionLike>subscription).closed) {
      subscriber.next(this._value);
    }
    return subscription;
  }

  getValue(): T {
    if (this.hasError) {
      throw this.thrownError;
    } else if (this.closed) {
      throw new ObjectUnsubscribedError();
    } else {
      return this._value;
    }
  }

  next(value: T): void {
    super.next(this._value = value);
  }
}

要么复制上述内容，要么创建一个子类，公开一个 setValue

export class SettableBehaviorSubject<T> extends BehaviorSubject<T> {
  setValue(value: T): void {
    this._value = value;
  }
}

BehaviorSubject 的来源在这里：https://github.com/ReactiveX/rxjs/blob/master/src/internal/BehaviorSubject.ts

【讨论】：