RxJs——创建型操作
我们在使用RxJs中，知道RxJs的操作分为两类，一类是创建型，比如of()，fromEvent()，from()等，还有一类是操作型，比如map()，filter()。如果对Observable不甚理解，需要快速理解的可以查看这一篇今天我们来学习第一类，尝试着自己实现一次。of()这个操作接收一些...
RxJs高阶运算——switchMap
上一节我们学习了mergeMap的相关知识，我们知道了在并发执行的时候，我们可以使用mergeMap来达到效果。今天我们学习另一个高阶运算符switchMap。同样的道理，我们想要学习理解switchMap，我们首先得知道什么是switch?ObservableSwitchingswitch的概念更...
RxJs高阶运算——mergeMap
上一节我们介绍了第一个高阶运算concatMap,今天我们开始学习第二个高阶运算mergeMap。同样的道理，为了掌握mergeMap,我们先了解merge。mergeMap动态图我们知道concatMap是顺序执行，有的时候我们可能需要并行执行，此时我们就要用到merge.ObservableMe...
RxJs——subject理解一
什么是subject首先我们来理解什么是subject，按照官方的定义：ASubjectisaspecialtypeofObservablethatallowsvaluestobemulticastedtomanyObservers.SubjectsarelikeEventEmitters.从定义我...
RxJs高阶运算——exhaustMap
上一节我们介绍了switchMap的特点，只要一个新的SourceObservable到来，我们就订阅新的Observable，那么可能会有另一种情况就是，我们订阅第一个SourceObservable,只有当这个Observable都完成的时候，如果之前有新的Observable到来，我们都忽略，...
RxJs高阶运算——concatMap
在我们的实际使用中，最重用的一些高阶映射运算主要有四类——concatMap,mergeMap,switchMap,exhaustMap这些高阶映射运算符在网络响应式编程中的使用非常广泛，因此理解它们很重要。但是知道在什么场景下使用这些运算符本身就十分困惑，本文就是为了解疑释惑而写，我们后续会在本节...
RxJs——错误处理（二）
从前文我们知道，错误处理有两种方式，一种是重新抛出一个错误，另一个是提供一个默认的回调值。今天我们介绍错误处理的另一些方式，先来看看重试。重试策略有一点需要记住，一旦流出现了错误，我们不能恢复它。但是没有什么能阻碍我们订阅其派生类对应的Observable，并且创建一个新的流。这种策略的工作原理是：...
RxJs——错误处理（一）
错误处理是RxJs中重要组成部分。我们在响应式编程中几乎都要使用到。然而RxJs中的错误处理不像在其他库中的错误处理那么容易理解。小窍门就是关注Observable的约定，这样就容易理解RxJs中错误处理。 今天我们介绍一些常见的错误处理策略，涵盖一些常用场景，当然还是从Observable的基础知...
初步理解RxJs
学习是一个由浅入深的过程，如果能够理解并掌握二八原则(帕累托法则)，那么我们对知识的学习定会事半功倍，甚至事半多倍。RxJs定义 RxJS是ReactiveX在JavaScript上的一个派生。ReactiveX是一个应用比较广泛的响应式编程框架，这个框架很好的应用了ObserverP...
[RxJS] map vs flatMap
What'sthedifferencebetweenmapandflatmap?First,let'sshowwhatmapis.Toshowthat,Ineedasourcestream,soI'mgoingtomakeaninterval.Ittakesatenthofasecond,andI'...
RxJS 实现摩斯密码(Morse) 【内附脑图】
参加2018ngChina开发者大会，特别喜欢MichaelHladky奥地利帅哥的RxJS分享，现在拿出来好好学习工作坊的内容（工作坊Demo地址），结合这个示例，做了一个改进版本，实现更简洁，逻辑更直观。一、摩斯密码是什么？了解者可跳过次章节摩斯密码(Morse)，是一种时通时断的信号代码，这种...
rxjs5.X系列 —— Combination/Multicasting系列 api 笔记
欢迎指导与讨论:）前言本文是笔者翻译 RxJS5.X官网各类operation操作系列的的第三篇 ——Combination组合与Multicasting广播。如有错漏，希望大家指出提醒O(∩_∩)O。更详细的资料尽在rxjs官网【http://reactivex.io/rxjs/manual/ov...
角2返回RxJs订阅的数据
I'veaservicewithanauthenticatefunction-我有一个具有认证功能的服务authenticate(username:string,password:string){letret;letpacket=JSON.stringify({username:username,p...
RxJS入门之函数响应式编程
一.函数式编程1.声明式（Declarativ）和声明式相对应的编程⽅式叫做命令式编程（ImperativeProgramming），命令式编程也是最常见的⼀种编程⽅式。//命令式编程：functiondouble(arr){constresults=[]for(leti=0;i<arr.le...
[RxJS] Transformation operators: delay and delayWhen
ThislessonsteachesaboutdelayanddelayWhen:simpleoperatorsthattimeshift.delay(number|date)varfoo=Rx.Observable.interval(500).take(5);/*--0--1--2--3--4|d...
[RxJS] Transformation operators: debounce and debounceTime
DebounceanddebounceTimeoperatorsaresimilartodelayWhenanddelay,withthedifferencethattheymaydropsomeemissions.Thislessonteachesyouhowdebounceworksandwhe...
[RxJS] Filtering operators: distinct and distinctUntilChanged
Operatordistinct()anditsvariantsareanimportanttypeofFilteringoperator.Thislessonsshowshowtheyworkandinwhatcasesaretheyuseful.distinctUntilChanged():va...
[RxJS] Filtering operators: takeLast, last
Operatorstake(),skip(),andfirst()allrefertovaluesemittedinthebeginningofanObservableexecution.Inthislessonwewillseesimilaroperatorswhichreferinsteadto...
[RxJS] Filtering operators: throttle and throttleTime
Debounceisknowntobearate-limitingoperator,butit'snottheonlyone.ThislessonsintroducesyoutothrottleTimeandthrottle,whichonlydropevents(withoutdelayingth...
ReactiveX 学习笔记（25）使用 RxJS + Vue.js 调用 REST API
JSON:PlaceholderJSON:Placeholder(https://jsonplaceholder.typicode.com/)是一个用于测试的RESTAPI网站。以下使用RxJS6+Vue.js调用该网站的RESTAPI，获取字符串以及JSON数据。GET/posts/1GET/po...