MeshCoreTCPMux::Broker

new(epoch : Int64, self_key : Bytes, config : MeshCoreTCPMux::Config = Config.new, now : Time::Span = Time::Span.zero, orphan : Bytes | Nil = nil, dedicated_slots : Hash(Int32, MeshCoreTCPMux::DedicatedClientSlot) = Hash(Int32, DedicatedClientSlot).new, radio_state : MeshCoreTCPMux::CompanionRadioState = CompanionRadioState.new)

admit(id : Int64, now : Time::Span, dedicated_slot_id : Int32 | Nil = nil) : Nil

client_closed(id : Int64, now : Time::Span, reason = "client disconnected", category = :normal) : Nil

client_frame(id : Int64, payload : Bytes, now : Time::Span) : Nil

drain_uncertain_frame(payload : Bytes, now : Time::Span) : Bool

fail_epoch(reason : String) : Nil

tick(now : Time::Span) : Nil

upstream_frame(payload : Bytes, now : Time::Span) : Nil

write_failed(id : Int64, epoch : Int64, reason : String, now : Time::Span) : Nil

written(id : Int64, epoch : Int64, write_id : Int64, now : Time::Span) : Nil