kuilt-conformance/us.tractat.kuilt.conformance/DelayedWovenSeam

DelayedWovenSeam

A Seam produced by DelayedWovenLoom that starts SeamState.Weaving.

Call markWoven to transition to SeamState.Woven, simulating a radio fabric completing its link-establishment phase.

Inbound delivery is bounded via a Spool — the same primitive used by InMemoryLoom — so backpressure and overflow behaviour follow the loom's DeliveryPolicy.

Properties

capability

open val capability: StateFlow<TransportCapability>

incoming

open override val incoming: Flow<Swatch>

maxPayloadBytes

open val maxPayloadBytes: Int?

peers

open override val peers: StateFlow<Set<PeerId>>

plies

open val plies: StateFlow<Map<PlyId, SeamState>>

selfId

open override val selfId: PeerId

state

open override val state: StateFlow<SeamState>

Functions

broadcast

open suspend override fun broadcast(payload: ByteArray)

open suspend override fun close(reason: CloseReason)

markWoven

fun markWoven()

Transition this seam from SeamState.Weaving to SeamState.Woven.

sendTo

open suspend override fun sendTo(peer: PeerId, payload: ByteArray)