Struct UploadProgress 

pub struct UploadProgress { /* private fields */ }

Upload progress middleware configuration.

Examples

use tako::middleware::upload_progress::UploadProgress;
use tako::middleware::IntoMiddleware;

// Simple progress tracking (access via ProgressTracker in extensions)
let progress = UploadProgress::new();

// With progress callback
let progress = UploadProgress::new()
    .on_progress(|state| {
        if let Some(pct) = state.percent() {
            println!("Upload: {pct}%");
        }
    })
    .min_notify_interval_bytes(8192); // notify at most every 8KB

Implementations

impl UploadProgress

pub fn new() -> UploadProgress

Creates a new upload progress middleware.

pub fn on_progress<F>(self, f: F) -> UploadProgress

where F: Fn(ProgressState) + Send + Sync + 'static,

Sets a callback that is called as bytes are received.

pub fn min_notify_interval_bytes(self, bytes: u64) -> UploadProgress

Sets the minimum byte interval between progress notifications.

This prevents the callback from being called too frequently for large uploads. Default is 0 (notify on every chunk).

Trait Implementations

impl Default for UploadProgress

fn default() -> UploadProgress

Returns the “default value” for a type.

impl IntoMiddleware for UploadProgress

fn into_middleware( self, ) -> impl Fn(Request<TakoBody>, Next) + Clone + Send + Sync + 'static