remote/dev.s7a.strata.runtime.remote/RemoteFrameInbox

RemoteFrameInbox

class RemoteFrameInbox(limits: RemoteLimits = RemoteLimits()) : AutoCloseable(source)

Bounded ingress between network callbacks and the connection's owner thread. Exhaustion permanently fails the inbox and clears its bytes; the owner must terminate the connection. Queue entries own defensive byte snapshots, bounded by both byte count and entry count.

Constructors

RemoteFrameInbox

constructor(limits: RemoteLimits = RemoteLimits())

Properties

failed

val failed: Boolean

Functions

open override fun close()

offer

fun offer(frame: ByteArray): Boolean

Enqueues a frame from any thread, returning false after close or a terminal bound violation.

poll

fun poll(): ByteArray?

Transfers one queued snapshot to the owner, or returns null when no frame is pending.