Kotlin语言下封装简化Retrofit|Kotlin语言下封装简化Retrofit, rxjava网络调用 Kotlin语言下封装简化Retrofit|r

封装后的使用示例接口定义:

interface LdApiService {@GET("wapi/ldapp/feedlist") fun getHomepageItemFeedlist(@Query("tagId") tagId: String = "0", @Query("locationAnchor") locationAnchor: String = "", @Query("slipDirection") slipDirection: String = "2", @Query("hwratio") hwRatio: Float = 1.0f): Observable }

在fragment中调用上面的接口, 加载数据:

api.getHomepageItemFeedlist().action( onError = { it -> Log.d(TAG, "exception", it) }, onNext = { it -> onDataCallBack(it) })

可以看到去掉了基本永远重复的线程切换逻辑:

.subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread())

整体感觉清爽了很多, 不再是经典的一坨无聊的代码堆积在那了.
实现下面是Api类全部的实现代码

import okhttp3.OkHttpClient import retrofit2.Retrofit import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory import retrofit2.converter.gson.GsonConverterFactory import java.util.concurrent.TimeUnitobject Api { var client: OkHttpClient = OkHttpClient.Builder() //.sslSocketFactory(HttpsTrustManager.createSSLSocketFactory()) //.hostnameVerifier(HttpsTrustManager.TrustAllHostnameVerifier()) //.addInterceptor(HttpLogInterceptor("http", true)) .connectTimeout(20, TimeUnit.SECONDS) .build() var service: LdApiService = Retrofit.Builder() .baseUrl(BaseURL.SERVER_URL) .addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) .client(client) .build().create(LdApiService::class.java)}

通过object实现单例模式. 并且这里把OkHttpClient变量单独列出来, 是为了glide等第三方库共用.
简短直接, 而且对于大部分依赖网络的应用来说, 这个初始化过程完全没必要进行懒加载.
这样每次使用时可以直接如此调用:

Api.service.queryXXXX() ..........

为了看着更简洁, 可以通过定义别名来缩短全面的Api.service

import com.spx.litedo.api.Api.service as api

对于线程切换的封装:

fun Observable.action( onError: (Throwable) -> Unit, onNext: (T) -> Unit, onComplete: () -> Unit = {} ): Disposable { return this.subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()).subscribe(onNext, onError, onComplete) }

目前还没发现其中有什么问题.
kotlin的表现力太好了. 有时候给人一种天高任鸟飞, 海阔凭鱼跃的柑橘. 赞!!!~