defer操作符

defer() 是一个创建操作符，它会一直等待直到有观察者订阅它，才使用Observable工厂方法生成一个Observable，并且为每个观察者创建一个新的Obserable。

正题

先来看个例子：

  public class SomeType {  
      private String value;
      public void setValue(String value) {
            this.value = value;
      }
      public Observable<String> valueObservable() {
            return Observable.just(value);
      }
      public static void main(String[] args) {
            SomeType some = new SomeType();
            Observable<String> observable = some.valueObservable();
            some.setValue("小龙虾");
            observable.subscribe(new Consumer<String>() {
                  @Override
                  public void accept(String s) throws Exception {
                          System.out.println("s == " + s);
                  }
            });
       }
   }

在上面的代码中，我先创建了Observable，然后再给SomeType对象赋值，最后订阅一个观察者来获取SomeType对象的value。可能我们所期望的是打印出小龙虾三个字，然而却直接抛了个空指针出来。

just()、fromXXX()，以及其他的Observable创建方法都是在创建的时候存储数据，而不是在被订阅的时候。在这个例子中，我所期望的是无论何时请求valueObservable()方法，都能返回单前的value。

当你处于此种尴尬场景的时候，可能你会这么做：

public Observable<String> valueObservable() {
    return Observable.create(new ObservableOnSubscribe<String>() {
        @Override
        public void subscribe(ObservableEmitter<String> e) throws Exception {
            e.onNext(value);
            e.onComplete();
        }
    });
}

这样做，确实达到了订阅的时候才创建Observable。

defer()操作符便是把细节封装了起来，让使用更加方便，更加简单：

public Observable<String> valueObservable(){
    return Observable.defer(new Callable<ObservableSource<? extends String>>() {
        @Override
        public ObservableSource<? extends String> call() throws Exception {
            return Observable.just(value);
        }
    });
}

深入

当你想在一个方法中将数据写入disk，并且返回此数据，可以通过defer() 来实现：

 public Observable<SomeType> createSomeType(String value) {  
        return Observable.defer(() -> {
               SomeType someType = new SomeType();
               someType.setValue(value);

               try {
                      db.writeToDisk(someType);
               }
               catch (IOException e) {
                    return Observable.error(e);
               }

              return Observable.just(someType);
    });
}