RxJava的简介和简单使用

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();
}

}