Struggling with 0.5.0

[kmbisset89]

I started using RPC with 0.3.0 and had good success with 0.4.0, but when I created a new project with 0.5.0, I feel like I can't get it to work. I'm not sure if it's an issue or a bug with RPC, so I'm starting a discussion here. Any help would be appreciated.

Relevant class - Shared

@Rpc
interface DeviceStatus : RemoteService {
//    val attachedDevices: String

    suspend fun getAttachedDevices(): Flow<String>
}

Relevant classes - Server

@Single
class BasicService(
    @InjectedParam
    wait: Boolean,
    @InjectedParam
    host: String
) : KoinComponent {
    init {
        start(wait, host)
    }

    private fun start(wait: Boolean = false, host: String) {
        embeddedServer(Netty, port = SERVER_PORT, host = host, module = {
            install(Krpc)

            install(CORS) {
                allowMethod(HttpMethod.Options)
                allowMethod(HttpMethod.Put)
                allowMethod(HttpMethod.Delete)
                allowMethod(HttpMethod.Patch)
                allowHeader(HttpHeaders.Authorization)
                allowHeader(HttpHeaders.AccessControlAllowOrigin)
                allowHeader(HttpHeaders.Upgrade)
                allowNonSimpleContentTypes = true
                allowCredentials = true
                allowSameOrigin = true

                // webpack-dev-server and local development
                val allowedHosts = listOf("localhost:3000", "localhost:8080", "localhost:8081", "127.0.0.1:8080")
                allowedHosts.forEach { host ->
                    allowHost(host, listOf("http", "https", "ws", "wss"))
                }
            }

            val koin = getKoin()
            routing {
                rpc("/device") {
                    rpcConfig {
                        serialization {
                            json()
                        }
                    }

                    registerService<DeviceStatus> { ctx ->
                        koin.get { parametersOf(ctx) }
                    }
                }
            }
        }).start(wait = wait)
    }
}

@Factory([DeviceStatus::class])
class DeviceStatusImpl(
    @InjectedParam
    override val coroutineContext: CoroutineContext
) : DeviceStatus {

//    override val attachedDevices: String = "attached"

    override suspend fun getAttachedDevices(): Flow<String> = flowOf("attached")
}

Relevant Classes - Client

    scope.launch(Dispatchers.IO) {
            val client = HttpClient(CIO) { installKrpc() }.rpc {
                url {
                    host = "127.0.0.1"
                    port = SERVER_PORT
                    encodedPath = "device"
                }

                rpcConfig {
                    serialization {
                        json()
                    }
                }
            }

            streamScoped {
                client.withService<DeviceStatus>().getAttachedDevices()
            }.collect {
                _devices.emit(it)
            }
        }

Exception Thrown

18:51:02.100 [eventLoopGroupProxy-4-1] DEBUG io.ktor.server.Application -- 101 Switching Protocols: GET - /device. Exception class kotlinx.coroutines.JobCancellationException: StandaloneCoroutine is cancelling
kotlinx.coroutines.JobCancellationException: StandaloneCoroutine is cancelling
Caused by: java.lang.IllegalStateException: Unsupported opcode 7
	at io.ktor.websocket.FrameParser.getFrameType(FrameParser.kt:40)
	at io.ktor.websocket.FrameParser.parseHeader1(FrameParser.kt:100)
	at io.ktor.websocket.FrameParser.handleStep(FrameParser.kt:72)
	at io.ktor.websocket.FrameParser.frame(FrameParser.kt:67)
	at io.ktor.websocket.WebSocketReader.parseLoop(WebSocketReader.kt:83)
	at io.ktor.websocket.WebSocketReader.readLoop(WebSocketReader.kt:74)
	at io.ktor.websocket.WebSocketReader.access$readLoop(WebSocketReader.kt:25)
	at io.ktor.websocket.WebSocketReader$readLoop$1.invokeSuspend(WebSocketReader.kt)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:100)
	at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.base/java.lang.Thread.run(Thread.java:833)
18:51:02.101 [eventLoopGroupProxy-4-1] ERROR io.ktor.server.Application -- Unhandled exception caught for CoroutineName(call-handler)
java.lang.IllegalStateException: Unsupported opcode 7
	at io.ktor.websocket.FrameParser.getFrameType(FrameParser.kt:40)
	at io.ktor.websocket.FrameParser.parseHeader1(FrameParser.kt:100)
	at io.ktor.websocket.FrameParser.handleStep(FrameParser.kt:72)
	at io.ktor.websocket.FrameParser.frame(FrameParser.kt:67)
	at io.ktor.websocket.WebSocketReader.parseLoop(WebSocketReader.kt:83)
	at io.ktor.websocket.WebSocketReader.readLoop(WebSocketReader.kt:74)
	at io.ktor.websocket.WebSocketReader.access$readLoop(WebSocketReader.kt:25)
	at io.ktor.websocket.WebSocketReader$readLoop$1.invokeSuspend(WebSocketReader.kt)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:100)
	at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.base/java.lang.Thread.run(Thread.java:833)

[kmbisset89]

I also tried the examples in the repo and got the same error

[kmbisset89]

It was because 8080 was blocked on my mac.