当前位置: 首页 > 知识库问答 >
问题:

RxJs:从字段值更改创建可观察

刁浩言
2023-03-14

我想创建一个可观察的作为源变量:this.pending

我想创建一个可观察的,每次this.pending值更改时都会生成提要。

我是说,当我这样做的时候:

this.pending = false;

在我的代码的某个地方,我希望收到订阅的false提要,等等。。。

有什么想法吗?

共有1个答案

戴原
2023-03-14

只需使用行为主题

this.pending = new BehaviorSubject<boolean>(false)

在某处

subscription = this.pending.subscribe(console.log)

然后每次你执行

this.pending.next(true)this.pending.next(false)

订阅this.pending获取新值。

 类似资料:
  • 我对RxJs还比较陌生,我想了解与Rx结合使用Promises的最佳方式是什么。 我想要创建的是Angular中的一个服务,它的作用类似于事件分派器模式,一旦promise完成,就会发出一个事件。我还需要的是,如果没有(事件)订阅者,则永远不会调用可观察对象。我最不希望发生的事情是,observable的任何后续订户都会得到相同的结果,而不会触发对服务器的另一个请求。我在这里实现了自己的解决方案:

  • 在组件中: 在init上,我可以观察到 如何获取当前值,如?

  • 也许我错过了什么。我找不到Observable及其语法的简单教程。我在使用Angular,我需要从服务调用一个函数(在组件中定义)。我读了这个解决方案。但是我不知道如何更改在服务中创建的Observable中的值(也许创建不是最好的方法)。 我在解决方案中有一个组件: } 这是我的服务:

  • 假设我有一个,它从网络获取数据并发出数据,如果我订阅这个observable,每次它试图从网络请求数据时,它会很重。 我想创建BehaviorSubject并将其连接到observableA,这样任何其他线程/对象都将订阅BehaviorSubject以获取最新发出的数据。 到目前为止,我还不能用它来编码。我不能创建空的BehaviorSubject并在observableA内调用,因为它们彼此不

  • 嗨,我正在使用angular 7和rxjs async 在我的组件中,我使用ngFor与异步观察者 在我的服务中,我有一个BehaviorSubject,当用户选择一个组时,它会被释放 这是selectedItems$可观察的: 这是可行的,但现在我需要能够更改特定项以响应websocket消息。我有一个websocket连接,用于处理更新项目的消息。有没有一种方法可以使用rxjs的反应式方法来实

  • 我已经实现了一个angular应用程序,它请求一个项目列表来填充一个表格。在我的服务中,我有以下函数,它从服务器请求项目列表: 编辑:表获取数据的方式: 在HTML中,我将数据源绑定到mat表