Struct SseActor 

pub struct SseActor { /* private fields */ }

The SSE-based actor that continuously:

• Reads incoming events from the SSE stream.
• Sends outgoing messages via HTTP POST (once the post endpoint is known).

Implementations

impl SseActor

pub fn new( receiver: Receiver<TransportMessage>, pending_requests: Arc<PendingRequests>, sse_url: String, post_endpoint: Arc<RwLock<Option<String>>>, ) -> Self

pub async fn run(self)

The main entry point for the actor. Spawns two concurrent loops:

1. handle_incoming_messages (SSE events)
2. handle_outgoing_messages (sending messages via POST)