flatmap( return Observer::onComplete;) 在 rxJava 中是什么意思？为什么它的return类型是Observable<POJO>？

Question

Observable<POJO> localRequest = Database.getInstance(this.context).getAllQuestions().flatMapObservable((questions) -> {
         ContentHolder.getHolder().setQuestionMap(questions);
         return Observer::onComplete;
     });

 public Maybe<Question[]> getAllQuestions () {
     
 }

我无法理解 return Observer::onComplete;

的行

Answer 1

这是一种花哨但不正确的处理空结果的方法 Observable.empty()。

由于目标输入，

fatMapObservable 期望 Observable<POJO> 作为其 return。由于 Observable 是单一抽象方法类型，您可以使用 lambda 表达式构造它的实例。即，通过 observer -> observer.onComplete() 或 Observer::onComplete.

实现 subscribe(Observer<POJO>) 方法

flatmap( return Observer::onComplete;) 在 rxJava 中是什么意思？为什么它的return类型是Observable<POJO>？

What is the meaning of flatmap( return Observer::onComplete;) in rxJava? And why is the return type of it is Observerable<POJO>?

java

android

rx-java