transport-tcp/org.meshtastic.mqtt.transport.tcp/TcpTransport

TcpTransport

class TcpTransport(configureTls: TLSConfigBuilder.() -> Unit? = null) : MqttTransport

TCP transport for MQTT over raw sockets with optional TLS.

TCP is stream-oriented, so receive must reconstruct MQTT packet boundaries by parsing the fixed header and Variable Byte Integer remaining length from the byte stream, then reading exactly that many payload bytes.

Parameters

configureTls

optional hook applied to ktor's TLSConfigBuilder during the TLS handshake, after the SNI server name is set and before platform trust is configured. Use it to trust a private or self-signed CA for this connection only. Ignored for non-TLS endpoints.

Constructors

TcpTransport

constructor(configureTls: TLSConfigBuilder.() -> Unit? = null)

constructor()

Properties

isConnected

open override val isConnected: Boolean

Functions

open suspend override fun close()

connect

open suspend override fun connect(endpoint: MqttEndpoint)

receive

open suspend override fun receive(): ByteArray

Reads one complete MQTT packet from the TCP stream.

send

open suspend override fun send(bytes: ByteArray)