Struct SseState 

pub struct SseState<P: SseEventProducer> { /* private fields */ }

SSE state shared across connections

Contains the event producer and optional JSON schema for validating events. This state is shared among all connections to the same SSE endpoint.

Implementations

impl<P: SseEventProducer + 'static> SseState<P>

pub fn new(producer: P) -> Self

Create new SSE state with an event producer

Creates a new state without event validation schema. Events are not validated.

Arguments

• producer - The event producer implementation

Example

let state = SseState::new(MyProducer);

pub fn with_schema( producer: P, event_schema: Option<Value>, ) -> Result<Self, String>

Create new SSE state with an event producer and optional event schema

Creates a new state with optional JSON schema for validating outgoing events. If a schema is provided and an event fails validation, it is silently dropped.

Arguments

• producer - The event producer implementation
• event_schema - Optional JSON schema for validating events

Returns

• Ok(state) - Successfully created state
• Err(msg) - Invalid schema provided

Example

use serde_json::json;

let event_schema = json!({
    "type": "object",
    "properties": {
        "count": {"type": "integer"}
    }
});

let state = SseState::with_schema(MyProducer, Some(event_schema))?;

Trait Implementations

impl<P: SseEventProducer> Clone for SseState<P>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.