Socket On listeners donot fire but emit works fine

[Xcode09]

i am working on chat application and facing some issues when i send the message , it sent succuessfully but my listeners donot fire and message cannot updates
i make a sperate class code is here please help
open class SocketIOManager {

public static let default = SocketIOManager()
private let manager: SocketManager
private let socket: SocketIOClient

private init() {
self.manager = SocketManager(socketURL: URL(string: "http://18.220.164.142:3000/")!, config: [.connectParams(["token": UserState.gettoken() ?? ""]), .compress,.log(true)])
self.socket = manager.defaultSocket
}

//To check before any call is socket connected or not.
func isSocketConnected() -> Bool{
if self.socket.status == .connected {
return true
}
return false
}
//Connection with socket Handshaking
func establishConnection(completionHandler: @escaping (Bool) -> Void) {
socket.on(clientEvent: .connect) {data, ack in
completionHandler(true)
print("socket connected (data)")
}
socket.connect()
}
//Connection with socket Handshaking
func establishConnection() {
socket.connect()

}
//Socket connection disconnect
func closeConnection() {
socket.disconnect()
socket.off(clientEvent: .disconnect)
}

//Socket Remove Listeners
func removeListeners() {
socket.off("message")
socket.off("typing")
socket.off("stopTyping")
}

func getChatMessage(completionHandler: @escaping (GetChatConversation?,String?) -> Void) {

socket.on("message") { (dataArray, socketAck) -> Void in
  print(dataArray)
  
  if let data = dataArray.first as? Data{
    do{
      let objc = try JSONDecoder.init().decode(GetChatConversation.self, from: data)
      completionHandler(objc,nil)
    }
    catch let error{
      return completionHandler(nil,error.localizedDescription)
    }
  }else{
    completionHandler(nil,"Cannot cast Array of Any to Data")
  }
}

}

func getStartTypingResponse(completionHandler: @escaping (String) -> Void) {
socket.on("typing") { (dataArray, socketAck) -> Void in
let swiftyJsonVar = JSON(dataArray as Any)
let messageDictionary = swiftyJsonVar.arrayValue[0]

  completionHandler(messageDictionary["sender"].stringValue)
}

}

func getStopTypingResponse(completionHandler: @escaping (String) -> Void) {
socket.on("stopTyping") { (dataArray, socketAck) -> Void in
let swiftyJsonVar = JSON(dataArray as Any)
let messageDictionary = swiftyJsonVar.arrayValue[0]

  completionHandler(messageDictionary["sender"].stringValue)
}

}

func sendStartTypingMessage(conversationId: String) {

var typingDict = [String: Any]()
typingDict.updateValue(conversationId, forKey: "conversationId")

if let bearerToken = UserState.gettoken() {
  if bearerToken.count > 0 {
    typingDict.updateValue(bearerToken, forKey: "token")
  }
}
socket.emitWithAck("typing", typingDict).timingOut(after: 0.1, callback: { data in
  print("\(data)")
})  }

func sendStopTypingMessage(conversationId: String) {

var stopTypingDict = [String: Any]()
stopTypingDict.updateValue(conversationId, forKey: "conversationId")

if let bearerToken = UserState.gettoken() {
  if bearerToken.count > 0 {
    stopTypingDict.updateValue(bearerToken, forKey: "token")
  }
}
socket.emitWithAck("stopTyping", stopTypingDict).timingOut(after: 0.1, callback: { data in
  print("\(data)")
})

}

func sendMessage(message: String, conversationId: String, completionHandler: @escaping (Bool) -> Void) {

var conversationDictionary = [String: Any]()
conversationDictionary.updateValue(message, forKey: "message")
conversationDictionary.updateValue(conversationId, forKey: "conversationId")
conversationDictionary.updateValue(Date().millisecondsSince1970, forKey: "timestamp")

if let bearerToken = UserState.gettoken() {
  if bearerToken.count > 0 {
    conversationDictionary.updateValue(bearerToken, forKey: "token")
  }
}

socket.emitWithAck("message", conversationDictionary).timingOut(after: 0.1, callback: { data in
  print("\(data)")
 
})

}
}