remote/dev.s7a.strata.runtime.remote/RemoteConnection

RemoteConnection

class RemoteConnection(types: Set<ProjectionType>, limits: RemoteLimits = RemoteLimits(), send: (ByteArray) -> Unit) : AutoCloseable(source)

Protocol negotiation and ordered transport for one authenticated connection, confined to its execution owner. The adapter supplies authenticated bytes and synchronous transport writes, never arbitrary peers. The fixed bootstrap limits apply until both greetings have been sent; thereafter both sides use their intersection. All partial buffers and the transport callback are released on close or protocol failure.

Constructors

RemoteConnection

constructor(types: Set<ProjectionType>, limits: RemoteLimits = RemoteLimits(), send: (ByteArray) -> Unit)

Types

Companion

object Companion

Stable channel and wire-version identifiers shared by platform adapters.

Properties

capabilities

var capabilities: RemoteCapabilities?

Functions

open override fun close()

discardSession

fun discardSession(identity: Long)

Releases unsent work for a terminal session, retaining only ordered cancellation for an already started fragment group. Callers must separately send its typed Close notification; active business actions are never coalesced.

flush

fun flush(maxFrames: Int = 8)

Flushes at most maxFrames queued frames, bounding work and transport pressure per adapter tick.

receive

fun receive(bytes: ByteArray, nowMillis: Long): RemoteMessage?

Accepts one frame and returns only complete post-negotiation application messages. The first peer greeting is consumed here; a repeated greeting or premature application message is rejected.

send

fun send(message: RemoteMessage)

Sends one application message after successful capability negotiation. Queue exhaustion fails the connection explicitly; actions are never dropped silently.

start

fun start()

Sends the one bootstrap greeting once the underlying play connection can carry custom payloads.

tick

fun tick(nowMillis: Long)

Applies assembly and negotiation deadlines even when the peer sends no more fragments.