首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

如何在两个Angular 2订阅完成后调用函数?

在Angular 2中,可以使用rxjs库来处理订阅和异步操作。要在两个订阅完成后调用函数,可以使用rxjs的combineLatest操作符或forkJoin操作符。

  1. 使用combineLatest操作符: combineLatest操作符会在所有的Observable都发出至少一个值后,将每个Observable的最新值作为参数传递给回调函数。可以通过使用take(1)来确保只有第一个值被发出。
代码语言:typescript
复制

import { combineLatest } from 'rxjs';

const observable1 = ...; // 第一个Observable

const observable2 = ...; // 第二个Observable

combineLatest(observable1, observable2).pipe(

代码语言:txt
复制
 take(1)

).subscribe((value1, value2) => {

代码语言:txt
复制
 // 在两个Observable都发出至少一个值后调用的函数
代码语言:txt
复制
 // 可以在这里执行你的逻辑

});

代码语言:txt
复制
  1. 使用forkJoin操作符: forkJoin操作符会等待所有的Observable都完成后,将每个Observable的最后一个值作为参数传递给回调函数。可以通过使用take(1)来确保只有最后一个值被发出。
代码语言:typescript
复制

import { forkJoin } from 'rxjs';

const observable1 = ...; // 第一个Observable

const observable2 = ...; // 第二个Observable

forkJoin(observable1, observable2).pipe(

代码语言:txt
复制
 take(1)

).subscribe((value1, value2) => {

代码语言:txt
复制
 // 在两个Observable都完成后调用的函数
代码语言:txt
复制
 // 可以在这里执行你的逻辑

});

代码语言:txt
复制

以上是使用rxjs库来在两个Angular 2订阅完成后调用函数的方法。请注意,rxjs库是Angular的核心依赖之一,因此无需额外安装。对于更多关于rxjs的详细信息和用法,请参考rxjs官方文档

页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

Vue.js快速入门

作为前端的三大框架之一(其他两个Angular、React),Vue得到了大多前端开发者的青睐,最新版本为2.4.4 。...Watcher 订阅者, 作为连接 Observer 和 Compile 的桥梁,能够订阅并收到每个属性变动的通知,执行指令绑定的相应回调函数。...Dep 消息订阅器,内部维护了一个数组,用来收集订阅者(Watcher),数据变动触发notify 函数,再调用订阅者的 update 方法。...当数据发生变化时,Observer 中的 setter 方法被触发,setter 会立即调用Dep.notify(),Dep 开始遍历所有的订阅者,并调用订阅者的 update 方法,订阅者收到通知后对视图进行相应的更新...2,安装cnpm 安装完node之后,npm包含的很多依赖包是部署在国外的,为了加快依赖包的加载速度,开发中一般选择使用国内的镜像。

2.2K90
  • Angular实战之使用NG-ZORRO创建一个企业级中后台框架(进阶篇)

    前言:   上一篇文章我们讲了如何在创建的Angular项目中快速引入ng-zorro-antd企业中台组件库,并且快速构建后台管理页面框架模板。...这一章主要介绍的是如何在创建好的后台管理页面框架的快速生成NG-ZORRO相关的组件,并且介绍Angular相关目录结构、生命周期函数,路由配置和使用相关知识点,以及如何使用Angular CLI使用一行代码快速添加...生命周期钩子详解:https://angular.cn/guide/lifecycle-hooks 当 Angular 使用构造函数新建一个组件或指令后,就会按下面的顺序在特定时刻调用这些生命周期钩子方法...在这儿反订阅可观察对象和分离事件处理器,以防内存泄漏。 在 Angular 销毁指令/组件之前调用。...2、配置首页组件路由(多模块路由完美解决): 首先,我们的博客项目存在博客管理和用户管理两个核心模块,我们创建了两个模块,那么我们如何在【app-routing.module.ts】应用路由文件中配置多个模块的路由

    4K20

    Vue.js简介

    作为前端的三大框架之一(其他两个Angular、React),Vue得到了大多前端开发者的青睐,最新版本为2.4.4 。...Watcher 订阅者, 作为连接 Observer 和 Compile 的桥梁,能够订阅并收到每个属性变动的通知,执行指令绑定的相应回调函数。...Dep 消息订阅器,内部维护了一个数组,用来收集订阅者(Watcher),数据变动触发notify 函数,再调用订阅者的 update 方法。...当数据发生变化时,Observer 中的 setter 方法被触发,setter 会立即调用Dep.notify(),Dep 开始遍历所有的订阅者,并调用订阅者的 update 方法,订阅者收到通知后对视图进行相应的更新...2,安装cnpm 安装完node之后,npm包含的很多依赖包是部署在国外的,为了加快依赖包的加载速度,开发中一般选择使用国内的镜像。

    5.6K70

    Angular的12个经典问题,看看你能答对几个?(文末附带Angular测试)

    它是如何在Angular 2中工作的? Angular 2不具有双向digest cycle,这是与Angular 1不同的。...如何在Angular 2应用程序中使用codelyzer? 所有企业应用程序都会遵循一组编码惯例和准则,以更好的方式维护代码。...如何在Angular 2中启用延迟加载? 大多数企业应用程序包含用各式各样的用于特定业务案例的模块。捆绑整个应用程序代码并完成加载,会在初始调用时,产生巨大的性能开销。...Observable类似于(在许多语言中的)Stream,当每个事件调用回调函数时,允许传递零个或多个事件。...如果服务器的HTTP请求结果或其它一些异步操作不再需要,则Observable的订阅者可以取消订阅,而Promise将最终调用成功或失败的回调,即使你不需要通知或其提供的结果。

    17.3K80

    彻底搞懂RxJS中的Subjects

    Observable才能开始计数,这与调用函数的方式相同。...同样类似于函数,第二个"调用"将触发新的独立执行。如果两秒钟后再次订阅此Observable,我们将在控制台中看到两个"计数器",第二个计数器有两秒钟的延迟。...有时,我们需要在订阅该对象之前,知道该对象最后一次发射了哪个值。例如,如果我们发出日期,情况就是这样。任何在3月1日订阅的观察者,无论何时订阅,都将获得3月1日的订阅。...由于ReplaySubject保留了最后两个值,第二个观察者立即收到1和2。 AsyncSubject 使用AsyncSubjects,在主题完成之前,观察者实际上什么也没收到。...在AsyncSubject完成后订阅的任何观察者将收到相同的值。

    2.6K20

    vue响应式原理(数据双向绑定的原理)

    比如说,Angular,它两个版本都是强主张的,如果你用它,必须接受以下东西: - 必须使用它的模块机制 - 必须使用它的依赖注入 - 必须使用它的特殊形式定义组件(这一点每个视图框架都有...比如React,它也有一定程度的主张,它的主张主要是函数式编程的理念,比如说,你需要知道什么是副作用,什么是纯函数,如何隔离副作用。它的侵入性看似没有Angular那么强,主要因为它是软性侵入。...Vue可能有些方面是不如React,不如Angular,但它是渐进的,没有强主张,你可以在原有大系统的上面,把一两个组件改用它实现,当jQuery用;也可以整个用它全家桶开发,当Angular用;还可以用它的视图...然后,需要compile解析模板指令,将模板中的变量替换成数据,接着初始化渲染页面视图,并将每个指令对应的节点绑定更新函数,添加监听数据的订阅者。...接着,Watcher订阅者是Observer和Compile之间通信的桥梁,主要负责: 1)在自身实例化时,往属性订阅器(Dep)里面添加自己 2)自身必须有一个update

    2.7K40

    响应式脑电波 — 如何使用 RxJS、Angular、Web 蓝牙以及脑电波头戴设备来让我们的大脑做一些更酷的事

    虽然它能够教会你如何平静下来,但对我来说,只有弄清楚如何在网页上消费这些数据后,我才能平静下来!...它配备了4个脑电波电极:2个在前额,眼睛稍微往上一些,另外2个与耳朵接触。此外,它还配备了螺旋仪和加速计,这样可以计算出头的方位。...我本可以让用户注册一个 JavaScript 函数,每当接收到新数据时便调用函数,但我最后决定使用 RxJS 库 (JavaScript 的响应式扩展库),它包括用于转换,组合和查询数据流的各种方法。...测量的信号是大脑活动的副作用,可用于检测一般心理状态 (浓度水平、突发刺激的检测,等等)。...简单来说,每当一个新项到达时,switchMap 会抛弃前一个流并调用给定的函数来产生新的流。

    2.3K80

    RxJS Subject

    我们可以使用日常生活中,期刊订阅的例子来形象地解释一下上面的概念。期刊订阅包含两个主要的角色:期刊出版方和订阅者,他们之间的关系如下: 期刊出版方 —— 负责期刊的出版和发行工作。...在观察者模式中也有两个主要角色:Subject(主题)和 Observer (观察者),它们分别对应例子中的期刊出版方和订阅者。...上面的示例,我们可以简单地认为两次调用普通的函数,具体参考以下代码: function interval() { setInterval(() => console.log('..'), 1000)...error —— 运行中出现异常,error 方法会被调用。 complete —— Subject 订阅的 Observable 对象结束后,complete 方法会被调用。...因为 Subject 对象没有再调用 next() 方法。但很多时候我们会希望 Subject 对象能够保存当前的状态,当新增订阅者的时候,自动把当前最新的值发送给订阅者。

    2K31

    AngularDart 4.0 高级-生命周期钩子 顶

    生命周期序列 通过调用其构造函数创建组件/指令后,Angular在特定时刻按以下顺序调用生命周期钩子方法: 钩子 作用和时机 ngOnChanges Angular(重新)设置数据绑定输入属性时响应。...取消订阅observables并分离事件处理程序以避免内存泄漏。 在Angular摧毁指令/组件之前调用。 其他生命周期挂钩 其他Angular子系统除了这些组件钩子可能有自己的生命周期钩子。...Angular团队负责人Misko Hevery解释了为什么您应该避免使用复杂的构造函数逻辑。 不要在组件构造函数中获取数据。您不应该担心当在测试下创建或决定显示之前时新组件会尝试联系远程服务器。...Angular的单向数据流规则禁止在视图组成之后更新视图。 组件视图组合完成后,这两个钩子都会触发。 如果钩子立即更新组件的数据绑定comment属性,Angular会抛出一个错误(尝试它!)。...回想一下,在调用AfterView钩子之前,Angular调用了AfterContent的两个钩子。 在完成该组件的视图之前,Angular会完成投影内容的组合。

    6.2K10

    纯前端控件集 WijmoJS 2018V2发布,在React、Vue和Angular中更易用

    WijmoJS 现在拥有了用于创建和自定义前端控件的设计器,包含两个beta版本,一个是与Visual Studio Code完美融合的设计器、另一个则是在线Web设计器,提供实时预览和编辑页面属性的功能...配置完成后,可以将生成的代码复制到自己的应用程序中。...与顶级组件互补的子组件,定义FlexGrid列的wjc-flex-grid-column组件,作为它们所代表的WijmoJS 类的包装器。...JavaScript代码可以使用本机Element.addEventListener('event',handler)方法为WijmoJS控件事件订阅处理程序。...随着新版本上线,WijmoJS 添加了Web Components In Angular示例,演示了如何在Angular应用程序中使用 WijmoJS Web组件。

    7K20

    AngularDart 4.0 高级-管道 顶

    ~locale.en"> 内置管道 Angular附带一系列管道,DatePipe,UpperCasePipe,LowerCasePipe,CurrencyPipe,PercentPipe...不纯的AsyncPipe Angular AsyncPipe是一个不纯管道的有趣例子。 AsyncPipe接受Future或Stream作为输入并自动订阅输入,最终返回发出的值。...该组件不必订阅异步数据源,提取已解析的值并将其公开以进行绑定,并且必须在其销毁时取消订阅(内存泄漏的有效来源)。 不纯的缓存管道 再写一个不纯的管道,一个发出HTTP请求的管道。...纯函数处理输入并返回值,但没有可检测到的副作用。 给定相同的输入,他们应该总是返回相同的输出。 本页前面讨论的管道是用纯函数实现的。 内置的DatePipe是一个纯函数实现的纯管道。...当Angular每秒钟多次调用这些管道方法时,即使是中等大小的列表,用户体验也会严重降级。 filter和orderBy经常被滥用在Angular 1应用程序中,导致投诉Angular本身很慢。

    6.4K20

    耽误你的十分钟,让MVVM原理还给你

    既然来了就继续看看吧 这篇文章其实没有什么鸟用,只不过对于现在的前端面试而言,已经是一个被问烦了的考点了 既然是考点,那么我就想简简单单的来给大家划一下重点 众所周知当下是MVVM盛行的时代,从早期的Angular...我们来进入今天的主题 划重点 MVVM 双向数据绑定 在Angular1.x版本的时候通过的是脏值检测来处理 而现在无论是React还是Vue还是最新的Angular,其实实现方式都更相近了 那就是通过数据劫持...发布订阅 发布订阅主要靠的就是数组关系,订阅就是放入函数,发布就是让数组里的函数执行 // 发布订阅模式 订阅和发布 [fn1, fn2, fn3] function Dep() { //...... // 替换的逻辑 node.textContent = txt.replace(reg, val).trim(); // 监听变化 // 给Watcher再添加两个参数...// 如果是函数直接就会调get方法 // 如果是对象的话,手动调一下get方法即可 // :sum(

    1.1K30

    (转) 别再对 Angular 表单的 ControlValueAccessor 感到迷惑

    input,textarea 进行交互,并且很有可能需要自定义一个表单控件作为 Angular 组件而不是使用原生表单控件,而通常自定义表单控件会封装一个使用纯 JS 写的控件 jQuery UI's...本文我将使用原生表单控件术语来区分 Angular 特定的 formControl 和你在 html 使用的表单控件,但你需要知道任何一个自定义表单控件都可以和 formControl 指令进行交互,而不是原生表单控件...另外,这个接口还定义两个重要方法——writeValue 和 registerOnChange (译者注:可查看 Angular 源码这一行): interface ControlValueAccessor...setUpControl 函数来让表单控件和DefaultValueAccessor 实现交互(译者注:意思就是上面代码中绑定的 formControl 指令,在其自身实例化时,会调用 setUpControl...() 函数给同样绑定到 input的 DefaultValueAccessor 指令做好安装工作, L85,这样 formControl 指令就可以借助 DefaultValueAccessor 来和

    3.8K20
    领券