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() -> Self

Creates a new upload progress middleware.

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

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) -> Self

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() -> Self

Returns the “default value” for a type.

impl IntoMiddleware for UploadProgress

fn into_middleware( self, ) -> impl Fn(Request, Next) -> Pin<Box<dyn Future<Output = Response> + Send + 'static>> + Clone + Send + Sync + 'static