ZeroMq.kt

ZeroMq.kt

private fun startReceiving() {
  receiveJob = CoroutineScope(Dispatchers.IO).launch {
    try {
      while (isRunning && subSocket != null) {
        val message = subSocket?.recvStr()
        if (message != null) {
          Log.d(TAG, "Server received message: $message")
          messageCallback?.invoke(message)
        }
      }
    } catch (e: Exception) {
      Log.e(TAG, "Error receiving message: ${e.message}", e)
    }
  }
}