pda/zhuike/src/main/java/com/novelbook/android/netsubscribe/BookSubscribe.java

package com.novelbook.android.netsubscribe;

import com.novelbook.android.netutils.HttpMethods;

import java.util.HashMap;
import java.util.Map;

import io.reactivex.Observable;
import io.reactivex.observers.DisposableObserver;
import okhttp3.ResponseBody;

public class BookSubscribe {
    public static void getData(int pageNumber, int count, DisposableObserver<ResponseBody> subscriber) {
        Map<String,Integer> map = new HashMap<>();
        map.put("start",pageNumber);
        map.put("count",count);
        Observable<ResponseBody> observable =  HttpMethods.getInstance().getHttpApi().getDataForMap(map);
        HttpMethods.getInstance().toSubscribe(observable, subscriber);
    }

    public static void getNovel(String novelId,DisposableObserver<ResponseBody> subscriber){
        Observable<ResponseBody> observable =  HttpMethods.getInstance().getHttpApi().getNovel(novelId);
        HttpMethods.getInstance().toSubscribe(observable, subscriber);
    }
    public static void getNovelSites(String novelId,DisposableObserver<ResponseBody> subscriber){
        Observable<ResponseBody> observable =  HttpMethods.getInstance().getHttpApi().getNovelSites(novelId);
        HttpMethods.getInstance().toSubscribe(observable, subscriber);
    }
    public static void getSiteRule(String domain,DisposableObserver<ResponseBody> subscriber){
        Observable<ResponseBody> observable =  HttpMethods.getInstance().getHttpApi().getNovelRule(domain);
        HttpMethods.getInstance().toSubscribe(observable, subscriber);
    }
}