发表了博客
2018/03/26 11:57

RxJS速成 (下)

上一部分: http://www.cnblogs.com/cgzl/p/8641738.html Subject Subject比较特殊, 它即是Observable又是Observer. 作为Observable, Subject是比较特殊的, 它可以对多个Observer进行广播, 而普通的Observable只能单播, 它有点像EventEmitters(事件发射器), 维护着多个注册的Listeners. 作为Observable, 你可以去订阅它,...

0
0
发表了博客
2018/11/15 16:08

RxJS--Subject

Subject是Observable(可观察对象)的子类,subject是多播的,允许将值多播给多个observer(观察者),普通observable是单播。 每一个Subject都是一个Observable(可观察对象),可以订阅(subscribe)它。 要给subject提供新值,只要调用next(theValue), 它会将值theValue多播给已注册监听该subject的观察者们。 import {Compon...

0
0
发表了博客
2019/01/02 14:18

Rxjs常用operators

本文使用的是angular6内置的rxjs,版本号为6.3.3 concat 通过顺序地发出多个 Observables 的值将它们连接起来,一个接一个的。 参数: 名称 类型 属性 描述 other ObservableInput 等待被连接的 Observable。 可以接受多个输入 Observable。 scheduler Scheduler 可选的,默认值: null 可选的调度器,控制每个输入 Observ...

0
0
发表了博客
2020/04/27 11:12

RxJS Subject学习

一个Observable的例子 import { interval } from "rxjs"; import { take } from "rxjs/operators"; const interval$ = interval(1000).pipe(take(3)); interval$.subscribe(value => console.log("Observer A get value: " + value)); setTimeout(() => { interval$.subscribe(value => console.log("Observer B ge...

0
0
发表了博客
2019/03/10 20:49

angular7 Rxjs 异步请求

Promise 和 RxJS 处理异步对比 Promise 处理异步: let promise = new Promise(resolve => { setTimeout(() => { resolve('---promise timeout---'); }, 2000); }); promise.then(value => console.log(value)); RxJS 处理异步 import {Observable} from 'rxjs'; let stream = new Observable(observer => { setTi...

0
0
发表了博客
2019/06/03 03:40

[RxJS] RxJS Advanced Patterns Operate Heavily Dynamic UIs

Check the playground. import {Counter, CountDownState, ConterStateKeys, PartialCountDownState} from './counter' import { Subject, Observable, merge, timer, NEVER, combineLatest} from 'rxjs'; import { map, mapTo, switchMap, pluck, scan, startWith,shareReplay, distinctUntilChanged, withLatestFro...

0
0
发表了博客
2018/12/06 12:32

一起来看 rxjs

更新日志 2018-05-26 校正 2016-12-03 第一版翻译 过去你错过的 Reactive Programming 的简介 你好奇于这名为Reactive Programming(反应式编程)的新事物, 更确切地说,你想了解它各种不同的实现(比如 [Rx*], [Ba...

0
0
发表了博客
2018/12/11 17:15

《深入浅出RxJS》读书笔记

rxjs的引入 // 如果以这种方式导入rxjs,那么整个库都会导入,我们一般不可能在项目中运用到rxjs的所有功能 const Rx = require('rxjs'); 解决这个问题,可以使用深链deep link的方式,只导入用的上的功能 import {Observable} from 'rxjs/Observable'; 这样可以减少不必要的依赖,不光可以优化打包文件的大小,还有利...

0
0
发表了博客
2018/07/08 01:13

[RxJS 6] The Catch and Rethrow RxJs Error Handling Strategy and the finalize Operator

Sometime we want to set a default or fallback value when network request failed. http$ .pipe( map(res => Object.values['payload']), shareReplay(), catchError(err => of([])) // return an empty value ); Sometime we want to just throw the error again: http$ .pip...

0
0
发表于大前端专区
2020/10/29 22:49

rxjs 冷热两种模式

原文链接: rxjs 冷热两种模式 https://www.cnblogs.com/starof/p/10505617.html 冷模式 类似点播模式, B站看番剧, 每次都是从头开始 每一个订阅者都单独对应一个实例, 并且只有在订阅后才会开始传送值 好处是多个...

0
0
2020/09/19 18:59

rxjs fromEvent的用法

源代码: import { of, fromEvent, interval, Observable } from 'rxjs'; import { Injectable } from '@angular/core'; import { map, switchMap } from 'rxjs/operators'; import { tap } from 'rxjs/operators......

0
0
2020/09/26 19:46

rxjs switchMap的实现原理

SwitchMap can cancel in-flight network requests. 先引用rxjs官网对SwitchMap的介绍: The main difference between switchMap and other flattening operators is the cancelling effect. On each emission th......

0
0
发表于大前端专区
2020/08/02 21:51

Rxjs异步编程的学习

1. Rxjs是ReactiveX编程理念的javascript版本。ReactiveX来自微软,它是一种针对异步数据流的编程。简单来说,它将一切数据,包括http请求,dom事件,或者普通数据等包装成流的形式,然后用强大丰富的操作符对流进...

0
0
发表于大前端专区
2020/03/17 12:10

理解 rxjs 中的 subject

已经学习了很久的 angular 了,rxjs 中的操作数也有很多都打过了照面,subject 也已经可以仿着别人的栗子,能写个大概的轮廓了,可是我真的理解了、掌握了 rxjs 中的 subject 吗? 以前有人告诉过我:在生活中学到...

2
1
发表了博客
2018/08/21 22:08

RxJS v6 学习指南

为什么要使用 RxJS RxJS 是一套处理异步编程的 API,那么我将从异步讲起。 前端编程中的异步有:事件(event)、AJAX、动画(animation)、定时器(timer)。 异步常见的问题 回调地狱(Callback Hell) 竞态条件(Race Condition) 内存泄漏(Memory Leak) 管理复杂状态(Manage Complex States) 错误处理(Exception...

0
0
发表了博客
2019/09/02 09:39

RxJS——Operators

RxJS 的操作符(operators)是最有用的,尽管 Observable 是最基本的。操作符最基本的部分(pieces)就是以申明的方式允许复杂的异步代码组合简化。 什么是操作符? 操作符是函数。这里有两种操作符: 管道操作符(Pipeable Operators)是可以通过使用 observableInstance.pipe(operator()) 管道传输到 Observable 对象。...

0
0
2020/11/04 14:22

rxjs 里的subscribeToArray.js

只有调用函数subscribeToArray的上下文,才知道array的内容到底是什么。 调用上下文,只有一个参数input传给了subscribeToArray: 因此只有在Observable构造函数里,才能打印出input的真实数据: 更多Jerry的原创...

0
0
发表于大前端专区
2020/03/18 18:13

再读《深入浅出 rxjs》的小收获

Observbale 对象可以看作一个数据集合,但这个数据集合可以不是一次产生,而是在一个时间段上逐个产生每个数据,因为这,一个 observable 对象即使产生超庞大的数据,依然不会消耗很多内存,因为每一次只产生一个...

0
1
发表了博客
2019/10/25 16:20

[RxJS] Subject asObservable() method

You can create your own state store, not using any state management libraray. You might have seen the partten: People create a Subject, then use abObservable() method. export class State { private prevState: INEO[]; private neoStoreSubject: BehaviorSubject<INEO[]>; neoStore$: Observable<...

0
0
发表了博客
2018/06/05 08:38

RxJS操作符(二)

一、Observable的性质 三种状态:nex, error, complete 进入到Error状态: const interval$ = Rx.Observable.interval(1000) .filter(val=>{ throw '出错了' }) .take(4) .reduce((x,y)=>{//reduce接收函数作为参数 return [...x,y]; },[]) interval$.subscribe( val=>console.log(val), err=>conso...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页