1

可能是一个 rx newbee 问题。

如果我有两个 rx 流，它们有一些共同的部分，是否有可能提取和重用它们？

这是伪代码示例：

someManager.getInfo(id) returns a Single<SometInfo>

这个乐趣需要一个 id 并且应该只返回一个状态

fun getStatus(id: String): Single<Status> =
    someManager.getInfo(id)
        .flattenAsObservable { it.items }
        .map { getSomeProp(it) } // from here
        .toList()
        .map { getStatus(it) }
        .doOnSuccess { getStatusRelay(id).accept(it) } // until here it's common

这个不带 id 但已经是一个对象，应该检查状态是否正常

fun isStatusOk(info: SomeInfo): Single<Boolean> =
    Observable.fromIterable(info.items)
        .map { getSomeProp(it) } // from here
        .toList()
        .map { getStatus(it) }
        .doOnSuccess { getStatusRelay(id).accept(it) } // until here it's common
        .map { it == Status.OK }

先感谢您

4

2 回答 2

1

您还可以使用扩展功能

fun Observable<Item>.convertToSingeStatus(): Single<Status> =
        this.map { getSomeProp(it) }
            .toList()
            .map { getStatus(it) }
            .doOnSuccess { getStatusRelay(id).accept(it) }

接着

fun getStatus(id: String): Single<Status> =
someManager.getInfo(id)
    .convertToSingeStatus()
    .doOnSuccess { getStatusRelay(id).accept(it) }
于 2018-10-22T10:22:01.417 回答
0

凤凰王建议变形金刚。我尝试了它们，经过一些实验后似乎我得到了它的工作。

我创建了一个 SingleTransformer：

private fun getStatus() =
    SingleTransformer<SomeInfo, Status> {
        it.flatMap {
            Observable.fromIterable(it.items)
                .map { getSomeProp(it) }
                .toList()
                .map { getStatus(it) }
        }
    }

然后我可以重构

fun getStatus(id: String): Single<Status> =
    someManager.getInfo(id)
        .compose(getStatus())
        .doOnSuccess { getStatusRelay(id).accept(it) }

这也是

fun isStatusOk(info: SomeInfo): Single<Boolean> =
    Single.just(info)
        .compose(getStatus())
        .doOnSuccess { getStatusRelay(id).accept(it) }
        .map { it == Status.OK }

希望它可以帮助别人。

于 2018-10-04T14:18:00.517 回答