RSocket retrieveFlux()和Kotlin

Question

我正在尝试为我的服务器编写一个客户机(无论是用Kotlin还是使用)。我在尝试使用RSocket时遇到了这个问题。如何使用RSocket获得流量？

​

@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)
    }
}