代码之家 › 专栏 › 技术社区 › user3139545

RxJava/RxKotlin根据子类型拆分流

rx-javafx rx-kotlin2 rx-kotlin rx-java kotlin

user3139545 · 技术社区 · 8 年前

ResponseMessage 可以是不同的子类型。我想把流分割成流,在那里我可以在自己的流中处理每种类型。

我的第一次尝试导致了这一点,我看不出有什么效果。

file.readLines()
        .toObservable()
        .map { mapper.readValue(it, ResponseMessage::class.java) }
        .groupBy { when(it) {
            is MarketChangeMessage -> it::class
            else -> it::class
        }}
        .map { it.????? } //How can possible this work?

我现在的问题是: 将流划分为一个特定子类型的流的惯用方法是什么?

1 回复 | 直到 7 年前

ESala 8 年前

你可以使用 ofType 操作员:

ofType()只从源可观察到的属于特定类的项发出。

val messages = file.readLines()
    .toObservable()
    .map { mapper.readValue(it, ResponseMessage::class.java) }
    .share() // <-- or other multicasting operator

messages
    .ofType(MarketChangeMessage::class)
    .subscribe()

messages
    .ofType(Other::class)
    .subscribe()

推荐文章

somnathchakrabarti · 从Kotlin 2.0开始,启用Compose时需要Compose编译器Gradle插件

1 年前

Para1life · 解组时找不到类:com.google.firebase。时间戳,

1 年前

A. Cedano · 如何在UIState中包含错误案例?

1 年前

Marcoral · 如何使用kotlin.reflet API设置kotlin对象类属性的值?

1 年前

Murilo · Jetpack编写导航栏项目图标

1 年前

Sachin · IntelliJ不断给出无法解析jdocs/kdocs中的@param

1 年前

Bass · @Volatile lateinit变量可以在Kotlin中使用DCL模式进行原子初始化吗?

1 年前

user2649681 · 实时生成音频以写入“SourceDataLine”`

1 年前

zplot · 使用具有抽象嵌套类的泛型时类型不匹配

1 年前

Santhosh Kumar · 当应用程序在Android 15 Pixel 9中重新启动时,Room DB被破坏

1 年前