Struct DownloadStore 

pub struct DownloadStore { /* private fields */ }

Every transfer koan knows about.

Implementations

impl DownloadStore

pub fn new() -> Arc<Self>

pub fn version(&self) -> u64

Bumped when an entry appears, settles or is forgotten — not when its byte count moves. A client redraws its list on this and reads the counters every frame regardless.

pub fn figures(&self) -> u64

Bumped whenever a byte count or a rate here moved. What a client redraws a figure on, as against version, which is the list itself changing shape.

pub fn all(&self) -> Vec<Download>

Everything, running first, then whatever settled most recently.

pub fn get(&self, id: QueueItemId) -> Option<Download>

The transfer for one queue item, if there is one.

A scan, deliberately: entries are bounded by the number of download workers plus the settled tail, because a transfer only appears here when a worker picks it up. Indexing tens of rows would cost more to maintain than it saves.

pub fn phase_of(&self, id: QueueItemId) -> Option<Phase>

Whether a transfer exists for this item and what it is doing, without cloning its paths and titles — what deriving a queue row needs, per row per frame.

pub fn active(&self) -> usize

How many transfers are actually moving.

pub fn queued(&self, download: Download)

Note that a transfer is wanted. Replaces any earlier entry for the same queue item — a track cleared and fetched again is the same row starting over, not a second one.

pub fn started(&self, id: QueueItemId, total: u64, written: Arc<ByteFeed>)

Bytes have started arriving, and this is how many there are in total.

pub fn finished(&self, id: QueueItemId)

It landed.

pub fn failed(&self, id: QueueItemId, reason: String)

It did not.

pub fn clear_settled(&self)

Drop everything that has already settled. The running ones are not this call’s business — stopping a transfer is a different verb.

impl DownloadStore

pub fn progressed(&self)

Take a rate reading, if one is due.

Called by the downloader as bytes land, not by a timer: what knows a transfer moved is the code moving it, and what knows it stopped is the absence of the next call. Chunks arrive far faster than a figure needs redrawing, so this is gated to MIN_SAMPLE_GAP before it touches the list every client is reading.

Every running transfer is sampled, not just the one that moved: a transfer that has stalled has nothing to report by definition, and its figure decaying to zero is the one worth noticing.

Rates live here rather than in each front end because every one of them would otherwise keep its own last-reading map and get a different answer.

Trait Implementations

impl Debug for DownloadStore

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

Formats the value using the given formatter.

impl Default for DownloadStore

fn default() -> DownloadStore

Returns the “default value” for a type.