reline
07/15/2019, 5:25 PMfun parseObservable(f: File): Observable<Item> { ... }
Observable.fromIterable(List<File>)
.concatMapEagerDelayError({ parseObservable(it) }, true)
.toList()
.subscribeOn(<http://Schedulers.io|Schedulers.io>())
.observeOn(AndroidSchedulers.mainThread())
.subscribe { items -> ... }
rook
07/15/2019, 10:21 PMsealed class Result(){
class Content(val content: Type) : Result
class Error(val error: Throwable): Result
}
Result
and you can decide what to do based on the type of Result
it isursus
07/16/2019, 10:49 AMreline
07/19/2019, 6:16 PMfun parseObservable(f: File): Observable<Result> {
...
.map { Success(f, it) }
.onErrorResumeNext { Single.just(Failure(f, it)) }
.toObservable()
}
Observable.fromIterable(List<File>)
.concatMapEager { parseObservable(it) }
.toList()
.subscribe { results -> ... }
ursus
07/19/2019, 7:50 PM