构建一个动态的可监听树 构建一个动态的可监听树 迄今为止，我们的模型在单层数据结构运行得很好，但是要求我们手工把每个新对象-值属性封装为可监听。例如，如下代码将不能按预期运行。 const person = observable ({ data : { name : 'John' }}) function print ...

retry 演示 1 演示 2 retry 如果源 Observable 产生一个错误事件，重新对它进行订阅，希望它不会再次产生错误 retry 操作符将不会将 error 事件，传递给观察者，然而，它会从新订阅源 Observable ，给这个 Observable 一个重试的机会，让它有机会不产生 error 事件。retr...

startWith signature: startWith(an: Values): Observable Emit given value first. Examples Example 1: startWith on number sequence Example 2: startWith for initial scan value Exa...

Operators time interval timer delay Business case sample Business case debounceTime Business case throttleTime buffer Business case Model in Rxjs Operators time Thi...

编写异步 Actions (动作) Promises runInAction 工具函数 async / await flows 编写异步 Actions (动作) action 包装/装饰器只会对当前运行的函数作出反应，而不会对当前运行函数所调用的函数（不包含在当前函数之内）作出反应！这意味着如果 action 中存在 setTimeou...

拦截器 基础 截取之前/之后 响应映射 异常映射 stream 重写 拦截器 拦截器是@Interceptor () 装饰器注解的类。拦截器应该实现 NestInterceptor 接口。 拦截器具有一系列有用的功能，这些功能受面向切面编程（AOP）技术的启发。它们可以： 在函数执行之前/之后绑定额外的逻辑 转换从函数返回的结...

window window 将 Observable 分解为多个子 Observable ，周期性的将子 Observable 发出来 window 操作符和 buffer 十分相似，buffer 周期性的将缓存的元素集合发送出来，而 window 周期性的将元素集合以 Observable 的形态发送出来。 buffer ...

Build a streaming data source plugin Build a streaming data source plugin This guide explains how to build a streaming data source plugin. This guide assumes that you’re alread...

Build a streaming data source plugin Build a streaming data source plugin This guide explains how to build a streaming data source plugin. This guide assumes that you’re alread...

作者 介绍 View Reactor 示例 作者 Jeon Suyeol 是 ReactorKit 的作者。他也发布了一些富有创造性的框架，如 Then ，URLNavigator ，SwiftyImage 以及一些开源项目 RxTo...