如何仅写入一个具有现有WebSocket连接而不是所有用户的用户？

Question

这就是我所拥有的： 在这里，传入消息将发送给所有用户。

fun Route.chatSocket(roomController: RoomController) {
    webSocket("/chat-socket" ) {
        val session = call.sessions.get<ChatSession>()
        if (session==null) {
            close(CloseReason(CloseReason.Codes.VIOLATED_POLICY,"No session"))
            return@webSocket
        }
        try {
            roomController.onJoin(
            username = session.username,
            sessionId = session.sessionId,
            socket = this
        )
       incoming.consumeEach { frame ->
            if (frame is Frame.Text) {
                roomController.sendMessage(
                    senderUsername = session.username,
                    message = frame.readText()
                )
            }

        }

        } catch (e: MemberAlredyExistExpetion) {
            call.respond(HttpStatusCode.Conflict)
        } finally {
            roomController.tryDisconnect(session.username)
        }
    }
}

这是RoomController：

class RoomController(
    private val messageDataSource: MessageDataSource
) {
    private val members = ConcurrentHashMap<String,Member>()

    fun onJoin(
        username:String,
        sessionId:String,
        socket: WebSocketSession
    ) {
        if (members.containsKey(username)) {
            throw MemberAlredyExistExpetion()
        }
        members[username] = Member(
            username = username,
            sessionId = sessionId,
            socket  = socket
        )
    }

   suspend fun sendMessage(senderUsername: String, message: String) {
        members.values.forEach { member ->
            val messageEntity = Message(
                text = message,
                username = senderUsername,
                timestamp = System.currentTimeMillis()
            )
            messageDataSource.insertMessage(messageEntity)

            val parsedMessage = Json.encodeToString(messageEntity)
            member.socket.send(Frame.Text(parsedMessage))
        }
    }

在这里，我尝试实现一个可以直接写给用户的命令。但是它不起作用。

fun Route.chatToOne(roomController: RoomController) {
    webSocket("/whisper") {
        val session = call.sessions.get<ChatSessionToOne>()
        if (session==null) {
            close(CloseReason(CloseReason.Codes.VIOLATED_POLICY,"No Session"))
            return@webSocket
        }
        try {
            incoming.consumeEach { frame ->
                if (frame is Frame.Text) {
                    roomController.sendMessageToOneUser(
                        senderUsername = session.username,
                        targetUsername = session.targetusername,
                        message = frame.readText()
                    )
                }
            }
        } catch (e: MemberAlredyExistExpetion) {
            call.respond(HttpStatusCode.Conflict)
        }
    }
}

在这里，来自RoomController的代码：

suspend fun sendMessageToOneUser(senderUsername: String, targetUsername :String, message: String) {
        members.values.forEach { member ->
            if (member.username == targetUsername) {
                val messageEntity = Message(
                    text = message,
                    username = targetUsername,
                    timestamp = System.currentTimeMillis()
                )
                messageDataSource.insertMessage(messageEntity)

                val parsedMessage = Json.encodeToString(messageEntity)
                member.socket.send(Frame.Text(parsedMessage))
            }
        }
    }

如何仅写入一个具有现有WebSocket连接而不是所有用户的用户？