allprojects {
    repositories {
        maven { url "https://jitpack.io" }
    }
}

android {
    compileOptions {
        sourceCompatibility JavaVersion.VERSION_1_8
        targetCompatibility JavaVersion.VERSION_1_8
    }
}

plugins {
    // kapt/ksp выбираете одно
    // id 'kotlin-kapt'
    id 'com.google.devtools.ksp' version '2.0.0-1.0.24'
}
    
dependencies {
    def rxhttp_version = '3.3.1'
    implementation 'com.squareup.okhttp3:okhttp:4.12.0'  
    implementation "com.github.liujingxing.rxhttp:rxhttp:$rxhttp_version"
    // ksp/kapt/annotationProcessor выбираете одно
    ksp "com.github.liujingxing.rxhttp:rxhttp-compiler:$rxhttp_version"
 }

implementation 'io.reactivex.rxjava3:rxjava:3.1.6'
implementation 'io.reactivex.rxjava3:rxandroid:3.0.2'
implementation 'com.github.liujingxing.rxlife:rxlife-rxjava3:2.2.2' //RxJava3, Автоматическое закрытие запросов

implementation 'io.reactivex.rxjava2:rxjava:2.2.8'
implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'
implementation 'com.github.liujingxing.rxlife:rxlife-rxjava2:2.2.2' //RxJava2, Автоматическое закрытие запросов

ksp {
    arg("rxhttp_rxjava", "3.1.6")
}

kapt {
    arguments {
        arg("rxhttp_rxjava", "3.1.6")
    }
}

android {
    defaultConfig {
        javaCompileOptions {
            annotationProcessorOptions {
                arguments = [
                    rxhttp_rxjava: '3.1.6', 
                ]
            }
        }
    }
}

ksp {
     arg("rxhttp_package", "rxhttp.xxx")
}

RxHttpPlugins.init(OkHttpClient)  
    .setDebug(boolean)  
    .setOnParamAssembly(Consumer)
    ....

public class Url {

    //Добавьте аннотацию @defaultDomain к BASE_URL
    @DefaultDomain
    public static BASE_URL = "https://..."
}

// java
RxHttp.get("/service/...")   //1、Вы можете выбрать get, postFrom, postJson и т.д.
    .addQuery("key", "value")               //добавление параметра запроса
    .addHeader("headerKey", "headerValue")  //добавление заголовка запроса
    .toObservable(Student.class)  //2、Используйте метод toXxx для определения типа возвращаемого значения, настраиваемый
    .subscribe(student -> {  //3、Подписывание наблюдателя
        //Успешный обратный вызов，默认IO线程
    }, throwable -> {
        //Обратный вызов ошибки
    });

// kotlin 
RxHttp.postForm("/service/...")          //post FormBody
    .add("key", "value")                 //добавление параметра в тело
    .addQuery("key1", "value1")          //добавление параметра запроса
    .addFile("file", File(".../1.png"))  //добавление файла в тело
    .toObservable<Student>()           
    .subscribe({ student ->       
        //默认IO线程
    }, { throwable ->
        
    })

// kotlin корутина
val students = RxHttp.postJson("/service/...")  //1、post {application/json; charset=utf-8}
    .toAwaitList<Student>()                          //2、Используйте метод toXxx для определения типа возвращаемого значения, настраиваемый
    .await()                                    //3、Получение возвращаемого значения, await — это suspend метод

// В Rxjava2, автоматическое закрытие запросов
RxHttp.get("/service/...")
    .toObservableString()
    .as(RxLife.as(this))  // При уничтожении Activity автоматически закрывается запрос
    .subscribe(s -> {
        // 默认IO线程
    }, throwable -> {

    });

// В Rxjava3, автоматическое закрытие запросов
RxHttp.get("/service/...")
    .toObservableString()
    .to(RxLife.to(this))  // При уничтожении Activity автоматически закрывается запрос
    .subscribe(s -> {
        // 默认IO线程
    }, throwable -> {
        
    });


// В RxJava2/RxJava3, закрытие запроса вручную
Disposable disposable = RxHttp.get("/service/...")
    .toObservableString()
    .subscribe(s -> {
        // 默认IO线程
    }, throwable -> {
        
    });

disposable.dispose(); // Закрытие запроса в нужное время

Copyright 2019 liujingxing

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

   http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.