archive-gh-me/FastHub
1
0
Fork 0
mirror of https://github.com/k0shk0sh/FastHub.git synced 2025-12-08 19:05:54 +00:00
Code Issues Projects Releases Wiki Activity

fix some usecases

Browse Source
This commit is contained in:
k0shk0sh 2019-09-26 03:56:51 +02:00
parent 44c6fbfb6f
commit a75d45cfbd
3 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/src/main/java/com/fastaccess/github/usecase/user/BlockUnblockUserUseCase.kt
View File

@ -18,8 +18,6 @@ class BlockUnblockUserUseCase @Inject constructor(
override fun buildObservable(): Observable<Boolean> = login?.let { login ->
userRepository.blockUnblockUser(login, block)
.subscribeOn(schedulerProvider.ioThread())
.observeOn(schedulerProvider.uiThread())
.map {
val isSuccess = it.isSuccessful && it.code() == 204
if (isSuccess) {
@ -27,5 +25,7 @@ class BlockUnblockUserUseCase @Inject constructor(
}
return@map isSuccess
}
.subscribeOn(schedulerProvider.ioThread())
.observeOn(schedulerProvider.uiThread())
} ?: Observable.empty()
}

8
app/src/main/java/com/fastaccess/github/usecase/user/FollowUnfollowUserUseCase.kt
View File

@ -1,5 +1,6 @@
package com.fastaccess.github.usecase.user
import com.fastaccess.data.repository.SchedulerProvider
import com.fastaccess.data.repository.UserRepository
import com.fastaccess.domain.usecase.base.BaseObservableUseCase
import io.reactivex.Observable
@ -8,7 +9,10 @@ import javax.inject.Inject
/**
* Created by Kosh on 10.06.18.
*/
class FollowUnfollowUserUseCase @Inject constructor(private val userRepository: UserRepository) : BaseObservableUseCase() {
class FollowUnfollowUserUseCase @Inject constructor(
private val userRepository: UserRepository,
private val schedulerProvider: SchedulerProvider
) : BaseObservableUseCase() {
var login: String? = null
var follow: Boolean = false
@ -25,5 +29,7 @@ class FollowUnfollowUserUseCase @Inject constructor(private val userRepository:
}
return@map isSuccess
}
.subscribeOn(schedulerProvider.ioThread())
.observeOn(schedulerProvider.uiThread())
} ?: Observable.empty()
}

2
app/src/main/java/com/fastaccess/github/usecase/user/IsUserBlockedUseCase.kt
View File

@ -17,8 +17,8 @@ class IsUserBlockedUseCase @Inject constructor(
override fun buildObservable(): Observable<Boolean> = login?.let { login ->
userRepository.isUserBlocked(login)
.map { it.isSuccessful && it.code() == 204 }
.subscribeOn(schedulerProvider.ioThread())
.observeOn(schedulerProvider.uiThread())
.map { it.isSuccessful && it.code() == 204 }
} ?: Observable.empty()
}