eygraber
01/24/2017, 7:59 PMval networkObservable = observable {
val newList = getUpdatedListFromNetwork()
if(!it.isUnsubscribed) it.onNext(newList)
}.cache()
val cachedObservable = Observable.from(...).delay(500, TimeUnit.MILLISECONDS)
return amb(cachedObservable.concatWith(networkObservable), networkObservable)