Revision control
Copy as Markdown
/*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
*/
package mozilla.lockbox.extensions
import io.reactivex.Observable
import mozilla.appservices.logins.ServerPassword
import mozilla.lockbox.LogProvider
import mozilla.lockbox.model.ItemViewModel
import mozilla.lockbox.support.Optional
fun <T : Any, U : T> Observable<T>.filterByType(clazz: Class<out U>): Observable<U> {
return this.filter { t -> clazz.isInstance(t) }.map { t -> clazz.cast(t) }
}
fun <T : Any> Observable<T>.debug(message: String = "observer"): Observable<T> {
return this
.doOnSubscribe {
LogProvider.log.info("$message: subscribed")
}
.doOnNext {
LogProvider.log.info("$message: event: $it")
}
.doOnError {
LogProvider.log.info("$message: error: ${it.localizedMessage}")
}
.doOnDispose {
LogProvider.log.info("$message: disposed")
}
}
fun <T : Any, U : Optional<T>> Observable<U>.filterNotNull(): Observable<T> {
return this.filter { it.value != null }.map { it.value }
}
fun Observable<List<ServerPassword>>.mapToItemViewModelList(): Observable<List<ItemViewModel>> {
return this.map { list -> list.map { it.toViewModel() } }
}