如何使用RxJava 2 + Retrofit 2发布？

implementation 'io.reactivex.rxjava2:rxjava:2.x.x'
implementation 'com.squareup.retrofit2:retrofit:2.x.x'
implementation 'com.squareup.retrofit2:adapter-rxjava2:2.x.x'

public interface ApiService {
    @GET("users/{username}")
    Observable<User> getUser(@Path("username") String username);
}

Retrofit retrofit = new Retrofit.Builder()
    .baseUrl("https://api.example.com/")
    .addConverterFactory(GsonConverterFactory.create())
    .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
    .build();

ApiService apiService = retrofit.create(ApiService.class);

apiService.getUser("john_doe")
    .subscribeOn(Schedulers.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() {
            // 在这里处理请求完成的情况
        }
    });