创建 observable 数据结构和 reactions(反应) Atoms Reactions(反应) 创建 observable 数据结构和 reactions(反应) Atoms 在某些时候，你可能想要有更多的数据结构或其他可以在响应式计算中使用的东西(如流)。要实现这个其实非常容易，使用 Atom 类即可。Atom 可以用来通知 ...

gRPC Installation Overview Options Sample gRPC service Client Example gRPC Streaming Streaming sample Subject strategy Call stream handler gRPC Metadata gRPC gRPC is...

Components Application architecture with components Aggregation of responsibility Distribution of concrete responsibilities Cross-communication in single-purpose components The...

ElementAt elementAtOrDefault ElementAt 只发射第N项数据 ElementAt 操作符获取原始Observable发射的数据序列指定索引位置的数据项，然后当做自己的唯一数据发射。 RxJava将这个操作符实现为elementAt ，给它传递一个基于0的索引值，它会发射原始Observable数据序列对...

reduce 演示 reduce 持续的将 Observable 的每一个元素应用一个函数，然后发出最终结果 reduce 操作符将对第一个元素应用一个函数。然后，将结果作为参数填入到第二个元素的应用函数中。以此类推，直到遍历完全部的元素后发出最终结果。 这种操作符在其他地方有时候被称作是 accumulator ，aggregate...

Maybe 如何创建 Maybe Maybe Maybe 是 Observable 的另外一个版本。它介于 Single 和 Completable 之间，它要么只能发出一个元素，要么产生一个 completed 事件，要么产生一个 error 事件。 发出一个元素或者一个 completed 事件或者一个 error 事件 不...

存取器技术 语法 监听变化 存取器技术 存取器技术现在是热点。因为需要 ES5 getter/ setter 功能而未受广泛支持，但是它因语法优雅而弥补了这个弱点。 语法 定义提供者需要特殊的语法。简单的提供者对象必须被传入 observable 函数，这个函数可以用来把提供者对象转化为一个被监听的对象。 const provider...

(@)computed @computed computed 调节器 计算值的 setter computed(expression) 函数 computed 的选项 @computed.struct 用于比较结构 @computed.equals 用于自定义比较 内置比较器 错误处理 (@)computed egghe...

Enhancing Search with switchMap A Quick Example What is switchMap? Enhanced Search with switchMap Further Resources Enhancing Search with switchMap There is a problem with ...

transformDataFrame() function transformDataFrame() function transformDataFrame() function transformDataFrame() function Apply configured transformations to the input data Sig...