也许到Completable

Question

我哈瓦一个Maybe<>源和一些行动，我想用这个值来执行，如果可能不为空：

// Maybe<T> maybe(); 
// Completable action(T value); 
return maybe().flatMapCompletable(val -> action(val)); 

但当也许是空的我希望得到“已完成” completable：

return Completable.complete(); 

如何使这个开关：如果可能不是空的获得一个可完成的，否则另一个？

Answer 1

好了，我已经写了两次测试，我想你想这种行为是给开箱即用。该maybeTest将完成，而无需调用saveToDb。 maybeTest2将调用saveToDb和扁平值回和完整。

@Test 
public void maybeTest() throws Exception { 
    Completable completable = Maybe.<Integer>empty() 
      .flatMapCompletable(o -> { 
       System.out.println(o); 

       return saveToDb(5); 
      }); 

    completable.test().await().assertComplete(); 
} 


@Test 
public void maybeTest2() throws Exception { 
    Completable completable = Maybe.just(5) 
      .flatMapCompletable(o -> { 
       System.out.println(o); 

       return saveToDb(5); 
      }); 

    completable.test().await().assertComplete(); 
} 

private Completable saveToDb(long value) { 
    return Completable.complete(); 
}