Struct PageHandle 

pub struct PageHandle { /* private fields */ }

Implementations

impl PageHandle

pub fn new( target_id: TargetId, session_id: SessionId, opener_id: Option<TargetId>, request_timeout: Duration, page_wake: Option<Arc<Notify>>, ) -> Self

Create a PageHandle with the default per-page channel capacity (DEFAULT_PAGE_CHANNEL_CAPACITY). Preserved unchanged for backwards compatibility — call with_capacity to override.

pub fn with_capacity( target_id: TargetId, session_id: SessionId, opener_id: Option<TargetId>, request_timeout: Duration, page_wake: Option<Arc<Notify>>, capacity: usize, ) -> Self

Create a PageHandle with a caller-chosen channel capacity.

capacity is the tokio mpsc buffer size for TargetMessages flowing from this page to the handler. Capacity is clamped to at least 1 because tokio::sync::mpsc::channel(0) panics; callers passing 0 get a 1-slot channel instead of an abort.

Under bursty per-page load, larger capacities reduce the rate at which CommandFuture / TargetMessageFuture fall back to the boxed async-send slow path on TrySendError::Full; smaller capacities apply back-pressure sooner at the cost of that fallback.

Trait Implementations

impl Debug for PageHandle

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.