Skip to content

Instantly share code, notes, and snippets.

@alexmoleiro
Created January 14, 2019 13:04
Show Gist options
  • Save alexmoleiro/784a2f2c454d9dea5a849d9808286259 to your computer and use it in GitHub Desktop.
Save alexmoleiro/784a2f2c454d9dea5a849d9808286259 to your computer and use it in GitHub Desktop.
RxJava 1.x . --> List to Observable
@Override
public Single<FormResource> getDraft(GetDraftRequestDto getDraftRequestDto) {
return cochesnetRepository.getDraft(getDraftRequestDto)
.flatMapObservable(draftResponses -> Observable.from(draftResponses)
.map(DraftResponse::mapFromCochesFieldsToPtaFields)
.flatMap(values -> createFormResource(values, getDraftRequestDto.getToken()).toObservable())
.switchIfEmpty(createDraft(getDraftRequestDto.getToken()).toObservable()))
.toSingle()
.onErrorResumeNext(this::handleError);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment