🥮 mooncakes.io
README

colmugx/acp/transport does not have a README file

#
FramingError

source
pub(all) suberror FramingError {
  InvalidMaxFrameSize
  Closed
  EmptyFrame
  InvalidUtf8
  FrameTooLarge(limit~ : Int, actual~ : Int)
  UnexpectedEof
} derive(Eq, 
Debug)

Errors raised by the newline-delimited transport boundary.

Framing deliberately does not parse JSON. Every non-empty line is emitted as a UTF-8 frame so that transport noise cannot be silently discarded; the JSON-RPC codec remains the next, explicit validation step.

#
FramingState

source
pub(all) struct FramingState {
  pending : Bytes
  max_frame_bytes : Int
  closed : Bool
} derive(Eq, 
Debug)

Immutable state for a newline-delimited decoder.

#
FramingStep

source
pub(all) struct FramingStep {
  state : FramingState
  frames : Array[String]
} derive(Eq, 
Debug)

Frames emitted by one feed operation and the state for the next operation.

#
framing_feed

source
fn framing_feed(state : FramingState, chunk : Bytes) -> FramingStep raise FramingError

Feed an arbitrary byte chunk. A chunk may contain partial or multiple frames. CRLF is accepted by removing the CR immediately before LF.

#
framing_finish

source
fn framing_finish(state : FramingState) -> FramingStep raise FramingError

Finish the stream. A partial line is never silently discarded.

#
framing_state

source
fn framing_state(max_frame_bytes~ : Int) -> FramingState raise FramingError

Create a decoder with a positive maximum payload size in bytes.

#
stdio_transport

source

Thin native stdio adapter. The caller supplies the handler and redacted trace sink; this adapter never writes diagnostics to stdout.

Source Files

Powered by MoonBit

Site sourceReport issuePackagesBuild queueSkillsStatistics

© 2026 mooncakes.io