创建类继承HystrixObservableCommand泛型是String 重写里面方法。 返回的类型就是 Observable,返回的就是它 初始化name属性和构造方法 这是哦我们讲隔离的时候,会用到的东西,为了减少那时候的代码量,所以这里提前做个预留, 那么我们返回呢?要返回Observab ...
分类:
其他好文 时间:
2020-05-01 11:13:52
阅读次数:
69
一个Observable的例子 输出 可以看到 Observable 对象可以被重复订阅。 Observable 对象每次被订阅后,都会重新执行。 一个Subject的例子 输出 可以看到 Subject 是 Observable 对象。 Subject 是保持内部状态的 Observable 对象 ...
分类:
Web程序 时间:
2020-04-26 20:32:52
阅读次数:
87
take 仅仅从 Observable 中发出头 n 个元素 通过 take 操作符你可以只发出头 n 个元素。并且忽略掉后面的元素,直接结束序列。 let disposeBag = DisposeBag() Observable.of("🐱", "🐰", "🐶", "🐸", "🐷", " ...
分类:
其他好文 时间:
2020-04-12 11:05:10
阅读次数:
97
timeout 如果源 Observable 在规定时间内没有发出任何元素,就产生一个超时的 error 事件 如果 Observable 在一段时间内没有产生元素,timeout 操作符将使它发出一个 error 事件。 timer 创建一个 Observable 在一段延时后,产生唯一的一个元素 ...
分类:
其他好文 时间:
2020-04-12 10:30:40
阅读次数:
77
sample 不定期的对 Observable 取样 sample 操作符将不定期的对源 Observable 进行取样操作。通过第二个 Observable 来控制取样时机。一旦第二个 Observable 发出一个元素,就从源 Observable 中取出最后产生的元素。 scan 持续的将 O ...
分类:
其他好文 时间:
2020-04-12 07:50:09
阅读次数:
71
from 将其他类型或者数据结构转换为 Observable 当你在使用 Observable 时,如果能够直接将其他类型转换为 Observable,这将是非常省事的。from 操作符就提供了这种功能。 将一个数组转换为 Observable: let numbers = Observable.f ...
分类:
其他好文 时间:
2020-04-12 07:46:17
阅读次数:
58
Observable & Observer 既是可监听序列也是观察者 有一部分非常特别的序列。它们既是可监听序列也是观察者 textField的当前文本。它可以看成是由用户输入,而产生的一个文本序列。也可以是由外部文本序列,来控制当前显示内容的观察者: // 作为可监听序列 let observab ...
分类:
其他好文 时间:
2020-04-11 22:08:50
阅读次数:
74
使用HttpClient.get等方法进行http请求,一般都是返回的一个Observable,给上层进行订阅处理 将响应转成响应的Model类,可以直接在HttpClient.get中指定,如果有特殊处理(比如只要响应中的一部分),那么可以在返回的Observable后继续使用pipe、map等方 ...
分类:
Web程序 时间:
2020-03-26 15:17:53
阅读次数:
281
interval和timer:定时产生数据 interval的参数是1000,在1秒的时刻吐出0,2s吐出1,3s吐出2,........ 这个数据流不会完结,因为interval不会主动调用下游的complete,要想停止这个数据的序列,必须要做退订的动作。 import { Observable ...
分类:
Web程序 时间:
2020-03-03 10:48:41
阅读次数:
79
注意: 安装了 npm install rxjs@6.5.4 --save 如果按照以下方法调用of方法:会报错找不到of方法的错误。 import React from 'react'; import { Observable } from 'rxjs'; import 'rxjs/add/obs ...
分类:
Web程序 时间:
2020-03-02 10:38:09
阅读次数:
149