Function process_inbound
pub(super) fn process_inbound(
reader: &mut PacketReader<GrowBuffer>,
client: &mut Client<JournaledSession>,
outbound: &mut PacketWriter<GrowBuffer>,
pending: &mut Pending,
inbound_aliases: &mut InboundAliases,
outbound_aliases: &mut OutboundAliases,
pending_messages: &mut VecDeque<Message>,
) -> Option<(DisconnectReason, bool)>Expand description
Decodes and handles every complete packet currently framed in reader, in
order, stopping when the delivery buffer reaches MSG_QUEUE_BOUND (so a
slow consumer applies backpressure) or a terminal event occurs.
Returns Some((reason, graceful)) when the connection should end;
graceful is true when a DISCONNECT was enqueued and should be flushed.