Struct AcquisitionDeduplicator 

pub struct AcquisitionDeduplicator { /* private fields */ }

In-flight acquisition tracking for deduplication

Implementations

impl AcquisitionDeduplicator

pub fn new() -> Self

Create a new acquisition deduplicator

pub fn is_in_flight(&self, key: &str) -> Result<bool, String>

Check if an acquisition is already in flight

pub fn register_acquisition( &self, key: String, receiver: Receiver<Result<AcquisitionResult, ContentTransferError>>, ) -> Result<bool, String>

Register a new in-flight acquisition Returns true if this is the first acquisition, false if joining existing

pub fn mark_complete( &self, key: &str, _result: Result<AcquisitionResult, ContentTransferError>, ) -> Result<(), String>

Mark an acquisition as complete and notify all waiters

Trait Implementations

impl Clone for AcquisitionDeduplicator

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for AcquisitionDeduplicator

fn default() -> Self

Returns the “default value” for a type.