rxjava 多状态，多条件的用法

[lrj2u]

有这么一个业务问题想请大牛指点下：

现在用上了 rxjava ＋ retrofit 开发点网络程序。

我这里有某个服务 api ，请求后返回 4 个状态，每个状态都有对应的操作。 比如有的是继续请求另外的 api ，有的是执行数据保存等。

请问用 rxjava 怎么把链条执行下去？

[twoyuan]

根据状态码 flatMap ？非法状态可以直接在 Interceptor 那边映射成自定义的 Exception 然后统一处理

[lrj2u]

不是非法状态，都是正常的状态。 flatMap 怎么操作？有代码看看吗？
因为每个状态都是操作不同的操作链。

[chocotan]

Observable connectable = sourceObservalbe.publish()
a.filter(状态 1).doOnNext...
a.filter(状态 2).doOnNext...
a.filter(状态 3).doOnNext...
connectable.connect()

大概像这样？

[chocotan]

@chocotan 上面写错，第二行以后的 a.filter.. 应该是 connectable.filter...

[lrj2u]

@chocotan 这样似乎行不通啊，第一条 filter 的时候就把其它情况都过滤掉了。

[lrj2u]

刚才没看清楚， aa 后加了个 publish ，我在、再试试

[lrj2u]

@chocotan 只添加 publish() 还不行，还要添加一个链条： autoConnect()，如果有 4 个状态，就填 4 ，这样才会把 4 个 subscribe 都执行。