filippodb/SchildiChat-android
1
0
Fork 0
mirror of https://github.com/SchildiChat/SchildiChat-android.git synced 2025-01-11 01:13:46 +01:00
Code Issues Packages Projects Releases Wiki Activity

False positive

Browse Source
This commit is contained in:
Benoit Marty 2020-10-06 16:00:29 +02:00
parent 250ac42fa3
commit 7e3acaa987
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
vector/src/main/java/im/vector/app/core/platform/VectorViewModel.kt
View File

@ -42,9 +42,11 @@ abstract class VectorViewModel<S : MvRxState, VA : VectorViewModelAction, VE : V
* This method does the same thing as the execute function, but it doesn't subscribe to the stream * This method does the same thing as the execute function, but it doesn't subscribe to the stream
* so you can use this in a switchMap or a flatMap * so you can use this in a switchMap or a flatMap
*/ */
// False positive
@Suppress("USELESS_CAST")
fun <T> Single<T>.toAsync(stateReducer: S.(Async<T>) -> S): Single<Async<T>> { fun <T> Single<T>.toAsync(stateReducer: S.(Async<T>) -> S): Single<Async<T>> {
setState { stateReducer(Loading()) } setState { stateReducer(Loading()) }
return this.map { Success(it) as Async<T> } return map { Success(it) as Async<T> }
.onErrorReturn { Fail(it) } .onErrorReturn { Fail(it) }
.doOnSuccess { setState { stateReducer(it) } } .doOnSuccess { setState { stateReducer(it) } }
} }
@ -53,9 +55,11 @@ abstract class VectorViewModel<S : MvRxState, VA : VectorViewModelAction, VE : V
* This method does the same thing as the execute function, but it doesn't subscribe to the stream * This method does the same thing as the execute function, but it doesn't subscribe to the stream
* so you can use this in a switchMap or a flatMap * so you can use this in a switchMap or a flatMap
*/ */
// False positive
@Suppress("USELESS_CAST")
fun <T> Observable<T>.toAsync(stateReducer: S.(Async<T>) -> S): Observable<Async<T>> { fun <T> Observable<T>.toAsync(stateReducer: S.(Async<T>) -> S): Observable<Async<T>> {
setState { stateReducer(Loading()) } setState { stateReducer(Loading()) }
return this.map { Success(it) as Async<T> } return map { Success(it) as Async<T> }
.onErrorReturn { Fail(it) } .onErrorReturn { Fail(it) }
.doOnNext { setState { stateReducer(it) } } .doOnNext { setState { stateReducer(it) } }
} }