Skip to content

Instantly share code, notes, and snippets.

@murki

murki/Chaining-rxjava-4-2.java

Created November 24, 2016 20:11
Show Gist options
  • Save murki/ff7afec07cd709cfa470f7a76cfda00c to your computer and use it in GitHub Desktop.
Save murki/ff7afec07cd709cfa470f7a76cfda00c to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. murki created this gist Nov 24, 2016.
    14 changes: 14 additions & 0 deletions Chaining-rxjava-4-2.java
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,14 @@
    // DomainService.java
    @RxLogObservable
    public Observable<Data> getMergedData() {
    return Observable.mergeDelayError( // <-- don't interrupt stream
    diskRepository.getData().subscribeOn(Schedulers.io()),
    networkRepository.getData()
    .doOnNext(new Action1<Data>() {
    @Override
    public void call(Data data) {
    diskRepository.saveData(data);
    }
    }).subscribeOn(Schedulers.io())
    );
    }