runBlocking {
println("Starting subscription")
val connection = apiClient.ws()
connection.addListener[U]() {
println("数据监听")
}
// Listen for messages
// this automatically subscribes to activity log entries etc.
connection.addGlobalListener { message ->
println("Received $message")
}
awaitCancellation()
}
