使用RxJava解析JSON的主线程

Observable.create(new ObservableOnSubscribe<String>() {
    @Override
    public void subscribe(ObservableEmitter<String> emitter) throws Exception {
        // 发射JSON数据
        String json = "{'name':'John', 'age':30}";
        emitter.onNext(json);
        emitter.onComplete();
    }
})
.map(new Function<String, User>() {
    @Override
    public User apply(String json) throws Exception {
        // 解析JSON数据为User对象
        Gson gson = new Gson();
        User user = gson.fromJson(json, User.class);
        return user;
    }
})
.subscribeOn(Schedulers.io()) // 在IO线程执行数据流操作
.observeOn(AndroidSchedulers.mainThread()) // 在主线程回调观察者
.subscribe(new Observer<User>() {
    @Override
    public void onSubscribe(Disposable d) {
        // 订阅成功
    }

    @Override
    public void onNext(User user) {
        // 处理解析后的数据
    }

    @Override
    public void onError(Throwable e) {
        // 处理错误
    }

    @Override
    public void onComplete() {
        // 数据流处理完成
    }
});