aiidziis
02/02/2021, 8:10 AMflatMap
. Currently I am trying to do something like this, but have no succes:
class Client {
fun fetchToken(accessToken: String): Observable<String> {
return observable {}
}
}
class Storage {
fun accessToken(): Observable<String> {
return observable {}
}
}
class DataProcessor(
private val client: Client,
private val storage: Storage
) {
fun freshAccessToken(): Observable<String> {
return storage.accessToken()
.subscribeOn(ioScheduler)
.flatMap { client.fetchToken(it) } <--- here
.observeOn(mainScheduler)
}
}