If/else 在 Observable 中

If/else in Observable

我在理解如何使用 Observables 在循环中重构这个 if/else 条件时遇到一些问题。

这是我的代码:

for (Restrictions restrictions : Restrictions.values()) {
    if (conditionA(restrictions) {
        //Do something A
    } else {
        //Do something B
    }
}

我想要类似的东西

Observable.from(Restrictions.values()).filter(restrictions -> ....)

可是我不知道怎么表达if/else。

有什么建议吗?

此致。

类似于:

Observable.from(Restrictions.values())
.groupBy(restriction -> conditionA(restriction))})
...