Rxandroid2.0 使用一

1,初始化被观察者对象，并将对象发送出去
Observable<String> observable=Observable.create(new ObservableOnSubscribe<String>() {
    @Override
    //将事件发射出去,持有观察者的对象
    public void subscribe(ObservableEmitter<String> e) throws Exception {

        try {
            Thread.sleep(1000);
        } catch (Exception ee) {

        }
        e.onNext("第一次调用");
        try {
            Thread.sleep(1000);
        } catch (Exception ee) {

        }
        e.onNext("第二次调用");
        try {
            Thread.sleep(1000);
        } catch (Exception ee) {

        }
        e.onNext("第三次调用");

        e.onComplete();
    }
});
2，观察者执行
observable.observeOn(AndroidSchedulers.mainThread())
        .subscribeOn(Schedulers.newThread())
        .subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {

            }

            @Override
            public void onNext(String value) {
                Toast.makeText(MainActivity.this, value, Toast.LENGTH_SHORT).show();
            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onComplete() {

            }
        });