这是我试图完成的图片.
--abca - BBB - 一个
分裂成
--a ----- a ------- a - >一个流
---- b ------ bbb --- - > b stream
------ c ---------- - > c stream
然后,能够
a.subscribe()
b.subscribe()
c.subscribe()
到目前为止,我发现的所有内容都使用groupBy()拆分流,但随后将所有内容折叠回单个流并在同一个函数中处理它们.我想要做的是以不同的方式处理每个派生流.
我现在正在做的方式是做一堆过滤器.有一个更好的方法吗？