longhuanlin/multipart-stream/mixed

README
U
AuditSummary
U
AuditedSink
U
ChunkSourceAdapter
U
DecodedField
U
FieldCollector
U
FieldCollectorLimits
U
FormError
U
FormField
U
HeaderField
U
LimitKind
U
Limits
U
MeasuredSink
U
MediaType
U
MixedError
U
MixedEvent
U
MixedLimits
U
MixedPart
U
MixedStream
U
MultipartDiagnostic
U
MultipartError
U
MultipartEvent
U
MultipartParser
U
MultipartPlan
U
MultipartWriter
U
Parameter
U
ParserPhase
U
ParserStats
U
PartDigest
U
PartMeta
U
PartSinkAdapter
U
PlannedEmitter
U
PlannedPart
U
SinkMetrics
U
UploadError
U
UploadPart
U
UploadPartKind
U
UploadPipeline
U
UploadPolicy
U
UploadProgress
U
UploadReceipt
U
UploadSink
V
body_contains_boundary
V
boundary_from_entropy
V
crc32_finish
V
crc32_initial
V
crc32_update
V
decode_extended_filename
V
default_field_collector_limits
V
default_limits
V
default_mixed_limits
V
default_upload_policy
V
drive_events
V
expand_mixed
V
format_content_type
V
format_part_headers
V
parse_content_type
V
parse_from_source
V
parse_part_headers
V
plan
V
redact_error
V
validate_boundary

longhuanlin/multipart-stream/mixed does not have a README file

MixedError

pub(all) suberror MixedError {
  InvalidLimits(reason~ : String)
  DepthExceeded(limit~ : Int, observed~ : Int)
  ContainerTooLarge(limit~ : Int64, observed~ : Int64)
  InvalidContainer(reason~ : String)
  UnexpectedEvent(reason~ : String)
  Protocol(error~ : @longhuanlin/multipart-stream/model.MultipartError
MultipartError)
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

ActiveMixed

source

pub struct ActiveMixed {
  part_index : Int
  parser : @longhuanlin/multipart-stream/parser.MultipartParser
MultipartParser
  child : MixedStream
  observed_bytes : Int64
}

ActivePart

source

pub enum ActivePart {
  Leaf(Int)
  Container(ActiveMixed)
}

MixedEvent

source

pub(all) struct MixedEvent {
  depth : Int
  parent_part_index : Int?
  event : @longhuanlin/multipart-stream/model.MultipartEvent
MultipartEvent
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

One event after recursively expanding legacy multipart/mixed containers. Container envelopes are suppressed; leaf events retain their original protocol metadata, depth, and immediate container part index.

MixedLimits

source

pub(all) struct MixedLimits {
  max_depth : Int
  max_parts_per_container : Int
  max_container_bytes : Int64
  max_part_bytes : Int64
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Bounds for recursive legacy multipart/mixed expansion.

MixedPart

source

pub(all) struct MixedPart {
  depth : Int
  parent_part_index : Int?
  meta : @longhuanlin/multipart-stream/model.PartMeta
PartMeta
  body : Bytes
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

One owned leaf part returned by the compatibility batch helper.

MixedStream

source

pub struct MixedStream {
  limits : MixedLimits
  depth : Int
  parent_part_index : Int?
  emit_message_end : Bool
  active : ActivePart?
  completed : Bool
}

MixedStream::feed

source

fn MixedStream::feed(self : MixedStream, events : Array[@longhuanlin/multipart-stream/model.MultipartEvent
MultipartEvent]) -> Array[MixedEvent] raise MixedError

Transform one batch of top-level parser events. Feed this method after each MultipartParser::feed result; nested leaf data can be emitted before the outer container has ended.

MixedStream::finish

source

fn MixedStream::finish(self : MixedStream) -> Unit raise MixedError

Require that the event stream has completed without a partial container.

MixedStream::new

source

fn MixedStream::new(limits? : MixedLimits) -> MixedStream raise MixedError

Create an incremental transformer for top-level multipart parser events.

default_mixed_limits

source

fn default_mixed_limits() -> MixedLimits

expand_mixed

source

fn expand_mixed(content_type : String, body : Bytes, inherited_name : String, limits? : MixedLimits) -> Array[MixedPart] raise MixedError

Compatibility helper for callers that already own a complete container. New upload paths should use MixedStream directly to avoid buffering the nested body before parsing it.