                 resFrom: -200,
                 threadKey: threadKey)
         case .text(let text):
-            let result = processMessageSocketTimeShiftTextEvent(text: text)
+            let result = processTimeShiftMessageSocketTextEvent(text: text)
             switch result {
             case .pingContentStart:
                 timeShiftChatCountIn1ThreadRequest = 0

        case unknown
    }

    func processMessageSocketTimeShiftTextEvent(text: String) -> MessageSocketProcessResult {
        guard let data = text.data(using: .utf8) else { return .unknown }
        let decoder = JSONDecoder()
        decoder.keyDecodingStrategy = .convertFromSnakeCase
        if let pc = try? decoder.decode(WebSocketPingContentData.self, from: data) {
            if pc.ping.content.hasPrefix("rs:0") {
                return .pingContentStart
            } else if pc.ping.content.hasPrefix("rf:0") {
                return .pingContentFinish
            }
            return .unknown

    }

    // swiftlint:disable function_parameter_count function_body_length
    func handleTimeShiftMessageSocketEvent(socket: WebSocket, event: WebSocketEvent, userId: String, threadId: String, threadKey: String, completion: (Result<Void, NicoError>) -> Void) {
        // log.debug(event)
        switch event {
        case .connected:
