core-network/org.meshtastic.core.network.radio/StreamTransport

StreamTransport

abstract class StreamTransport(callback: RadioTransportCallback, scope: CoroutineScope) : RadioTransport(source)

An interface that assumes we are talking to a meshtastic device over some sort of stream connection (serial or TCP probably).

Delegates framing logic to StreamFrameCodec from core:network.

Inheritors

SerialRadioTransport

SerialTransport

Constructors

StreamTransport

constructor(callback: RadioTransportCallback, scope: CoroutineScope)

Functions

open suspend override fun close()

Closes admission and lets already-admitted frames finish before cancelling the worker as a bounded fallback.

open fun flushBytes()

Flushes buffered bytes to the underlying stream. No-op by default.

handleSendToRadio

open override fun handleSendToRadio(p: ByteArray): Boolean

open fun keepAlive()

abstract fun sendBytes(p: ByteArray)

Writes raw bytes to the underlying stream (serial port, TCP socket, etc.). Implementations may block until the driver accepts the bytes, so direct callers must already be running on an I/O dispatcher. Framed packet sends use queueFramedSend, whose writer controls dispatcher confinement. Subclasses that rely on queueFramedSend's default writer must therefore supply an I/O-confined scope.

open fun start()