Struct SseConnection 

pub struct SseConnection { /* private fields */ }

A reserved SSE stream slot, released when dropped.

Keep it alive for as long as the stream it guards: move it into the stream so the slot is freed when the client disconnects or the stream ends.

Examples

use ironflow_api::sse_limiter::SseLimiter;
use uuid::Uuid;

let limiter = SseLimiter::default();
let connection = limiter.try_acquire(Uuid::now_v7())?;
assert_eq!(limiter.open_connections(), 1);
drop(connection);
assert_eq!(limiter.open_connections(), 0);

Trait Implementations

impl Debug for SseConnection

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

Formats the value using the given formatter.

impl Drop for SseConnection

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.