#streaming-io code explainers

rust

use std::sync::Arc;
use axum::{
    extract::{Multipart, State},
    http::StatusCode,

Throttling file uploads in Axum with a Semaphore

concurrency backpressure multipart

Advanced 8 steps

go

func handleUpload(w http.ResponseWriter, r *http.Request) {
	if err := r.ParseMultipartForm(32 << 20); err != nil {
		http.Error(w, "failed to parse form: "+err.Error(), http.StatusBadRequest)
		return

Handling multi-file uploads in Go

multipart file-upload http-handler

Intermediate 9 steps

ruby

require "digest"
 
class UploadDeduplicator
  CHUNK_SIZE = 64 * 1024

Deduplicating uploads by content hash

hashing deduplication streaming-io

Intermediate 7 steps

python

import time
from concurrent.futures import ThreadPoolExecutor, as_completed
from pathlib import Path

Parallel file downloads with a thread pool

concurrency thread-pool streaming-io

Intermediate 8 steps