如何将Observable转换为Maybe？RxJava2转换方法咨询

其实在RxJava2里，把Observable转换成Maybe有几种实用的方式，我给你梳理下常用的几种方案：

1. 使用firstElement()或lastElement()方法 #

如果你的Observable可能发射0个或1个数据项，这两个方法可以直接完成转换：

• firstElement()：取Observable发射的第一个数据项。如果Observable没有发射任何数据就完成，Maybe也会以onComplete()结束；如果Observable发射了一个数据，Maybe就会发射这个数据然后完成；如果Observable发射多个数据，只会保留第一个。
• lastElement()：逻辑和上面类似，不过是取最后一个数据项。

示例代码：

// 单个数据的Observable转Maybe
Observable<Integer> singleItemObservable = Observable.just(1);
Maybe<Integer> maybeFromFirst = singleItemObservable.firstElement();

// 空Observable转Maybe
Observable<Integer> emptyObservable = Observable.empty();
Maybe<Integer> maybeEmpty = emptyObservable.lastElement();

2. 使用singleElement()方法 #

如果你确定原Observable只会发射0个或1个数据项，用这个方法更严谨。如果Observable发射了多个数据，它会直接触发onError()，抛出IllegalArgumentException，能帮你提前发现不符合预期的数据流。

示例代码：

// 空Observable转Maybe
Observable<Integer> emptyObservable = Observable.empty();
Maybe<Integer> maybeEmpty = emptyObservable.singleElement();

// 单个数据的Observable转Maybe
Observable<Integer> singleItemObservable = Observable.just(2);
Maybe<Integer> maybeSingle = singleItemObservable.singleElement();

// 多个数据的Observable转Maybe会触发错误
Observable<Integer> multiItemObservable = Observable.just(3,4);
Maybe<Integer> maybeError = multiItemObservable.singleElement();

3. 结合过滤逻辑转换 #

如果原Observable有多个数据，但你需要根据特定条件筛选出0个或1个数据再转成Maybe，可以结合filter()和上述方法一起使用：

Observable<Integer> rangeObservable = Observable.range(1, 10);
// 筛选出等于5的项，转成Maybe
Maybe<Integer> filteredMaybe = rangeObservable.filter(num -> num == 5)
                                .firstElement();

简单总结：

• 想取第一个/最后一个数据（不管原Observable有多少个）：用firstElement()/lastElement()
• 确保原Observable最多只有一个数据，多了就报错：用singleElement()
• 需要先过滤再转换：结合过滤操作符+上述Maybe转换方法

内容的提问来源于stack exchange，提问作者Leroy Dunn