1.create

代码：

Observable.create(new ObservableOnSubscribe<String>() {
                    @Override
                    public void subscribe(ObservableEmitter<String> emitter) throws Exception {
                        for (int i = 0; i < 10; i++) {
                            emitter.onNext(String.valueOf(i));
                        }
                        emitter.onComplete();
                    }
                })
                .subscribe(new Observer<String>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }

                    @Override
                    public void onNext(String s) {
                        Log.d(TAG, s);
                    }

                    @Override
                    public void onError(Throwable e) {

                    }

                    @Override
                    public void onComplete() {
                        Log.d(TAG, "complete");
                    }
                });
    }

输出：

 通过subscribe去订阅ObservableOnSubscribe里面内容的变化

格式，Observable 被观察者
           ObservableOnSubscribe 观察者与被观察者的桥接(事件发射器)

           ObServer 观察者

           被观察者.create(观察者与被观察者的桥接).subscribe(观察者)

2.just 和 fromIterable

Observable.fromIterable(list)
                //just("1","2")
                .subscribe(new io.reactivex.Observer<String>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }

                    @Override
                    public void onNext(String strings) {
                        Log.i("aaaa= ", strings);
                    }

                    @Override
                    public void onError(Throwable e) {

                    }

                    @Override
                    public void onComplete() {
                        Log.i("aaaa= " ,"onComplete");
                    }
                });

fromIterable把list输出，相当于循环，just 意思相当

3.timer()操作符

Observable.timer(2, TimeUnit.MICROSECONDS)
                .subscribe(new Consumer<Long>() {
                    @Override
                    public void accept(Long aLong) throws Exception {
                        Log.i("aaaa= " ,aLong + "");
                    }
                });

跟handle的定时差不多意思，延迟指定时间发送一个0数值(Long类型)

timer操作符主要运行在一个新线程中，也可以自定义线程调度器(第三个参数)

4.interval() 定时器

  Observable.interval(1, TimeUnit.SECONDS)
                .subscribe(new Consumer<Long>() {
                    @Override
                    public void accept(Long aLong) throws Exception {
                        Log.d("aaaa=" ,"accept=" + String.valueOf(aLong));//从0开始输出
                    }
                });

 定时accept方法

5.intervalRange() 操作符

/**
         *  参数1：起始发送值
         *  参数2：发送数量
         *  参数3：首次发送延迟事件
         *  参数4：每次发送事件间隔
         *  参数5：时间单位
         *
         */

Observable.intervalRange(1, 6, 2, 1, TimeUnit.SECONDS)
                .subscribe(new Consumer<Long>() {
                    @Override
                    public void accept(Long aLong) throws Exception {
                        Log.d("aaaa=", String.valueOf(aLong));//从2开始输出
                    }
                });

 定时interval的进阶版

6、fromArray() 操作符

Observable.fromArray(list)
                .subscribe(new io.reactivex.Observer<List<String>>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }

                    @Override
                    public void onNext(List<String> strings) {
                        Log.i("aaaa=" , strings.toString());
                    }

                    @Override
                    public void onError(Throwable e) {

                    }

                    @Override
                    public void onComplete() {
                        Log.i("aaaa=" , "onComplete");
                    }
                });

输出 ，对一个数组集合进行观察，把数组一次性发给观察者，只会执行一次观察者的onNext，最后默认执行onComplete方法

aaaa=: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9]
onComplete

7.Range() 操作符

Observable.range(4, 6)
                .subscribe(new Consumer<Integer>() {
                    @Override
                    public void accept(Integer integer) throws Exception {
                        Log.d("aaaa=", String.valueOf(integer));//从4开始输出 4 5 6 7 8 9 6位
                    }
                });

作用发送指定范围的序列，可指定范围.作用类似intervalRange，但不同的是range是无延迟发送