longhuanlin/multipart-stream/writer

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/writer does not have a README file

MultipartPlan

pub struct MultipartPlan {
  // private fields
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Exact, validated multipart framing plan suitable for an HTTP Content-Length header or admission-control decision.

MultipartPlan::content_length

source

fn MultipartPlan::content_length(self : MultipartPlan) -> Int64

MultipartPlan::parts

source

fn MultipartPlan::parts(self : MultipartPlan) -> Array[PlannedPart]

MultipartWriter

source

pub struct MultipartWriter {
  // private fields
}

MultipartWriter::begin_part

source

fn MultipartWriter::begin_part(self : MultipartWriter, meta : @longhuanlin/multipart-stream/model.PartMeta
PartMeta) -> Bytes raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError

MultipartWriter::bytes_emitted

source

fn MultipartWriter::bytes_emitted(self : MultipartWriter) -> Int64

MultipartWriter::content_type

source

fn MultipartWriter::content_type(self : MultipartWriter) -> String

MultipartWriter::end_part

source

fn MultipartWriter::end_part(self : MultipartWriter) -> Bytes raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError

MultipartWriter::finish

source

fn MultipartWriter::finish(self : MultipartWriter) -> Bytes raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError

MultipartWriter::new

source

fn MultipartWriter::new(boundary : String, limits : @longhuanlin/multipart-stream/model.Limits
Limits) -> MultipartWriter raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError

MultipartWriter::write

source

fn MultipartWriter::write(self : MultipartWriter, chunk : Bytes) -> Bytes raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError

PlannedEmitter

source

pub struct PlannedEmitter {
  // private fields
}

State-machine wrapper around MultipartWriter that binds one emitted message to a previously validated content-length plan.

PlannedEmitter::begin_next

source

fn PlannedEmitter::begin_next(self : PlannedEmitter) -> Bytes raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError

PlannedEmitter::end_next

source

fn PlannedEmitter::end_next(self : PlannedEmitter) -> Bytes raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError

PlannedEmitter::finish

source

fn PlannedEmitter::finish(self : PlannedEmitter) -> Bytes raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError

PlannedEmitter::new

source

fn PlannedEmitter::new(plan : MultipartPlan) -> PlannedEmitter raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError

PlannedEmitter::write_chunk

source

fn PlannedEmitter::write_chunk(self : PlannedEmitter, chunk : Bytes) -> Bytes raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError

PlannedPart

source

pub struct PlannedPart {
  // private fields
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

A body whose length is known before multipart framing is emitted. The plan intentionally stores metadata and a count only; body ownership stays with the transport application.

PlannedPart::new

source

fn PlannedPart::new(meta : @longhuanlin/multipart-stream/model.PartMeta
PartMeta, body_length : Int64) -> PlannedPart raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError

plan

source

fn plan(boundary : String, parts : Array[PlannedPart], limits : @longhuanlin/multipart-stream/model.Limits
Limits) -> MultipartPlan raise @longhuanlin/multipart-stream/model.MultipartError
MultipartError