Struct PeerHandle 

pub struct PeerHandle { /* private fields */ }

Per-peer handle for submitting fetch commands and awaiting responses.

Cheap to Clone (one Arc bump). When the last clone is dropped, the peer-level cancel token fires, aborting all in-flight fetches for this peer.

Implementations

impl PeerHandle

pub fn abr(&self) -> &AbrHandle

ABR-side handle attached at registration.

pub async fn batch( &self, cmds: Vec<FetchCmd>, ) -> Vec<Result<FetchResponse, NetError>>

Submit a batch of fetch commands and await all responses.

Commands execute in parallel. Results are returned in array order, not completion order.

Errors

Individual commands may fail independently. Each slot in the returned Vec contains its own Result.

pub fn bus(&self) -> Option<EventBus>

Currently attached bus, if any.

pub fn cancel(&self) -> CancellationToken

Peer-level cancellation token.

Cancelling this token aborts all in-flight fetches for this peer. The cancel also fires automatically when the last clone of this handle is dropped.

pub async fn execute(&self, cmd: FetchCmd) -> Result<FetchResponse, NetError>

Submit a single fetch command and await the response.

Always runs at High priority — imperative requests are latency-sensitive.

Errors

Returns NetError::Cancelled when the peer cancel fires, the downloader shuts down, or the HTTP request itself fails.

pub fn peer_id(&self) -> AbrPeerId

ABR peer identifier for this handle.

pub fn with_bus(self, bus: EventBus) -> Self

Attach an event bus so the Downloader can publish per-peer DownloaderEvents and the ABR controller can publish AbrEvents to it. Returns self so the call chains naturally after Downloader::register.

Trait Implementations

impl Clone for PeerHandle

fn clone(&self) -> PeerHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PeerHandle

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

Formats the value using the given formatter.