RX Java android 用于改装

Question

我是 rx 的新手 java，所以你能帮忙吗？我有简单的改造实现，我正在使用它来获取有关无线电的数据。我需要每 10 秒获取一次这些数据。我知道的唯一方法是将 Service 与 AlarmManager 一起使用，但我不喜欢它。我如何使用 rx java 来做到这一点？我可以每 10 秒获取一次数据吗？下面是改造实现的代码

public class ApiProvider {
    public static final String PRODUCTION_API_URL = "http://radio.somesite.org";
    static final int DISK_CACHE_SIZE = (int) MEGABYTES.toBytes(50);
    private static ApiProvider instance;
    private Application application;

    private ApiProvider( ) {
        this.application = CApplication.getApplication();
    }

    public static ApiProvider getInstance() {
        if (instance != null)
            return instance;
        else {
            instance = new ApiProvider();
            return instance;
        }

    }

    public static OkHttpClient createOkHttpClient(Application app) {
        OkHttpClient client = new OkHttpClient();
        client.setConnectTimeout(10, SECONDS);
        client.setReadTimeout(10, SECONDS);
        client.setWriteTimeout(10, SECONDS);

        // Install an HTTP cache in the application cache directory.
        File cacheDir = new File(app.getCacheDir(), "http");
        Cache cache = new Cache(cacheDir, DISK_CACHE_SIZE);
        client.setCache(cache);

        return client;
    }

    private RestAdapter getRestAdapter() {
        Gson gson = new GsonBuilder()
                .registerTypeAdapter(DateTime.class, new DateTimeConverter())
                .create();
        OkHttpClient client = createOkHttpClient(application);

        Endpoint endpoint = Endpoints.newFixedEndpoint(PRODUCTION_API_URL);

        return new RestAdapter.Builder() //
                .setClient(new OkClient(client)) //
                .setEndpoint(endpoint) //
                .setConverter(new GsonConverter(gson)) //
                .build();
    }



    private RadioLiveInfoService getRadioInfo() {
        return getRestAdapter().create(RadioLiveInfoService.class);
    }

    private RadioWeekInfoService getRadioWeek() {
        return getRestAdapter().create(RadioWeekInfoService.class);
    }

    public void getRadioInfo(Type type, final CallbackInfoListener listener) {
        Callback callback = new Callback() {
            @Override
            public void success(Object o, Response response) {
                try {
                    LiveInfo liveInfo = (LiveInfo) o;
                    listener.dataLoaded(liveInfo, true);
                    Log.d("Success", response.toString());
                } catch (ClassCastException ex) {
                    ex.printStackTrace();
                }
            }

            @Override
            public void failure(RetrofitError retrofitError) {
                listener.dataLoaded(new LiveInfo(), false);
                Log.e("Error", retrofitError.toString());
            }
        };

        getRadioInfo().commits(type, callback);
    }

    public void getRadioWeekInfo(final CallbackWeekListener listener) {
        Callback callback = new Callback() {
            @Override
            public void success(Object o, Response response) {
                try {
                    WeekInfo weekInfo = (WeekInfo) o;
                    listener.dataLoaded(weekInfo, true);
                    Log.d("Success", response.toString());
                } catch (ClassCastException ex) {
                    ex.printStackTrace();
                }
            }

            @Override
            public void failure(RetrofitError retrofitError) {
                listener.dataLoaded(new WeekInfo(), false);
                Log.e("Error", retrofitError.toString());
            }
        };

        getRadioWeek().commits(callback);
    }

}

提前致谢

Answer 1

我就是这样工作的。我仍然需要了解如何使用复合订阅来做到这一点。

RadioLiveInfoObservableService radioLiveInfoObservableService=ApiProvider.getInstance().getRadioObserverInfo();
radioLiveInfoObservableService.commits(Type.INTERVAL)
        .observeOn(AndroidSchedulers.mainThread())
        .doOnError(trendingError)
        .onErrorResumeNext(Observable.<LiveInfo>empty()).subscribe(new Action1<LiveInfo>() {
    @Override
    public void call(LiveInfo liveInfo) {
        List<Current> currents=new ArrayList<Current>();
        currents.add(liveInfo.getCurrent());
        adapter.currentShows=currents;
        adapter.notifyDataSetChanged();
        rv.setAdapter(adapter);
    }
});

Answer 2

我就是这样用的

fun getEventDetails(eventId: Long) : MutableLiveData<Response> {
    Log.d("Retrofit", "Get event detail")
    compositeDisposable.add(useCase.getEvents()
            .repeatWhen {
                return@repeatWhen it.delay(10, TimeUnit.SECONDS) //Repeat every 10 seconds
            }
            .repeatUntil {
                return@repeatUntil repeat //Boolean
            }
            .map(this::parseResponse)
            .subscribeOn(Schedulers.io())
            .unsubscribeOn(AndroidSchedulers.mainThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe({
                dashboardResponse.postValue(Response().success(it))
            }, {
                Timber.d(it.message)
                dashboardResponse.postValue(Response().error(it.getRetrofitErrorMessage()))
            })
    )

    return dashboardResponse

}

和API方法是：

 @GET("events")
fun getEvents(): Observable<String>

RX Java android 用于改装

RX Java android for retrofit

android

rx-java

retrofit