java - 使用 Kotlin 的 RSocket retrieveFlux()

Question

我正在尝试为我的服务器编写一个客户端(在 Kotlin 和使用 Spring Reactive Web 中)。我在尝试使用 RSocket 时遇到了这个问题。如何使用 RSocket 获得 Flux？

@Component
class RSocketClient(val rSocketRequester: RSocketRequester) {
    data class Header(val playerToken: Int)

    fun matchmake(): Flux<Int> {
        return rSocketRequester.route("matchmaking")
                .data(Header(0))
                .retrieveFlux(Int)
    }
}

Answer 1

你需要得到Class的引用.您可以使用 Int::class.java或 Int::class取决于你是否需要 java Class或 KClass引用

@Component
class RSocketClient(val rSocketRequester: RSocketRequester) {
    data class Header(val playerToken: Int)

    fun matchmake(): Flux<Int> {
        return rSocketRequester.route("matchmaking")
                .data(Header(0))
                .retrieveFlux(Int::class.java)
    }
}