class

MeshCoreTCPMux::FrameCodec::Decoder

Inherits Reference < Object

Constructors

new(marker : UInt8, assembly_timeout : Time::Span = 5.seconds)

Source

Instance methods

assembly_timeout

Source

check_deadline(now : Time::Span) : Nil

Source

feed(bytes : Bytes, now : Time::Span, & : Bytes -> ) : Nil

Source

finish

Source

marker

Incrementally removes the TCP envelope and returns owned payloads.

now must come from a monotonic clock. The decoder deliberately does not read a clock itself, which keeps deadline handling deterministic and lets a connection's timer fiber use check_deadline while no bytes arrive.

Source

partial?

Source