Struct FrameFanout 

pub struct FrameFanout { /* private fields */ }

The live-frame fan-out for one browser.

Implementations

impl FrameFanout

pub fn new(width: u32, height: u32, default_quality: i64) -> Self

pub fn set_blackout(&self, active: bool)

Mirror of the control state’s blackout predicate. Called on every control-state change.

pub fn blackout_active(&self) -> bool

pub async fn bind(&self, backend: Arc<ChromiumBackend>)

Point the fan-out at a launched browser. Called once the assistant’s Chromium actually exists; starts capture immediately if anyone is already subscribed (the drawer opened first, the browser launched second — the ordinary case for the standing session).

pub async fn subscribe( &self, audience: FrameAudience, ) -> (FrameReceiver, Instant)

Register a consumer. The first one starts CDP capture (via the supervisor); dropping the returned receiver deregisters it at the next frame. Returns the epoch its frames are timestamped against.

pub fn quality(&self) -> i64

The quality the pump is currently capturing at.

pub async fn set_quality(&self, quality: i64)

Re-capture at quality. A no-op when it already matches; otherwise the current pump generation is stopped so the supervisor re-attaches at the new quality. Consumers keep their subscriptions across it.

This exists because ONE pump now serves both the drawer and browser_record_start, whose documented quality parameter would otherwise silently stop having an effect.

pub async fn prune(&self)

Drop consumers whose receiver has gone away and, if that was the last one, wake the supervisor so it stops CDP capture now rather than at whatever future moment the page next happens to change.