ZeroMq.kt

ZeroMq.kt

   override fun close() {
       try {
           isRunning = false
           receiveJob?.cancel()
           subSocket?.close()
           pubSocket?.close()
           context?.close()
           Log.d(TAG, "Disconnected from server")
           CoroutineScope(Dispatchers.Main).launch { onConnectionChanged?.invoke(false) }
       } catch (e: Exception) {
           Log.e(TAG, "Error disconnecting from server: ${e.message}", e)
       } finally {
           receiveJob = null
           subSocket = null
           pubSocket = null
           context = null
       }
   }