kuilt-test/us.tractat.kuilt.test/ControllableSeam

ControllableSeam

A Seam produced by ControllableLoom. Delivery is controlled by the parent loom; callers interact with it identically to any other Seam.

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>>

The loom's shared registry while this seam is live, and exactly { selfId } once it has closed (#2443, obligation from #1816). Handing the raw registry through failed both halves at once: a torn seam kept naming every remaining remote, and close removes this peer from that registry so its own id went missing too.

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)

sendTo

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