apply_packet_id_rows

finmqtt_tokio::persistence::turso::store

Function apply_packet_id_rows 

async fn apply_packet_id_rows(
    stmt: &mut Statement,
    session: &mut InMemorySession,
    ctor: impl Fn(PacketId) -> SessionOp<'static>,
) -> Result<()>
Available on crate feature turso only.
Expand description

Runs a no-parameter query whose rows are each a single packet id, applying ctor(packet_id) to session for every row (the shape shared by the pubrel and incoming-QoS-2 restore queries).