eygraber
01/24/2017, 7:47 PMamb to achieve the first part, but I can't figure out how to emit from both observables if the network one doesn't finish fast enough:
val cachedObservable = Observable.from(...).delay(500, TimeUnit.MILLISECONDS)
val networkObservable = observable {
val newList = getUpdatedListFromNetwork()
if(!it.isUnsubscribed) it.onNext(newList)
}
return Observable.amb(cachedObservable, networkObservable)