规范部分Thread

This commit is contained in:
kehaoyuan
2017-05-19 10:47:43 +08:00
parent 5865fdbd23
commit 0c1b48cee2
8 changed files with 99 additions and 79 deletions

View File

@ -623,25 +623,20 @@ public class MainActivity extends BaseActivity implements OnClickListener {
}
});
} else {
new Thread() {
@Override
public void run() {
TokenUtils.getToken(MainActivity.this, true)
.flatMap(new Func1<String, Observable<List<String>>>() {
@Override
public Observable<List<String>> call(String token) {
return RetrofitManager.getUser().getConcern(token);
}
}).subscribeOn(Schedulers.io())
.observeOn(Schedulers.io())
.subscribe(new Response<List<String>>() {
@Override
public void onResponse(List<String> response) {
getConcernDigest(response);
}
});
}
}.start();
TokenUtils.getToken(MainActivity.this, true)
.flatMap(new Func1<String, Observable<List<String>>>() {
@Override
public Observable<List<String>> call(String token) {
return RetrofitManager.getUser().getConcern(token);
}
}).subscribeOn(Schedulers.io())
.observeOn(Schedulers.io())
.subscribe(new Response<List<String>>() {
@Override
public void onResponse(List<String> response) {
getConcernDigest(response);
}
});
}
}