IOSMessageStreamManager

Properties

abstract fun addDeviceToStream(deviceId: UInt)

abstract suspend fun getActiveDevices(): List<UInt>

abstract suspend fun isStreamActive(): Boolean

abstract fun processStreamResponse(response: Any)

abstract suspend fun pushEncryptedHeartbeatAndCiphertext(deviceId: UInt, heartbeats: List<ByteArray>, ciphertexts: List<ByteArray>, heartbeatBridgeReceiveEpochSeconds: List<Long?> = emptyList())

abstract suspend fun pushEncryptedMessages(deviceId: UInt, payloads: List<ByteArray>, isHeartbeat: Boolean, heartbeatBridgeReceiveEpochSeconds: List<Long?> = emptyList())

abstract suspend fun removeDeviceFromStream(deviceId: UInt)

abstract suspend fun sendTelemetry(data: ByteArray)

abstract fun setOOBHandler(handleOOBResponse: (oobMessage: OOBWrapper?) -> Unit)

Called by the Kotlin wrapper so the native implementation can notify when payloads are persisted (e.g. after processStreamResponse).

abstract fun shutdown()