Chaining-rxjava-5.java

// We assume the repositories getData() methods will return null if no data is available

// DomainService.java
@RxLogObservable
public Observable<Data> getData() {
  return getMergedData()
    .filter( 
      new Func1<Data, Boolean>() { 
        @Override 
        public Boolean call(Data data) { 
          return data != null;
        }
      }
    );
}