a easy Asynchronous Library by RxJava3.X
get lib version by use this web link： https://jitpack.io/#KilleTom/rxtask
be careful v0.0.1-beta defalut scheduler was android
but start from v1.0.3-beta version you can use other scheduler
and now v1.1.0 was first release version.
look like this
allprojects {
repositories {
maven { url "https://jitpack.io" }
}
}
now lib version was： v1.1.0
libRxtask a base lib, use this can run on webService or other
libRxtaskAndroidScheduler a expand android lib
not run on android just like this dependdencies
dependencies {
//rxTask baselib
implementation 'com.github.KilleTom:rxtask:libRxtask:version'
}
run on android must write this:
dependencies {
//rxTask baselib
implementation 'com.github.KilleTom:rxtask:libRxtask:version'
//android expand scheduler lib
implementation 'com.github.KilleTom:rxtask:libRxTaskAndroidExpand:version'
}
if you don't want find lib version just write like this
dependencies {
//rxTask base lib
implementation 'com.github.KilleTom.rxtask:libRxtask:v1.1.0'
//run on android must use : android expand lib
implementation 'com.github.KilleTom.rxtask:libRxTaskAndroidExpand:v1.1.0'
}
// init RxTask gloabl defalut scheduler
//for example like android use this lib init gloable defalut scheduler
RxTaskSchedulerManager.setLocalScheduler(RxAndroidDefaultScheduler())
sometime you don't want asynchronous run on default schedule you can make this asynchronous run on other schedule
- use gloable defalut scheduler
//simple asynchronous operation
val singleTask = RxSingleEvaluationTaskTask.createTask {
//get news
val response = okHttpClient.newCall(createRequest(createNewUrl("top")))
.execute()
val body = response.body ?: throw RuntimeException("body null")
val result = Gson().fromJson(body.string(), JsonObject::class.java)
return@createTask result
}.successAction {
//do your sucess logic
Log.i("KilleTom", "$it")
}.failAction {
//do your fail logic
it.printStackTrace()
}.start()- run on designated schedule
val singleTask = RxSingleEvaluationTaskTask.createTask({
val response = okHttpClient.newCall(createRequest(createNewUrl("top")))
.execute()
val body = response.body ?: throw RuntimeException("body null")
val result = Gson().fromJson(body.string(), JsonObject::class.java)
return@createTask result
},
// like this use a designated schedule for RxAndroidDefaultScheduler
RxAndroidDefaultScheduler()
).successAction {
Log.i("KilleTom", "$it")
}.failAction {
it.printStackTrace()
}.start()- like this android example use a init gloable defalut scheduler
val progressTask = RxProgressEvaluationTaskTask
.createTask<JsonObject, Boolean> { task ->
val types = arrayListOf<String>("top", "shehui", "guonei")
types.forEach { value ->
val result = okHttpClient
.newCall(createRequest(createNewUrl(value)))
.execute()
val body = result.body ?: throw RuntimeException("body null")
val jsonObject = Gson().fromJson(body.string(), JsonObject::class.java)
Log.d("KilleTom", "推送新闻类型$value")
//pulish progress
task.publishProgressAction(jsonObject)
}
//asynchronous result
return@createTask true
}.progressAction {
//do on progress call logic
Log.i("KilleTom", "收到进度,message:$it")
}.successAction {
// do sucess logic
Log.i("KilleTom", "Done")
}.failAction {
// do fail logic
Log.i("KilleTom", "error message:${it.message ?: "unknown"}")
}.start()- run on designated schedule
val progressTask = RxProgressEvaluationTaskTask
.createTask<JsonObject, Boolean> ({ task ->
val types = arrayListOf<String>("top", "shehui", "guonei")
types.forEach { value ->
val result = okHttpClient
.newCall(createRequest(createNewUrl(value)))
.execute()
val body = result.body ?: throw RuntimeException("body null")
val jsonObject = Gson().fromJson(body.string(), JsonObject::class.java)
Log.d("KilleTom", "推送新闻类型$value")
task.publishProgressAction(jsonObject)
}
return@createTask true
},
// like this use a designated schedule for RxAndroidDefaultScheduler
RxAndroidDefaultScheduler())
.progressAction {
Log.i("KilleTom", "收到进度,message:$it")
}.successAction {
Log.i("KilleTom", "Done")
}.failAction {
Log.i("KilleTom", "error message:${it.message ?: "unknown"}")
}.start()RxTimerTask.createTask { task ->
if (task.getTimeTicker().countTimes >= 10) {
task.cancel()
}
// do your logic
return@createTask
}.setDelayTime(0L)
.setIntervalTime(1000)
.setTaskScheduler(Schedulers.computation())
.start()
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent