Struct HttpDownstream 

pub struct HttpDownstream {
    pub pending: Mutex<HashMap<String, Sender<String>>>,
    pub broadcast: Sender<String>,
}

Shared state between the HTTP server and the relay core.

Fields

pending: Mutex<HashMap<String, Sender<String>>>

Responses the HTTP layer is waiting on, keyed by canonical id.

broadcast: Sender<String>

Frames with no waiting POST (server-initiated traffic) fan out to every open GET SSE stream.

Implementations

impl HttpDownstream

pub fn new() -> Arc<Self>

pub async fn route_upstream_frame(&self, frame: String)

Route one upstream frame: complete the waiting POST if there is one, otherwise broadcast to SSE subscribers. Called by the relay core for every (post-interception) upstream frame.