Struct ResumptionManager 

pub struct ResumptionManager { /* private fields */ }

Manager for handling connection resumption.

Implementations

impl ResumptionManager

pub fn new(event_store: Arc<dyn EventStore>, session_id: String) -> Self

Create a new resumption manager.

pub async fn record_outbound(&self, message: TransportMessage) -> Result<()>

Record an outbound message.

pub async fn record_inbound(&self, message: TransportMessage) -> Result<()>

Record an inbound message.

pub async fn create_token(&self) -> Result<ResumptionToken>

Create a resumption token for the current state.

pub async fn resume_from_token(&self, token: &str) -> Result<Vec<StoredEvent>>

Resume from a token, returning events since last acknowledgement.

pub async fn get_pending_events( &self, since_event_id: &str, ) -> Result<Vec<StoredEvent>>

Get pending events that need to be resent.

Trait Implementations

impl Debug for ResumptionManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.