# RxJava 学习笔记未整理

首先所谓的数发送观察者和订阅者的概念

1.可观察者的概念

```

可观察者负责发送数据，并且它知道什么数据是正确的和错误的

于是进行交互

1 如果是正确的数据就传递

    2.错误的数据发送错误消息

    3.最终流程完成的时候，发送完成的信号```

##### 数据是和订阅者关联的

由数据源决定是否发送数据，结果数据如何由订阅者处理

Single只会发送一次数据，

Just 会一次性把所有的数据发送出去

From 则会分次发送

1.数组

2.iterator

3.furure

4.callable

`interval`

相隔一段时间就发送数据

`repeast`

数据重复发送N次

`timer`

在指定时间之后发送一个0

`buffer`

按照指定的参数缓存数据，达到缓存的数据的数量的时候就发送数据

`skip是指获取的数量，取出几个数字‘

比如说(1,3)是说每3个数据发送一个

(3,3)完全不过滤

（4，3）缓存为四个，这里就是说完全不跳过

将一个数据转化成另一种订阅原，然后把每个订阅原的数据整合起来成为一个订阅原

发送出去

是把多个observerable整合起来成为一个obserable，那么数据就可能发生交错

groupBy

根据key把源数据分成几个不同的Observerable

`flatMap`

`map`

`cast`

`throttleWithTimeOut`

根据时间进行过滤，时间小于一定的数据全部丢弃

`distinct`

过滤重复的数据

`distinctUntilChanged`

过滤连续的重复的数据

`elementAt`

返回在数据中位置为给定的位置的元素

`filter`

过滤数据

`first`

返回第一个满足要求的数据

`last`

满足条件的最后一条数据

`toBlockingObserverable`

`BlockingObserverable`

`skip`

过滤前n个数据

`take`

只取前n个数据

`skipLast`

`takeLast`

`sample`

取规定时间内最后一个数据

`throastFisrt`

取规定时间的第一个数据