RxJs高阶运算——concatMap
在我们的实际使用中，最重用的一些高阶映射运算主要有四类——concatMap,mergeMap,switchMap,exhaustMap这些高阶映射运算符在网络响应式编程中的使用非常广泛，因此理解它们很重要。但是知道在什么场景下使用这些运算符本身就十分困惑，本文就是为了解疑释惑而写，我们后续会在本节...
RxJs——subject理解一
什么是subject首先我们来理解什么是subject，按照官方的定义：A Subject is a special type of Observable that allows values to be multicasted to many Observers.Subjects are like...
RxJs——错误处理（二）
从前文我们知道，错误处理有两种方式，一种是重新抛出一个错误，另一个是提供一个默认的回调值。今天我们介绍错误处理的另一些方式，先来看看重试。重试策略有一点需要记住，一旦流出现了错误，我们不能恢复它。但是没有什么能阻碍我们订阅其派生类对应的Observable，并且创建一个新的流。这种策略的工作原理是：...
RxJs——错误处理（一）
错误处理是RxJs中重要组成部分。我们在响应式编程中几乎都要使用到。然而RxJs中的错误处理不像在其他库中的错误处理那么容易理解。小窍门就是关注Observable的约定，这样就容易理解RxJs中错误处理。 今天我们介绍一些常见的错误处理策略，涵盖一些常用场景，当然还是从Observable的基础知...
初步理解RxJs
学习是一个由浅入深的过程，如果能够理解并掌握二八原则(帕累托法则)，那么我们对知识的学习定会事半功倍，甚至事半多倍。RxJs定义 RxJS是ReactiveX在JavaScript上的一个派生。ReactiveX是一个应用比较广泛的响应式编程框架，这个框架很好的应用了O...
[RxJS] Filtering operator: single, race
Single, race both get only one emit value from the stream.Single(fn):const source = Rx.Observable.from([1,2,3,4,5]);var single = source.single( x =>...
RxJS 实现摩斯密码(Morse) 【内附脑图】
参加 2018 ngChina 开发者大会，特别喜欢 Michael Hladky 奥地利帅哥的 RxJS 分享，现在拿出来好好学习工作坊的内容（工作坊Demo地址），结合这个示例，做了一个改进版本，实现更简洁，逻辑更直观。一、摩斯密码是什么？了解者可跳过次章节摩斯密码(Morse)，是一种时通时断...
[Javascript + rxjs] Simple drag and drop with Observables
Armed with the map and concatAll functions, we can create fairly complex interactions in a simple way. We will use Observable to create a simple drag ...
[RxJS] Filtering operators: throttle and throttleTime
Debounce is known to be a rate-limiting operator, but it's not the only one. This lessons introduces you to throttleTime and throttle, which only drop...
角2返回RxJs订阅的数据
I've a service with an authenticate function - 我有一个具有认证功能的服务 authenticate(username: string, password: string) { let ret; let packet = JS...
RxJS之Subject主题 ( Angular环境 )
一 Subject主题 Subject是Observable的子类。- Subject是多播的，允许将值多播给多个观察者。普通的 Observable 是单播的。 在 Subject 的内部，subscribe 不会调用发送值的新执行。它只是将给定的观察者注册到观察者列表中，类似于其他库或语言中的 ...
TS2339: property 'of' does not exist on type 'typeof Observable' - rxjs@6.2.2
【出现的问题】 TS2339: property 'of' does not exist on type 'typeof Observable' 【解决方法】（如下代码粉色标记） 首先 import { of } from 'rxjs'; - 见下方【参考】(1) 和 import {...
RxJS入门之函数响应式编程
一.函数式编程1.声明式（Declarativ）和声明式相对应的编程⽅式叫做命令式编程（ImperativeProgramming），命令式编程也是最常见的⼀种编程⽅式。//命令式编程：function double(arr) { const results = [] for (let ...
[RxJS] Completing a Stream with TakeWhile
Subscribe can take three params:subscribe( (x)=> console.log(x), err=> console.log(err), ()=> console.log('complete') ...
如何理解 RxJS？
在 Angular 2 中，我们遇到了一个新的概念 —— RxJS。对很多人而言，这可能是一个比较难以理解的地方。所谓的难以理解并不是说 API 有多复杂，而是对于 RxJS 本身的理念就无从下手。所以，这里简单地对 RxJS 进行一些介绍。一、函数响应式编程（FRP）FRP 早在上世纪 90 年代...
[RxJS] Transformation operator: map and mapTo
We made our first operator called multiplyBy, which looks a bit useful, but in practice we don't need it because it's too specific: it only does simpl...
学习RxJS：Cycle.js
原文地址：http://www.moye.me/2016/06/16/learning_rxjs_part_two_cycle-js/是什么Cycle.js 是一个极简的JavaScript框架（核心部分加上注释125行），提供了一种函数式，响应式的人机交互接口（以下简称HCI）：函数式Cycle....
[RxJS] Using Observable.create for fine-grained control
Sometimes, the helper methods that RxJS ships with such as fromEvent, fromPromise etc don't always provide the exact values you want & you end up ...
为什么我们应该使用RxJs Of（）函数？
in service section of angular.io tutorial for angular2 I hit a method named of.for example : 在角度2的angular.io教程的服务部分，我点击了一个名为of.for的方法，例如： getHeroes():...
[RxJS] Combination operators: concat, startWith
Some Observables may complete, and we may want to append another Observable to the one which just completed. This lesson teaches you how to use the co...