Chaining-rxjava-4-1.java

// DomainService.java
@RxLogObservable
public Observable<Data> getData() {
  return getMergedData()
    .onErrorReturn(new Func1<Throwable, Data>() {
      @Override
      public Data call(Throwable throwable) {
        Log.e(CLASSNAME, "Error while fetching data. Swallowing the exception.", throwable);
        return null; // We return null since we know our filter will ignore null values.
      }
    })
    .filter( 
      new Func1<Data, Boolean>() { 
        @Override 
        public Boolean call(Data data) { 
          return data != null;
        }
      }
    );
}