对现有主题可观察的管道RxJS，但不能在完成时观察
RxJS（Reactive Extensions for JavaScript）是一个用于处理异步数据流和事件的库。它基于观察者模式和迭代器模式，提供了一种响应式编程的方式来处理数据流。
RxJS的主要特点包括：
- 数据流处理：RxJS可以处理各种类型的数据流，包括用户输入、HTTP请求、定时器等。它提供了丰富的操作符，可以对数据流进行过滤、转换、合并、分组等操作，使得数据处理变得简洁和灵活。
- 异步编程：RxJS可以处理异步操作，例如处理HTTP请求的响应、定时器的触发等。它通过Observable对象来表示异步数据流，并提供了各种操作符来处理异步数据流的各个阶段，例如发起请求、获取响应、处理错误等。
- 响应式编程：RxJS支持响应式编程范式，即数据的变化会自动触发相应的操作。通过使用Observable对象，可以监听数据流的变化，并在数据发生变化时执行相应的操作，例如更新UI、发送通知等。
- 组合操作：RxJS提供了丰富的操作符，可以将多个数据流进行组合和转换。例如，可以使用操作符如merge、concat、zip等将多个数据流合并成一个数据流，使用操作符如map、filter、reduce等对数据流进行转换和过滤。
- 错误处理：RxJS提供了多种方式来处理错误，例如使用catchError操作符捕获错误并返回一个备选的数据流，使用retry操作符重新订阅数据流以重试操作等。
- 取消订阅：RxJS允许在不需要继续处理数据流时取消订阅，以释放资源和减少内存占用。通过调用订阅对象的unsubscribe方法，可以取消对数据流的订阅。
RxJS可以应用于各种场景，包括但不限于：
- 前端开发：RxJS可以用于处理用户输入、处理HTTP请求、管理状态等。例如，可以使用RxJS来处理用户输入的搜索关键字，实现自动补全功能；可以使用RxJS来管理前端应用的状态，实现响应式UI。
- 后端开发：RxJS可以用于处理服务器端的异步操作，例如处理HTTP请求、处理数据库查询等。通过使用RxJS，可以简化异步操作的处理逻辑，提高代码的可读性和可维护性。
- 软件测试：RxJS可以用于编写测试用例，验证代码的正确性和性能。通过使用RxJS提供的操作符，可以模拟各种场景，例如模拟用户输入、模拟网络延迟等，从而对代码进行全面的测试。
- 数据库：RxJS可以用于处理数据库查询的结果。例如，可以使用RxJS来处理数据库查询的结果集，对结果进行过滤、转换、分组等操作，从而得到需要的数据。
- 服务器运维：RxJS可以用于处理服务器端的异步操作，例如处理日志、监控服务器状态等。通过使用RxJS，可以简化异步操作的处理逻辑，提高服务器运维的效率。
- 云原生：RxJS可以与云原生技术结合使用，例如使用Kubernetes进行容器编排，使用Istio进行服务网格管理等。通过使用RxJS，可以处理云原生环境中的异步数据流和事件，实现高效的云原生应用。
推荐的腾讯云相关产品和产品介绍链接地址：
- 云函数（Serverless）：腾讯云函数是一种无服务器计算服务，可以让您无需关心服务器管理和运维，只需编写代码并设置触发条件，即可实现按需运行。详情请参考：腾讯云函数
- 云数据库MongoDB：腾讯云数据库MongoDB是一种高性能、可扩展的NoSQL数据库服务，适用于存储大量结构化和非结构化数据。详情请参考：腾讯云数据库MongoDB
- 云原生容器服务TKE：腾讯云原生容器服务TKE是一种高度可扩展的容器管理服务，支持Kubernetes，提供了强大的容器编排和管理能力。详情请参考：腾讯云原生容器服务TKE
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求进行评估和决策。
相关·内容
4回答
我尝试在我的角6项目中导入rxjs计时器，如
import { timer } from 'rxjs/observable/timer';
我也试过，
Rx.Observable.timer(200, 100)
它们不起作用
以下是上的代码
浏览 0提问于2018-05-08得票数 19
回答已采纳
我是rxjs的新手，所以我可能不会像一个有经验的用户那样使用它。
我也在使用rxjs 5.1.0。
我有一个服务，其中有一个名为file$的BehaviorSubject和一个来自file$的名为files的observable
@Injectable()
export class UploadService {
files$: BehaviorSubject<FileToUpload[]> = new BehaviorSubject([]);
files: Observable<FileToUpload[]> = this.files$.asObservabl
浏览 45提问于2019-02-21得票数 2
当可观察性完成时，我需要执行一些代码，这取决于是否有错误完成。我有这样的代码：
const obs = getMyObservable().pipe(finalize(() => {
//here
}));
正如您所看到的，我使用的是finalize操作符，但我不知道是否有错误完成。在doOnComplete或doOnError算子中，rxjs中是否有某种类型的算子？
浏览 0提问于2018-05-18得票数 10
回答已采纳
我在我的应用程序中使用了RXJS websocket。登录后，数据从我的服务器发送到客户机，并将数据存储在一个可观察对象中，在导航应用程序时使用shareReplay保存数据。 if(!this.data$ || this.data$Completed) {
this.data$ = this.dataService.get(this.CTRL, 'list').pipe(
finalize(() => {
console.log('finalizing data list');
t
浏览 28提问于2021-02-11得票数 0
2回答
我有一个使用ngx-formly(动态表单)的角应用程序，其格式类型(select)中有一个subscribe()。在组件中，formly表单是为formly类型使用Observable定义的，并动态创建。
在组件中，我有一个Subject和按钮，生成一个next()，格式类型不接收数据(也没有收到完整的)。组件本身中的subscribe()可以工作。
从Subject到BehaviorSubject<number>()，我只收到一次格式类型的数据，但没有收到关于next()的进一步数据。
代码用于步骤/向导中，更改为下一步，此步骤中的所有select都应该重新加载它们的选项。
这
浏览 0提问于2018-10-08得票数 0
回答已采纳
在一个Range5项目中，我试图处理，但不明白在导入分离的operators时它是如何工作的。
fromPromise 考虑将与 map**:**链接起来
import { fromPromise } from 'rxjs/observable/fromPromise';
import { map } from 'rxjs/operator/map';
使用fromPromise().map()返回错误：fromPromise_1.fromPromise(...).map is not a function
和
import 'rxjs/add/obs
浏览 1提问于2018-03-19得票数 0
回答已采纳
我想和RxJS一起使用这两种解决方案，但我不知道该如何做。
调用Observable发出的每一个数据，并能够像Subject那样工作。
// Sample code, this does not work properly :(, because next is not defined on Observable
const dummy = new Subject<number>().pipe(
map((num) => num + 1)
);
dummy.subscribe((number) => {
// expects 4 but get 3
})
d
浏览 6提问于2022-06-04得票数 0
回答已采纳
2回答
在角应用程序中，从服务器获取数据有不同的方法：
从服务中获得可观察性，并在组件上订阅它
在服务中创建主题，在组件上订阅主题
这两种方法都适用于我，但我不知道该用哪种方法。
First method.从服务中获得可观察性，并在组件上订阅它
article.service.ts
import { Injectable } from '@angular/core';
import { Article } from '../models/article';
import { AngularFirestore } from '@angular/fi
浏览 0提问于2019-08-24得票数 3
回答已采纳
如果我有一个需要很长时间执行的可观察对象。我们将其称为longObservable，它的类型为Observable，执行时间为5秒，每次执行时，它只发出一次新字符串，然后完成。 longObservable(): Subject<string> {
return timer(5000).pipe{
map(() => randomString())
}
} 其他一些页面会多次调用它。如果它正在进行中，我只想继续这一个过程。如果完成了，我想重新开始。 longObservable.subscribe() // Immediate, start
浏览 15提问于2019-01-11得票数 2
回答已采纳
2回答
我感到困惑的是，这个rxjs tap()操作符从未在这个简单的角度组件中触发，而Subject值却在屏幕上得到更新。我还尝试使用BehaviorSubject代替使用相同的结果。我在这里做错了什么？
import { Component } from '@angular/core';
import { Subject, BehaviorSubject } from 'rxjs';
import { tap } from 'rxjs/operators';
@Component({
selector: 'my-app',
浏览 0提问于2019-06-24得票数 2
回答已采纳
2回答
与组件相比，在服务中实例化RxJS主题有什么缺点吗？主题的实例化本身是否会导致内存泄漏，就像我们忘记取消订阅可观察对象一样？在这方面，服务的作用域(根/模块/组件)很重要吗？
浏览 20提问于2019-11-20得票数 0
我有一个rxjs@6 BehaviorSubject source$，我想从source$获取子值
const source$ = new BehaviorSubject(someValue);
const subSource$ = source$.pipe(map(transform));
我希望subSource$也是一个BehaviorSubject，但不是，我怎么才能让subSource$是一个BehaviorSubject呢？
浏览 0提问于2018-07-09得票数 8
比方说，我在数据库中有100多个项目，确切的数量还不清楚。如果我提供开始项目ID和所需的项目数，我的后端API将给出所需的项目数。项ID从0开始，并增加1。
我希望一批一批地获取它们(例如，每批10项)，以便在客户端进行处理。处理完一批后，我想取下一批。
在我的RxJS项目中使用Angular 2实现这一目标的最佳方法是什么？
浏览 3提问于2017-02-05得票数 0
回答已采纳
2回答
热与冷观测
、、
在RxJS中，热观测是使用外部生产者的可观测性，而冷可观测的是使用本地生产者(参见)。
无论何时打电话，HttpClient.post都会使用冷观测值发送数据和重复。
有什么方法可以从角度上判断某一特定方法是否使用了可观察到的热或冷？
浏览 0提问于2017-09-06得票数 10
回答已采纳
我正在通过这个学习Angular2。
下面的代码突然出现了。为什么"missionAnnounced$“没有变量声明？让任务宣布$= ...下面代码的逻辑是什么？
import { Injectable } from '@angular/core';
import { Subject } from 'rxjs/Subject';
@Injectable()
export class MissionService {
// Observable string sources
private missionAnnouncedSource = n
浏览 0提问于2016-10-30得票数 9
所以，这就是我的用例:我从rest API获取一个observable，然后通过在模板中使用async来获取数据。单击时，我将获得特定用户的ID，然后使用该用户的数据填写表单。为了实现后者，我重用现有的观察值并过滤数据，然后订阅它。我想知道我的方法是否正确，因为我认为当我点击“编辑”来填写表单时，应用程序太慢了，所以我猜我在这里创建了太多的订阅或诸如此类的东西？
另外，为了便于讨论，我创建了两个可观察对象(user和users)，其中一个(user)获得了对另一个(users)的“引用”，然后它用async显示在模板中，同时我还订阅了它并将其设置为“常规”变量。这是一个问题吗？使用async显
浏览 0提问于2017-11-05得票数 0
我得到了这个错误。我在试着用 import { catchError } from 'rxjs/operators' 而不是 import 'rxjs/add/operator/catch' 但是如何使用rxjs/add/operator/do和rxjs/add/operator/toPromise的instaed呢
浏览 9提问于2020-10-07得票数 3
1回答
以下是解决相同问题的两种方法，即对用户在文本框中输入的某些字符进行反应性搜索。第一个解决方案来自，第二个解决方案来自即时搜索课程。
第一个解决方案使用Observable，第二个解决方案使用Subject。
Observable解决方案只使用takeUntil调用服务器一次。Subject解决方案使用distinctUntilChanged。
有人能解释一下这两种方法的优缺点吗？
使用可观察到的搜索：
@Injectable()
export class BookEffects {
@Effect()
search$: Observable<Action>
浏览 2提问于2017-03-06得票数 1
2回答
我是angular的新手，开始学习angular 4.Data not binding with ngfor directive on a component the the async pipe。请帮帮忙
用户服务使用HTTP请求从API获取数据：
user.service.ts
import { Injectable } from '@angular/core';
import { Http, Response, Headers, RequestOptions } from '@angular/http';
import { Observable } fro
浏览 0提问于2017-07-30得票数 1
我有一个简单的代码，返回缓存的公司或从数据库的公司。问题是我几乎在同一时间从两个不同的地方订阅了这个观察点。这会触发对数据库的2次调用，所以我只想在第一次调用完成并且缓存值已经存在的情况下运行第二次订阅。有没有通过rxjs运算符执行此操作的标准方法？
public current(): Observable<Company> {
if (this.cachedCompany) {
return Observable.of(this.cachedCompany);
} else {
if (this.
浏览 0提问于2018-05-25得票数 1
我正在升级从角2到角5
我使用了下面的链接并进行了更新。
每个步骤都不确定如何更新导入的每个RxJS操作符，现在应该从‘rxjs/ Operator’导入并使用管道操作程序。
我在代码库中使用过这样的Rxjs，但不确定如何更改它。
<!-- language-all: lang-or-tag-here -->
import { Subject } from 'rxjs/Subject';
import { Observable } from 'rxjs/Rx';
@Injectable()
export class pl
浏览 0提问于2018-01-26得票数 0
2回答
在我的项目中有许多使用异步/等待的代码。但是我想把所有的代码都转到rxjs代码上。
但我不习惯用rxjs。请告诉我将异步/等待代码转换为rxjs的模式或方法。或者请推荐一个例子。
这是我的原始代码(使用异步/等待)
this.userHistory$ = new Subject();
async getUserStatue(userId, query){
const userData = await this.UserApi.getUserInfo(userId, query);
this.userHistory$.next(userData);
}
下面的代码是我试图使用rxjs
浏览 7提问于2022-05-16得票数 0
我想知道像.map()这样的RxJS操作符是如何‘监听’传入的可观察流的。.map()和其他RxJS操作符是否在幕后订阅流，以便访问可观察值？
如果我理解正确的话，每个操作符都订阅了输入可观察值，这使它可以访问值流，然后将转换后的值的可观察值返回给下一个操作符？感谢您的任何澄清。
浏览 0提问于2020-10-04得票数 2
1回答
角4元件与RxJ的通信
、、、
我正在遵循教程。使用可以很好地接收消息，但不适用于其他组件。我使用MessageService作为@ngModule中的整个应用范围。Appcomponent接收消息，但其他组件可以发送消息，但不接收消息。
import { Injectable } from '@angular/core';
import { Observable } from 'rxjs';
import { Subject } from 'rxjs/Subject';
@Injectable()
export class MessageService {
浏览 5提问于2017-12-23得票数 1
5回答
我正在迁移一个角形5应用程序到最新的CLI和Range6RC，并且我所有的可观察到的导入都被破坏了。我看到了角度6改变了导入的工作方式，但是我找不到任何关于语法是如何工作的明确的参考。
我5岁的时候就有了这个，效果很好：
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/catch';
import 'rxjs/add/observable/throw';
现在使用新的语法，
浏览 0提问于2018-04-13得票数 42
回答已采纳
2回答
我已经开始学习run，并且我在中遇到了关于使用服务进行父服务通信的示例：
import { Injectable } from '@angular/core';
import { Subject } from 'rxjs';
@Injectable()
export class MissionService {
// Observable string sources
private missionAnnouncedSource = new Subject<string>();
private missionConfirmedSour
浏览 4提问于2022-02-14得票数 -1
回答已采纳
3回答
我正在尝试执行3个异步动作(可观察的)，一个在另一个里面。1.第一个可观察对象是一个模态对话框eventEmiter的响应--流程的其余部分取决于它的响应(假设模态返回布尔生成器涉及到：“你想要删除项吗”)。2.第二个可观察对象是更新(删除)操作3。第三个是在删除之后取回新数据。
我正在使用rxjs- -并试图弄清楚如何在没有订阅的情况下使用订阅。请看我的代码：
subscriptions : Subscription[] = [];
openDeleteDialog(data : any)
{
const modalRef : NgbModalRef = this.modalSer
浏览 29提问于2019-10-27得票数 2
回答已采纳
请考虑下面的图表。
问题：
在“设计模式书”第294页，Applicability's第一项：
当抽象有两个方面时，一个依赖于另一个。将这些方面封装在单独的对象中，可以使您独立地更改和重用它们。
Q1:如果您想“独立地更改和重用它们”，为什么要将ConcreteObserver绑定到ConcreteSubject？
不，这不是关于执行的问题。当作者设计图表时，他必须有一个通用的面向对象的想法，我认为他们没有注意到它会导致ConcreteSubject和ConcreteObserver之间的耦合。
Q2:主题界面的目的是什么？有些书漏掉了。
不，这不是关于执行的问题。
浏览 0提问于2019-04-04得票数 1
我需要澄清操作管道在RxJS中的效率。
我目前对RxJS中的操作符管道的了解是，管道中的每个操作符接收一个可观测的，并创建一个新的(可能修改的)可观测的，作为输入返回给下一个操作符。这种行为将类似于JavaScript过滤器，映射，减少行为。因此，保留原始的可观测(流)或数组未接触/纯。
这个假设得到了RxJS文档：的支持。
Pipeable运算符是一个函数，它将一个可观测的输入作为其输入，并返回另一个可观测的函数。这是一个纯粹的操作:以前的可观察到的保持不变。
考虑到长的操作员管道，创建中间可观测数据对我来说似乎是很昂贵的。
此外，我正在阅读由Sergi编写的“用RxJS 5进行反应
浏览 0提问于2020-02-25得票数 3
1回答
我的期望是，当我设置这样一个可观察到的绑定时，任何绑定都将使用switchMap调用的结果：
this.thing = this.route.paramMap.pipe(
switchMap(async (params: ParamMap) => {
const id = +params.get('id');
const data = await this.thingService.getThingDetails(id);
return new ThingDisplay(data);
浏览 0提问于2018-10-02得票数 0
回答已采纳
1回答
我使用新闻api制作新闻应用程序，并正确地获取数据，但不将数据从服务发送到组件，那么如何将数据从服务发送到组件？
并通过rxjs对组件进行组件转换。
import { Injectable } from '@angular/core';
import { Subject } from 'rxjs';
@Injectable()
export class NewService {
private pushSource = new Subject<object>();
Country_Name;
浏览 2提问于2021-02-05得票数 0
回答已采纳
4回答
我发现将它们定义为
什么是主题？RxJS主题是一种特殊的可观察类型，它允许对许多观察者多播值。虽然普通的可观测性是单播的(每个订阅的观察者都拥有一个独立的可观测执行)，但主题是多播的。
它接着给出了一些例子，但我正在寻找一个基本的ELI5解释。据我所知，它有助于处理和定义序列中的项。对吗？
我认为，使用和不定义rxJS Subject来理解为什么它是重要的，这将对我和其他人非常有帮助。
谢谢!
浏览 5提问于2016-10-05得票数 14
我有一个角9应用程序，其中角分量属性绑定到RxJS可观测值。在这里，我试图用聚合物定制元件(纸输入)代替角元件。
，我的观察是什么？，我无法将自定义元素属性绑定到RxJS可观测值，而这正是我能够用角分量属性绑定的。
如何再现？用于显示我所面对的情况，我有堆叠闪电式样本与自定义元素(纸输入)绑定到一个可观察到的。
app.component.html
<paper-input [label]="price$ | async" ></paper-input>
app.component.ts
import { Observable } from 'r
浏览 3提问于2020-07-13得票数 0
1回答
我试着从一个可观察到的地方得到最后的值。示例代码是
// RxJS v6+
import { lastValueFrom, Subject } from 'rxjs';
import { scan } from 'rxjs/operators';
async function main() {
const subject = new Subject();
const example = subject.pipe(
scan((acc, curr) => {
return Object.assign({}, acc, curr
浏览 1提问于2022-06-28得票数 0
1回答
如何使用可观察对象进行组件间通信
、、、、
我正在使用Rxjs中的可观察对象和主题在两个组件之间进行通信，以下是服务部分：
import {
Injectable,
EventEmitter,
Output
} from '@angular/core';
import {
HttpClientModule,
HttpClient
} from '@angular/common/http';
import {
Observable
} from 'rxjs/Rx';
import 'rxjs/add/operator/map';
import &
浏览 0提问于2017-10-06得票数 0
3回答
在一本“角度2”的指南中，它说：
可观察运算符的默认行为是在.complete()或.error()消息发布后立即释放订阅。请记住，RxJS的设计目的是在大多数情况下使用“失火而忘记”的方式。
在较早的一页中，有一个可观察和订阅的例子。
。
您可以看到，3秒后，onbservable ".complete()“的。但是，当再次单击Init()按钮并调用init()方法时，仍然会通知订阅者。
代码：
import {Component} from '@angular/core';
import {Observable} from 'rxjs/Observable&
浏览 1提问于2016-11-29得票数 1
所以，基本上，rxjs是新的，想知道，
我是否需要从Observable.of(数据)或更新的rxjs版本中取消订阅(数据)？
即
import {of} from 'rxjs';
const sub = of(data).subscribe();
这有必要吗？
sub.unsubscribe();
浏览 2提问于2019-04-28得票数 6
这是使用rxjs操作符的示例代码，我想打印/获取第二个最后的值。
类型标
import { from } from 'rxjs';
import { map, last } from 'rxjs/operators';
//emit (1,2,3,4,5)
const source = from([1, 2, 3, 4, 5]);
//add 10 to each value
const example = source.pipe(map(val => val + 10)).pipe(last());
//output: 11,12,13,14,15
c
浏览 6提问于2020-01-13得票数 7
回答已采纳
1回答
在rxjs主题上调用()的目的是什么？
例如:在可观察的takeUntil()通知程序上调用complete。为什么我们需要这样做，而不只是调用next()并完成它呢？
如果这只是个会议，为什么会这样？
浏览 0提问于2018-09-25得票数 11
回答已采纳
2回答
我正在使用angular/cli": "~6.1.5和rxjs": "^6.0.0，因为我刚接触到了Range6，我开始从正式文档中学习
代码如下
var clicks = Rx.Observable.fromEvent(document, 'click');
var result = clicks.throttleTime(1000);
result.subscribe(x => console.log(x));
与上面的代码相同，我在角6中尝试过
fromEvent(mybuttonId, 'click')
浏览 0提问于2018-09-02得票数 3
回答已采纳
我有一个父MatHorizontalStepper组件，它使用subscribe来检查服务中的Observable是否已经从false更新到true。如果可观测值发生了变化，则自动移动到步进器的下一步。
但是，我似乎无法让更新来正确地更改步骤。下面是我创建的两个组件。
父组件
import { Component, OnInit, ViewChild } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import { MatHorizontalStepper } from
浏览 0提问于2018-06-19得票数 0
回答已采纳
1回答
是否有任何设计模式在角12取消可观察的订阅？
目前，我们正在开发一个角度应用程序，并发现我们的一些组件没有unsubscribe到可观察的，因此它正在造成内存泄漏和一些奇怪的行为在不同的页面。因此，与其像下面这样使用ngDestroy关闭每个组件中的订阅，还有更好的方法像一个可以在应用程序中重用的设计模式而不改变现有行为和尽可能少的代码吗？
import {Component, OnInit, Output, EventEmitter, OnDestroy } from '@angular/core';
import { HttpClient } from '@an
浏览 1提问于2022-10-25得票数 0
我想实现一个搜索组件，如角教程。
问题:
search方法触发并修改searchTerms: Subject<string>，但switchMap从不触发。
代码：
进口
import { Component, OnInit } from '@angular/core';
import { SearchService } from "./search.service";
import { Observable } from 'rxjs/Observable';
import { Subject }
浏览 2提问于2017-07-26得票数 0
回答已采纳
我在尝试运行git bash时遇到了这个问题。.switchMap未执行，并显示错误为“error TS2339:属性'switchMap‘在类型'Observable’上不存在”“
我使用的代码是：
import { User } from './../classes/user';
import { Injectable } from '@angular/core';
import { Router } from '@angular/router';
import { Observable, of } from 'rxj
浏览 0提问于2019-03-17得票数 2
嘿，我是下一个我的角度，我和一个团队一起工作，他们使用非常老的角度，我试图升级很多东西，我以前的rxjs是在5.4版本，现在我升级到6.5地图，捕捉和抛出不再接受，我读了一些文章也是如何转换它们，但仍然不清楚，因为大多数文章没有解释如何得到json()的回应。
下面是我以前的rxjs5.4语法
import { Observable } from "rxjs/Observable";
import "rxjs/add/operator/catch";
import "rxjs/add/operator/map";
import "rxjs
浏览 0提问于2019-05-23得票数 0
示例：
import { BehaviorSubject } from 'rxjs';
import { share } from 'rxjs/operators';
const subject = new BehaviorSubject(123);
const obs = subject.asObservable().pipe(share());
obs.subscribe(console.log);
obs.subscribe(console.log);
obs.subscribe(console.log);
obs.subscribe(conso
浏览 0提问于2019-12-24得票数 0
回答已采纳
1回答
我们有一个函数，可以从后端获取一个可观察的流。但是，我们也希望能够在后端完成这些更改之前，将其推送到可观察对象。为了做到这一点，我试着返回一个主题，但在取消订阅后连接仍在继续。
换句话说，在下面的代码中，我们希望console.log(i)在我们订阅主题之前不要启动，在我们取消订阅时结束：
import { ReplaySubject, Observable, interval } from 'rxjs';
import { tap } from 'rxjs/operators'
function test() {
const obs = interv
浏览 9提问于2018-08-10得票数 3
回答已采纳
我仍然在学习棱角分明，试图看看BehaviorSubject是如何工作的，但却被困在了起点。以下是我想做的事：
创建一个名为HeroDetailComponent的搜索框组件，在其中输入一些文本，在此文本的基础上，我将搜索一个英雄列表，并使用另一个组件HeroesComponent显示给用户。现在，这种通信应该在BehaviorSubject的帮助下使用服务组件来完成。
以下是我的主要组成部分：
app.component.html
<app-hero-detail></app-hero-detail>
<app-heroes></app-heroes
浏览 0提问于2019-01-31得票数 2
回答已采纳
2回答
我正在做一个有角度的项目，需要加载页面，然后逐个/两个地显示它们。
根据和其他一些来源，订阅服务几乎是不必要的。那么，是否有一种方法可以使用RxJS运算符以纯反应性的方式重写此操作呢？
以下是我所做的(简化)：
export class NavigationService {
private pages: Page[] = [];
private mode = Mode.SinglePage;
private index = 0;
private currentPages = new BehaviorSubject<Page[]>([]);
const
浏览 16提问于2022-11-29得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
