Module inbound
Expand description
Inbound packet processing: framing, dispatch through the client state machine, and buffering received messages for delivery.
Functionsยง
- handle_
incoming ๐ - Handles one decoded inbound packet: runs it through the client state machine, enqueues any response, and buffers a received message for delivery to the application.
- process_
inbound ๐ - Decodes and handles every complete packet currently framed in
reader, in order, stopping when the delivery buffer reachesMSG_QUEUE_BOUND(so a slow consumer applies backpressure) or a terminal event occurs.