CodeVetter · Repo Unpack · Feature catalog

tokio-rs/tokio

Scanned commit 2746c3ae26 dated 2026-10-02 — last upstream commit. Generated by codevetter codevetter 1.15.0 on 2026-10-02. Deep analysis by cli:codex via the codex CLI on 2026-10-02 (425s). Source inspection; upstream code and tests were not executed.

User-facing functionality consists of composable Rust APIs rather than application routes or screens. Tokio provides execution, communication, I/O, timing, and operating-system control, with availability determined by features and targets. Companion libraries expose higher-level framing, cancellation, delayed queues, and stream composition. This catalog groups the inspected API families without claiming every public symbol was examined.

Execution APIs include spawn, spawn_blocking, yield_now, LocalSet/spawn_local, JoinSet, JoinHandle, and AbortHandle; main/test macros generate runtime construction.
tokio/src/task/mod.rs#L277-L320 tokio-macros/src/entry.rs#L468-L519
Networking exposes TCP streams/listeners/sockets, UDP, Unix sockets and FIFO pipes, Windows named pipes, and AsyncFd integration for other I/O resources.
tokio/src/net/mod.rs#L3-L29 tokio/src/net/mod.rs#L38-L64
AsyncRead and AsyncWrite define nonblocking poll interfaces; extension APIs provide operations such as write_all and flush, while filesystem APIs include whole-file writes and synchronization.
tokio/src/io/async_read.rs#L7-L59 tokio/src/io/async_write.rs#L6-L67 tokio/src/fs/write.rs#L5-L26 tokio/src/fs/file.rs#L317-L322
Synchronization exports broadcast, mpsc, oneshot, watch, Mutex, RwLock, Semaphore, Notify, Barrier, OnceCell, and SetOnce.
tokio/src/sync/mod.rs#L454-L497
Timing APIs include sleep/sleep_until, interval/interval_at with MissedTickBehavior, and timeout/timeout_at; Timeout polls its wrapped future before checking expiration.
tokio/src/time/mod.rs#L99-L116 tokio/src/time/timeout.rs#L204-L224
Command supports subprocess spawning and captured output; Child exposes wait-with-output, while signal::ctrl_c provides portable notification through platform implementations.
tokio/src/process/mod.rs#L863-L866 tokio/src/process/mod.rs#L1065-L1071 tokio/src/process/mod.rs#L1446-L1472 tokio/src/signal/ctrl_c.rs#L1-L16
tokio-util provides codec, compatibility, I/O, task, and time modules; CancellationToken offers child propagation, and DelayQueue returns keyed values after deadlines.
tokio-util/src/lib.rs#L25-L65 tokio-util/src/sync/cancellation_token.rs#L204-L247 tokio-util/src/time/delay_queue.rs#L23-L55
tokio-stream supplies StreamExt adapters and resource wrappers; StreamMap merges dynamically inserted streams while preserving each emitted item's source key.
tokio-stream/src/lib.rs#L76-L117 tokio-stream/src/wrappers.rs#L10-L70 tokio-stream/src/stream_map.rs#L9-L27