Struct PartialTransferManager 

pub struct PartialTransferManager { /* private fields */ }

Manager for partial message transfers

Implementations

impl PartialTransferManager

pub fn new() -> Self

Create a new transfer manager with default configuration

pub fn with_config(config: TransferConfig) -> Self

Create a new transfer manager with custom configuration

pub async fn start_transfer(&self, total_bytes: usize) -> Result<TransferId>

Start a new transfer session

Arguments

• total_bytes - Total size of data to transfer

Returns

Transfer ID for the new session

pub async fn update_progress( &self, id: TransferId, bytes_transferred: usize, chunk_index: usize, ) -> Result<()>

Update transfer progress

Arguments

• id - Transfer ID
• bytes_transferred - Total bytes transferred so far
• chunk_index - Current chunk index

pub async fn complete_transfer(&self, id: TransferId) -> Result<()>

Mark transfer as completed

pub async fn interrupt_transfer(&self, id: TransferId) -> Result<()>

Interrupt transfer (can be resumed if configured)

pub async fn resume_transfer(&self, id: TransferId) -> Result<usize>

Resume an interrupted transfer

pub async fn fail_transfer(&self, id: TransferId, error: String) -> Result<()>

Fail a transfer with error message

pub async fn get_transfer(&self, id: TransferId) -> Option<TransferInfo>

Get transfer information

pub async fn active_transfers(&self) -> Vec<TransferInfo>

Get all active transfers

pub async fn cleanup_completed(&self)

Remove completed or failed transfers

pub async fn cleanup_timed_out(&self)

Remove transfers that have timed out

Trait Implementations

impl Default for PartialTransferManager

fn default() -> Self

Returns the “default value” for a type.