Struct AdaptiveStreamController 

pub struct AdaptiveStreamController { /* private fields */ }

Adaptive streaming controller

Implementations

impl AdaptiveStreamController

pub fn new() -> Self

Create an empty controller with no active sessions.

pub async fn create_session( &self, data: Value, options: StreamOptions, ) -> PjsResult<String>

Create new streaming session

pub async fn start_streaming(&self, session_id: &str) -> PjsResult<()>

Start streaming frames for session

pub async fn handle_frame_ack( &self, session_id: &str, frame_id: u32, processing_time_ms: u64, ) -> PjsResult<()>

Handle frame acknowledgment

pub fn subscribe_frames(&self) -> Receiver<(String, WsMessage)>

Get subscriber for frame events

pub async fn set_rate_limit_guard( &self, session_id: &str, guard: RateLimitGuard, ) -> PjsResult<()>

Set rate limit guard for a session

pub async fn validate_message( &self, session_id: &str, frame_size: usize, ) -> PjsResult<()>

Validate message against rate limits

pub async fn remove_session(&self, session_id: &str) -> bool

Remove a single session by id.

Returns true if the session existed and was removed, false if the id was not present. Callers may safely invoke this multiple times — the second call is a no-op.

Examples

let controller = AdaptiveStreamController::new();
let id = controller.create_session(json!({}), StreamOptions::default()).await.unwrap();
assert!(controller.remove_session(&id).await);
// Idempotent — second call is a no-op:
assert!(!controller.remove_session(&id).await);

pub async fn cleanup_expired_sessions(&self, max_age: Duration)

Clean up expired sessions

Trait Implementations

impl Default for AdaptiveStreamController

fn default() -> Self

Returns the “default value” for a type.