RxJAVA notes

時間 2019-11-08

標籤 rxjava notes 欄目 Java 简体版

原文原文鏈接

注: 本文只適用於自我複習，初學者請移步連接html

經常使用模板java

rxjava2+retrofit2api

public static void main(String[] args) {
        String BASE_URL = " http://www.izaodao.com/Api/";

        okhttp3.OkHttpClient.Builder builder = new OkHttpClient.Builder();
        builder.connectTimeout(5, TimeUnit.SECONDS);

        Retrofit retrofit = new Retrofit.Builder()
                .client(builder.build())
                .addConverterFactory(GsonConverterFactory.create())
                .baseUrl(BASE_URL)
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .build();

        MyApiEndpointInterface apiService = retrofit.create(MyApiEndpointInterface.class);
        Observable<RetrofitEntity> observable = apiService.getAllVedioBy(true);
        observable.subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new DisposableObserver<RetrofitEntity>() {
                    @Override
                    public void onComplete() {
                    }
                    @Override
                    public void onError(Throwable e) {

                    }

                    @Override
                    public void onNext(RetrofitEntity retrofitEntity) {
                        System.out.println(retrofitEntity.toString());
                    }
                });
    }