RxJava的简介和简单使用

原创
2016/12/14 13:48
阅读数 83

RxJava简介:

http://gank.io/post/560e15be2dca930e00da1083#toc_1

实例:

public class MainActivity extends Activity {
 
  private Subscription subscription;
 
  @Override
  protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
 
    subscription = Observable
        .fromCallable(new Callable<Object>() {
          @Override
          public Object call() throws Exception {
            return doSomeStuff();
          }
        })
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Action1<Object>() {
          @Override
          public void call(Object o) {
            // adapt contents
          }
        });
  }
 
  private Object doSomeStuff() {
    //do something to get result
    return new Object();
  }
 
  @Override
  protected void onDestroy() {
    subscription.unsubscribe();
    super.onDestroy();
  }
 
}

注意如果我们没有unsubscribe Subscription那么仍然可能会出现内存泄漏。

 

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部