参见： 这一节解释ConnectableObservable 和它的子类以及它们的操作符： ConnectableObservable.connect( ) — 指示一个可连接的Observable开始发射数据 Observable.publish( ) — 将一个Observable转换为一个可连接的Observable Obser...

window signature: window(windowBoundaries: Observable): Observable Observable of values for window of time. Examples Example 1: Open window specified by inner observable Addi...

refCount refCount 将可被连接的 Observable 转换为普通 Observable 可被连接的 Observable 和普通的 Observable 十分相似，不过在被订阅后不会发出元素，直到 connect 操作符被应用为止。这样一来你可以控制 Observable 在什么时候开始 发出元素。 ref...

MobX API参考 核心API 创建 observables observable(value) @observable property = value observable.box(value) & observable.shallowBox(value) observable.object(value) & observable....

Single 介绍 Single的操作符 操作符图示 Single 介绍 RxJava（以及它派生出来的RxGroovy和RxScala）中有一个名为Single 的Observable变种。 Single类似于Observable，不同的是，它总是只发射一个值，或者一个错误通知，而不是发射一系列的值。 因此，不同于Observable...

Examples 计算变量 简单 UI 绑定 自动完成 Examples 计算变量 简单 UI 绑定 自动完成 更多例子 Playgrounds 计算变量 首先，让我们从一些必要的代码开始。 这个例子的目的是如果条件满足，将 a 和 b 计算后的值绑定到 c 上。 下面就是必要的代码示例： // this is s...

Installation and Setup ES6 Install Setup GOTCHA CommonJS Install Setup CDN or ES5 Installation and Setup The content for this chapter is taken from the offical docs but...

windowWhen signature: windowWhen(closingSelector: function(): Observable): Observable Close window at provided time frame emitting observable of collected values from source. Ex...

Buffer buffer(count) buffer(count, skip) buffer(bufferClosingSelector) buffer(boundary) buffer(bufferOpenings, bufferClosingSelector) buffer(timespan, unit[, scheduler]) buff...

partition 签名: partition(predicate: function: boolean, thisArg: any): [Observable, Observable] Split one observable into two based on provided predicate. 示例 示例 1: 分割偶数和奇数 示例 2: ...