异步管道和订阅在同一个可观察对象上
异步管道和订阅是一种在同一个可观察对象上进行的事件处理机制。
异步管道是一种处理事件的方式，它允许将多个操作连接起来，形成一个管道。每个操作都是异步执行的，当一个操作完成后，它的结果会传递给下一个操作。这种方式可以提高系统的并发性和响应性能力。在云计算中，异步管道常用于处理大规模数据处理、批量任务处理等场景。
订阅是一种观察者模式的实现方式，它允许多个观察者订阅同一个可观察对象，并在对象状态发生变化时接收通知。在云计算中，订阅常用于事件驱动的架构中，例如消息队列、事件总线等。通过订阅机制，可以实现解耦和灵活性，提高系统的可扩展性和可维护性。
在同一个可观察对象上同时使用异步管道和订阅，可以实现更加灵活和高效的事件处理。异步管道可以用于处理事件的具体逻辑，而订阅可以用于通知其他模块或系统进行相应的操作。这种组合可以提高系统的可扩展性、可维护性和性能。
腾讯云提供了一系列与异步管道和订阅相关的产品和服务，例如：
- 腾讯云消息队列 CMQ：提供高可靠、高可用的消息队列服务，支持异步消息传递和订阅机制。链接地址：https://cloud.tencent.com/product/cmq
- 腾讯云事件总线 CEB：提供事件驱动的架构，支持发布/订阅模式，可以实现系统间的解耦和灵活性。链接地址：https://cloud.tencent.com/product/ceb
通过使用腾讯云的这些产品，可以轻松构建和管理异步管道和订阅机制，实现高效的事件处理和系统架构。
相关·内容
2回答
我对角和RxJs和Ngrx都很陌生
我知道，我们赞同一个可观察的，并观察变化。我在Ngrx 中看到了这段代码
<div>Current Count: {{ count$ | async }}</div>
问题是，到底是什么?它和订阅一个可观察到的有什么不同？一种什么时候用，什么时候用？
浏览 1提问于2019-05-06得票数 3
回答已采纳
我是一个业余爱好者，正在自学angular一年。当我试图开发一个自定义分页服务来从firebase中检索数据时，我想出了一个在使用异步管道或普通订阅时返回不同数组的观察值。 基本上，我的observable使用扫描操作符来累积从firebase获取的数据。它有两个方法: init获取第一个数据并使用初始数据设置observable，以及addData获取更多数据。 在启动服务并添加一些数据后，如果我再次初始化它，如果使用正常订阅，它将不会重置数据。但如果使用异步管道，该服务将按预期重置数据。为什么订阅管道和异步管道具有不同的行为，而预期具有相同的行为？ 我在stackblitz中创建了一个错
浏览 7提问于2019-06-09得票数 1
我需要确定两种处理可观测值的不同方法是否同样有效，或者其中一种方法是否会导致内存问题。
在下面的示例中，foo$和bar是从服务接收其值的模板变量。每个人都有自己的可观察性。在组件中，从订阅中显式地给出了bar的值，然后在OnDestroy()中结束该订阅。然而，foo$没有显式地订阅服务，而是在模板中使用async管道。
foo$和bar都是显示服务数据的有效方式，还是foo$有问题，因为没有取消对内存清理的订阅？
ExampleService:
Injectable()
export class ExampleService {
get foo$(): Observable<
浏览 2提问于2019-05-08得票数 3
回答已采纳
2回答
在性能和“角度方式”方面，哪一个更好:在视图中有多个异步管道，还是在组件中有一个带有取消订阅操作onDestroy的订阅者？
示例：
@Component({
template: `<div> {{ post.title }} {{ post.author.name }} {{ post.category.name }} </div>`
...
})
class AppComponent {
public post: Post;
public postSubscription;
ngOnInit() {
postSubscription
浏览 0提问于2016-08-18得票数 11
我正在使用在应用程序上填充下拉列表。该应用程序使用一个下拉组件，该组件在整个应用程序中用于下拉，所以我不能修改它。
对于我的问题来说，来自该组件的HTML最重要的内容如下：
<option *ngFor="let option of options" [value]="stringifyOption(option.value)" [selected]="option.value === (selectedValue | async)">
{{option.text}}
</option>
我正在从商店获得下拉选项，这
浏览 0提问于2019-03-06得票数 1
1回答
当我的服务调用返回HTML页面的数据时，使用异步绑定与只映射到具体对象有什么好处或好处？
下面是这两个选项的一个例子。
映射到组件属性
// component
event: any;
// ngOnInit()
this.eventService.getEvent(this.id).pipe(take(1)).subscribe(response => {
this.event = response;
}, error => {
console.log(error);
});
// service
getEvent(id: number): Observable&
浏览 1提问于2021-12-03得票数 1
在我的项目中，我们使用数组和可观察值在服务中操作和存储数据。我们像这样创建可观察值：
Observable.of(数组)
然后，我们只在添加/删除/etc元素时更新数组。
在我们的组件中，我们只使用可观察对象并使用异步过滤器。
我想知道这是否是一个好的实践，因为即使在Angular的文档中，他们也建议使用Observable和Subject的组合，而不是Observable和Array的组合。
为什么使用主题更好？在性能上有区别吗？
谢谢
浏览 0提问于2017-09-22得票数 1
我开始关注ngrx，我看到了使用角异步管道的方便性。同时，我不确定大规模使用角异步管道是否是一个不错的选择。
我举一个简单的例子。让我们假设，在同一个模板中，我需要显示从Store检索到的对象(例如Person)的不同属性。
一段模板代码可以是
<div>{{(person$ | async).name}}</div>
<div>{{(person$ | async).address}}</div>
<div>{{(person$ | async).age}}</div>
而组件类构造函数将具有
export class
浏览 3提问于2017-01-17得票数 53
回答已采纳
2回答
很多角度教程都建议使用异步管道来实现自动不可观测。
他们声称的：
异步管道用于自动取消订阅观察者，否则需要手动取消订阅。
他们做了什么：
他们使用角http调用REST作为async管道的示例。
然而，根据我的理解，角HTTP自动取消订阅可观察到的内容。因此，异步管道实际上并没有达到预期的目的，因为即使没有异步管道，可观察到的用户也会自动取消订阅。
在这个用例中，为什么需要在这里使用异步管道，还有其他原因吗？
抽样实施情况：
getUserList() {
return this.http.get(apiUrl);
}
this.getUserList().subscribe(use
浏览 6提问于2017-09-22得票数 6
回答已采纳
1回答
使用可观测值自动更新视图
、、、
我使用可观察和HTTP请求在服务器上添加数据，然后更新其他路由。
我希望这些数据能立刻更新。实际上，我应该刷新页面以获得新的数据。
在我的服务中，我使用AddProj()和getAllProj()函数来获取和发送数据
service.ts
import { Injectable } from "@angular/core";
import { NouveauProjet } from "./models/nouveau-projet";
import { HttpClient, HttpResponse } from "@angular/common/h
浏览 3提问于2017-12-22得票数 0
我有一个非常简单的要求。当hideToolBarHeader的属性值设置为true时，使用ngClass ="{'my-class'：hideToolBarHeader}隐藏工具栏标题。传入的值来自服务。此服务如下所示：
`@Injectable({
providedIn: 'root'
})
export class HeaderService {
hideToolbarHeader$: ReplaySubject<boolean> = new ReplaySubject(1);
constructor() { }
浏览 0提问于2019-05-02得票数 0
我通过angular 11中的异步管道订阅了一个延迟的观察者。
出于某种原因，更改检测(？)不会稳定，管道不会接收这些值，我不知道原因是什么？它显示的不是我的数据，而是null。
示例：
html
<h1>{{ getData(0) | async | json }}</h1>
组件
@Component({
selector: 'my-app',
templateUrl: './app.component.html',
styleUrls: ['./app.component.css']
})
export
浏览 5提问于2021-06-07得票数 0
我一直在做一个有棱角的项目。但我的项目不像它应该做的那样。我得到了错误" Error :无法找到“object”类型的不同的支持对象‘对象’。NgFor只支持绑定到诸如数组之类的Iterable。“在我页面的控制台里。
在我的页面上，我得到了“这件事”，但仅此而已。同时，我也应该看到我的'dier‘的'soort’。
在我的html中：
<p>This works</p>
<div
class="dier"
*ngFor="let dier of dieren$">
浏览 2提问于2020-05-19得票数 1
回答已采纳
4回答
角异步管道
、、
我目前正在以角度进入入门部分，有一个部分我不明白。
从购物车服务中，他们从应用程序文件夹中的shipping.json中获取数据。
HttpClient http;
getShippingPrices() {
return this.http.get('/assets/shipping.json');
}
然后在shippingComponent中，他们调用该方法：
ngOnInit() {
this.shippingCosts = this.cartService.getShippingPrices();
在html模板中，必须使用异步管道。
<div cla
浏览 2提问于2020-10-13得票数 0
回答已采纳
3回答
我不知道到底出了什么问题，但我正在尝试应用的搜索系统，但没有成功。
以下是组件中使用的函数：
// my-comp.component.ts
public testing: Observable<any>;
private searchTerms = new Subject<string>();
search(term: string): void {
this.searchTerms.next(term.toUpperCase());
}
每当我在搜索框中输入某项内容时，这个函数就会被击中，所以这里没有问题。
下面是ngOnInit方法：
// my-com
浏览 9提问于2017-06-20得票数 2
回答已采纳
我在组件中定义了一个可观察的(结果$)，并通过异步管道在其模板上显示它。可观测性是通过combineLatest进行的其他两个可观测数据的组合(第一个$，第二个$)。如果其中一个可观测到的，或者两者都发布得太早(在我发现ngAfterContentInit之前)，那么可观察到的结果就不会发出一个值。
组件:不工作
@Component({
selector: 'my-app',
templateUrl: './app.component.html',
styleUrls: [ './app.component.css' ]
})
ex
浏览 0提问于2019-02-07得票数 7
回答已采纳
2回答
我有以下代码：
<div *ngIf="users">
<ul>
<li *ngFor="let user of users">{{ user.name }}</li>
</ul>
</div>
TS文件
export class AppComponent implements OnInit {
constructor(private http: HttpClient) {};
users: any;
ngOnInit() {
this.s
浏览 3提问于2020-11-25得票数 0
回答已采纳
我正在考虑，它使用Subject来增加搜索的去抖动时间。
但是，该代码不包含任何类型的取消订阅组件销毁。这里不需要取消订阅吗？为什么？如果需要，执行此操作的适当形式是什么？
谢谢。
浏览 0提问于2018-04-02得票数 0
我是新的角度，我使用id过滤用户，就像在JWT有效负载中一样。
我可以在可观察到的订阅()中这样做：
this.route.data.subscribe((data) => {
this.users = data.users.filter((u: User) => u.id !== +this.authService.decodedToken.nameid);
});
我还可以在管道()方法中这样做，如：
this.route.data
.pipe(map(data => data.users.filter((u: User) => u.id !
浏览 2提问于2019-12-09得票数 1
回答已采纳
我已经看到数百个论坛在搜索这个错误，但我还没有找到合适的答案，我在Angular上相对较新，仍然不能理解生命周期钩子的事情。 我有一个父窗口，它有一个组件，在这个组件中我设置了窗口的值 <app-acciones [window]="selectedWindow"></app-acciones> 在子窗口中，我有这个窗口的输入，还有一个数组，我想在其中计算我想要订阅的函数值。 @Input() window:Window;
Actions:Action[];
totalActions:number; //this work prope
浏览 7提问于2020-03-30得票数 1
2回答
我在IProject上收到一个错误
must return a value。
我想从api返回结果。
public getProjectDetails(projectId: number): IProject {
this.testStationService.getProjectById(projectId)
.subscribe(
(res) => {
return res;
});
}
浏览 0提问于2018-05-04得票数 1
1回答
来自管道服务角度的异步函数
、、、、
我需要从angular中查找省名称，所以我为查找名称编写了一个管道服务，代码是这是我的代码管道
export class ConvertStatePipe implements PipeTransform {
constructor(private callData: CallDataService) {}
transform(value: string): any {
let nameProvince = '';
this.callData.getAllProvinces().subscribe( (res) => {
for (c
浏览 3提问于2020-07-02得票数 0
4回答
我从异步API获取数据，在我的前端我有一个网格的Kendo UI，我想将它与这些数据绑定，但是在控制台中，我看到了invalidpipeobject对象
这是我的服务：
getEventLog(ip) {
return this.http.post(this.url_event_log, {}, {params: {id: ip}})
}
在我的部分，我有：
this.service.getEventLog(id).subscribe(s => {
this.eventlogs = s;
})
在我的kendo网格中，添加了异步管道：
[data]="eve
浏览 5提问于2020-09-29得票数 0
回答已采纳
1回答
这可能是个蹩脚的问题，但我对角度并不熟悉，对那些可观测到的东西我也不太了解。
我得到了一些代码，其中第二个选择的选项取决于第一个选择值。有一个refreshPeople()方法，它在第一个选择变更时调用，该方法尝试将加载设置为true，然后对数据进行异步调用，然后将加载设置为false。
但是refreshPeople()中的最后一个命令不是等待异步调用结束。:(
在angular2+中制作这类东西的正确方法是什么？
因此，模板是：
Gender: {{gender}}
<ng-select
[items]="genders"
(change)="r
浏览 3提问于2020-08-21得票数 0
回答已采纳
2回答
ngOnInit()中有Observable<>。 ngOnInit() {
this.products$ = this.someService.getMissingProducts();
} this.products$是Observable类型，并且产品具有代码(字符串类型)成员字段。我想要将所有Product[]的代码值更改为新的值。 对于这个愚蠢的问题我很抱歉。我不擅长typescript和angular，所以我试图找到一些解决方案，但失败了。 有什么简单的方法吗？ 提前谢谢。 附注:我将此代码添加到我的解决方案中。谢谢爱德华 this.products$
浏览 60提问于2021-01-09得票数 0
回答已采纳
我希望能够在我的Firebase数据库中的*ngFor对象的users属性上运行一个groups。
到目前为止，我正在尝试：
<h5>{{ (group$ | async)?.name }}</h5>
<div class="gd-users-container">
<span *ngFor="let user of (group$ | async)?.users">{{ user.email }}</span>
</div>
其中group$ = getGroup(): Firebas
浏览 4提问于2017-09-11得票数 1
回答已采纳
2回答
我有一个关于在Angular 2服务中使用观察值与变量的问题。前者似乎是首选的方式，但我找不到确切的原因。
给定一个示例服务，例如：
@Injectable()
export class TestService {
// Method 1
public data = {x: Math.random(), y: Math.random()};
// Method 2
private _data$:BehaviorSubject<any> = new BehaviorSubject({x: Math.random(), y: Math.random()
浏览 13提问于2017-01-26得票数 9
你好，我有一个应用程序，包括注册和登录。我的问题是，当一个新用户登录时，我必须刷新页面才能获得当前用户。我在模板上用内插法。我试图使用一个可观察的，但我得到一个错误，说订阅不是一个函数。请有人指点我的正确方向，我相信这也会帮助我在一个类似的问题与更新。我已经包含了一段代码。
提前感谢你
报头组件
export class HeaderComponent implements OnInit {
currentUser: User;
private userSubject: BehaviorSubject<User>;
public user: Observable&
浏览 1提问于2022-05-11得票数 0
1回答
我的任务由两个步骤组成。第一步是从firestore中检索一些id数据。第二步是根据第一步中检索到的数据来检索姓名数据。因此，我为每个步骤使用了1个订阅。在我执行console.log()的代码中，正确的结果出现了，但是，当网页加载时，下拉列表是空的。 this.MessagingService.recieveGetClient().subscribe(idData => {
this.dropdownList = [];
idData.map((id: string, i: number) => {
this.VehicleService.getOwnerInf
浏览 13提问于2020-10-05得票数 0
回答已采纳
在过去的几天里，我一直在试图解决这个问题，但我没有运气。
这就是我想要做的。
我的网站为项目列表发出了一个http请求，并使用ngFor循环在主页上显示这些项目。我使用可观察到的shareReplay缓存这些结果，这样当我查看单个项时-我就不需要执行另一个网络请求了。
我的问题是，在缓存之后，我找不到从可观察的数组中提取单个项目的方法。我知道.find或.filter，但它们似乎是在最初获得可观察性时使用的，而不是在shareReplay缓存之后使用的。
下面是我的密码。
//service.ts
get allProjects() {
if (!this.c
浏览 3提问于2020-08-12得票数 0
回答已采纳
我在角8中创建父/子关系。Parrent组件调用设置可观察roleList的服务调用，然后将此roleList传递给子组件。在子组件中，我尝试订阅子组件接收的输入变量，并使用新值实例化MatDataTableSource。
问题是：子组件接收值，但组件不会重新呈现。在调用应用程序中的更改(例如:将鼠标悬停到另一个更改状态的组件)之后，它确实显示了从服务接收到的数据。
这些是构成部分：
父组件.ts:
import { Component, OnInit, ChangeDetectionStrategy } from
'@angular/core';
import { Role
浏览 3提问于2019-09-30得票数 2
回答已采纳
我可以在html中使用{status_async | async}显示一个可观察到的值。
然而，我如何测试这个可观察到的东西是否等于某物呢？
具体来说，我想使用它来分配一个类：
<div [ngClass]="{'has-danger': status_async == 'created before'}">
<input type="text">
</div>
我发现我可以用：
<div [ngClass]="{'has-danger': (status_
浏览 3提问于2016-02-21得票数 2
回答已采纳
1回答
我正在构建一个Angular2应用程序，并试图从本地json文件中获取数据。问题是我创建的服务被应用程序忽略了。控制台或终端中没有错误、警告或其他任何内容。
index.html
<!DOCTYPE html>
<html>
<head>
<base href="/">
<title>My app</title>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-wi
浏览 2提问于2017-01-05得票数 0
我有一个问题，角2/4，并得到一个(S)的具体路线。我这样做了上百次，从来没有遇到过这样的问题，从我在路由上调用的代码中可以看出，paramMap只运行了一次，但不知怎么的，它最终被调用了两次。
这就好像paramMap发出的值是相同的两倍而不是一倍。问题是，通过这种方式，我向服务器发出两个请求，发送重复的数据。
export class UserComponent implements OnInit {
user: User;
submitted: Observable<Topic[]>;
constructor(
private rou
浏览 4提问于2017-08-25得票数 3
回答已采纳
我需要创建自动完成与角材料在角8。
现在，我在ts文件中使用了以下代码：
@Input() admins: User[];
userGroupOptions: Observable<User[]>;
filterFormFG: FormGroup;
constructor(private utilService: UtilsService, private messageService: MessageService) {
this.createForm();
this.userGroupOptions = this.filterFormFG.get(
浏览 1提问于2019-08-27得票数 1
回答已采纳
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回答
我正在尝试将"ag-Grid“实现到我的项目中，并试图通过从本地JSON模拟文件中获取数据来填充它。
考虑到这是我第一次使用"ag-Grid“，而且我刚开始使用我的第六角体验，这就是我到目前为止所做的。
这是我的JSON对象的结构
{
"response": {
"code": 200,
"body": {
"email": "email@email.com",
"displayName": "User 1",
浏览 0提问于2019-01-10得票数 0
回答已采纳
我是Angular5的新手，现在我正在使用Firebase来获取数据以显示我的页面。我在谷歌上搜索了一些如何使用AngularFire从firebase获取数据的例子，但其中很多都已经过时了。最后，我想我应该使用可观察性并订阅它。
service.ts
constructor(private db: AngularFireDatabase) {
}
shows: Show[] = [];
getShows(): Show[] {
const response = (this.db.list('show/data')
浏览 13提问于2018-07-30得票数 0
根据我对异步管道的理解，它是一种在较少的行中订阅可观察到的对象的更快捷的方法。然而，我试图了解在什么情况下，我需要使用它在传统的订阅，如我的当前组件下面？
import { Component, OnInit } from '@angular/core';
import { HttpService } from "./services/http.service";
import { Main } from "./interfaces/data-interface";
@Component({
selector: 'app-root&
浏览 3提问于2022-02-14得票数 0
回答已采纳
1回答
我正在做一个角度材料类分配，其中我列出了一组维修服务和价格。用户可以检查他们想要的服务。用户单击Calculate，将弹出一个发票窗口，其中仅列出他们选择的服务和总额。我可以让我的列表出现，但我在抓取已检查的服务时遇到了问题。我使用服务中的一个观察值填充第一个列表。然后，我尝试使用管道和过滤器来抓取选中的项目。但在我的过滤器中，我得到了一个‘属性检查不存在于类型Fix[]’的错误。有人能帮上忙吗？ 代码如下： fix.ts export interface Fix {
id: number;
name: string;
price: string;
checked: bool
浏览 20提问于2019-09-09得票数 0
回答已采纳
简而言之:我有一个定期向集线器发送信号的后端。我的角度客户端根据这些信号更新UI上的数据。
什么是最好的方式来动画这些模型数据的变化？
更新：
我没有描述这些数据，因为我在很多子组件上可视化了很多不同的模型。例如，在我的“实时应用程序”中，当一个相应的信号发生时，我想动画化模型中每一个变化的属性的背景。
我无法使用浏览器动画，因为只有当数据更改发生在同一页面上，而不是信号发生时，它才能工作。
我想避免的另一件事是使用ViewChilds从.ts文件中的DOM中获取元素，并直接在它们上制作动画。
我的主要问题是数据更新动画和signalR的最佳实践是什么？
浏览 4提问于2020-09-01得票数 0
1回答
来自GraphQL的角度返回数据
、、、、
所以，我在工作的时候遇到了一个问题。我需要将一些用户数据存储在图形库中，这样我就可以使用名称(字符串)和balance (数字)，但是只有当我在HTML中调用userName和userBalance时，它才能工作，而不是在TS中，下面是我的TS组件：
public userName: Observable<string>;
public userBalance: Observable<number>;
public getUserById: string;
constructor(
private activatedRoute: ActivatedRoute,
浏览 0提问于2018-11-19得票数 0
1回答
另一个可以观察到的问题。
我正在使用angular翻译服务和Kendo.UI组件。
根据Kendo.UI ，我可以实现一个MessageService来翻译它的组件。
为此，我必须扩展一个包含返回字符串的方法的抽象类：
@Injectable()
export class MyMessageService extends MessageService {
private messages = {'kendo.upload.select': 'initial value'}
constructor(private readonly translate:
浏览 0提问于2018-02-01得票数 0
1回答
我是个新手天使。我有一个代码示例，但是创建者没有向我解释"$“是什么意思，谁能告诉我这里的blog$和onDestroy$是什么意思？或者这只是他的名字？谢谢你！ blog-details.component.ts import { Component, OnInit, OnDestroy } from '@angular/core';
import { BlogService } from '../../services/blog.service';
import { Observable, Subject } from 'rxjs'
浏览 21提问于2020-08-21得票数 3
回答已采纳
首先，我有一个服务-- ContractorsService --它有一个函数getContractors，该函数使用AngularFire方法对contractors db进行Firestore调用。
我首先使用管道对快照的结果进行switchMap，以便获取每个承包商记录的uid，并将uid属性附加到iContractor模型的其余部分，然后根据要在模板中显示的经过身份验证的userId筛选哪些承包商。
我使用另一个服务函数isContractorRecordComplete完成管道，该函数接受contractorId的一个参数，并返回Observable<number>，并将
浏览 4提问于2021-06-08得票数 0
动态调用管道转换时，Ng-select ()没有更新值，将调用用于转换选项值的eg.when服务。
我尝试同时使用- ng-option方法和ng-template方法。
Ng-option-搜索有效，但值在语言更改后不会更新。Ng-template - values在更改后更新，但搜索不起作用。
示例：
预期的结果将是选项自动更新，或者在调用管道转换时使用ng-template进行搜索。
浏览 0提问于2019-09-28得票数 1
2回答
我想用ngrx做一个语言管道。
component.html：
<p>{{1 | language: languageId | async }}</p>
语言管道：
constructor(private store:Store){}
transform(resourceId: number, languageId:number): Observable<string> {
return this.store.select(selectResource, { resourceId, languageId });
}
我的问题是，如果我更改了
浏览 5提问于2020-08-06得票数 2
回答已采纳
1回答
我正在运行一个Range13应用程序，该应用程序从表单中查询给定国家和办事处/分支机构雇员的API，然后在表中显示该列表。我使用角数据表，并包括打印和导出按钮的剪贴板，CSV，文本，excel和pdf。
在重复提交表单时，将正确显示更新的员工列表，但只将第一次提交的初始数据导出到各种选项。
<div class="container">
<div class="row">
<form class="needs-validation" role="form" (ngSubmit)="
浏览 4提问于2022-03-11得票数 0
我正在使用一个可观察的间隔，每5秒在某个组件内执行某个函数，这与我的路由配置中的路径相关。
Observable.interval(5000).subscribe(res => {
// Something happens here
});
但是，当路径更改时，我希望终止间隔。现在它继续执行任务..。
做这件事最好的方法是什么？
浏览 3提问于2016-04-30得票数 7
回答已采纳
有人知道为什么这段代码(从Subject初始化值)不起作用吗？有缺陷吗?还是故意的？我做错了什么？
ts
import { Component, OnInit } from '@angular/core';
import { Subject } from "rxjs";
@Component({
selector: 'app-root',
templateUrl: './app.component.html',
styleUrls: ['./app.component.styl']
})
export
浏览 3提问于2017-01-15得票数 18
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
