-
mio
Lightweight non-blocking I/O
-
tonic
A gRPC over HTTP/2 implementation focused on high performance, interoperability, and flexibility
-
futures
streams featuring zero allocations, composability, and iterator-like interfaces
-
tower
modular and reusable components for building robust clients and servers
-
tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
tokio-rustls
Asynchronous TLS/SSL streams for Tokio using Rustls
-
futures-lite
Futures, streams, and async I/O combinators
-
mlua
High level bindings to Lua 5.4/5.3/5.2/5.1 (including LuaJIT) and Roblox Luau with async/await features and support of writing native Lua modules in Rust
-
h2
An HTTP/2 client and server
-
rdkafka
Rust wrapper for librdkafka
-
async-io
Async I/O and timers
-
tower-http
Tower middleware and utilities for HTTP clients and servers
-
oneshot
spsc channel with (potentially) lock-free non-blocking send, and a receiver supporting both thread blocking receive operations as well as Future based async polling
-
futures-timer
Timeouts for futures
-
axum-server
High level server designed to be used with axum framework
-
bb8
Full-featured async (tokio-based) connection pool (like r2d2)
-
async-stream
Asynchronous streams using async & await notation
-
pollster
Synchronously block the thread until a future completes
-
futures-concurrency
Structured concurrency operations for async Rust
-
async-process
Async interface for working with processes
-
socketcan
Linux SocketCAN library. Send and receive CAN frames via CANbus on Linux.
-
io-uring
The low-level
io_uring
userspace interface for Rust -
async-broadcast
Async broadcast channels
-
scc
High-performance containers and utilities for concurrent and asynchronous programming
-
interprocess
communication toolkit
-
async-openai
OpenAI
-
tower-sessions
🥠 Sessions as a
tower
andaxum
middleware -
want
Detect when another Future wants a result
-
tokio-serial
A serial port implementation for tokio
-
async_zip
An asynchronous ZIP archive reading/writing crate
-
embassy-executor
async/await executor designed for embedded usage
-
minus
An asynchronous data feedable terminal paging library for Rust
-
paho-mqtt
The Official Eclipse Paho MQTT Rust Client Library. This is a wrapper around the Paho C library
-
keycloak
Admin REST API
-
tokio-tar
async TAR file reader and writer. This library does not currently handle compression, but it is abstract over all I/O readers and writers. Additionally, great lengths are taken to ensure that the entire…
-
ractor
A actor framework for Rust
-
tracing-actix-web
Structured logging middleware for actix-web
-
futures-buffered
future concurrency primitives with emphasis on performance and low memory usage
-
salvo-serde-util
serde util for salvo
-
remoc
🦑 Remote multiplexed objects, channels, observable collections and RPC making remote interactions seamless. Provides multiple remote channels and RPC over TCP, TLS or any other transport.
-
kameo
Fault-tolerant Async Actors Built on Tokio
-
csv-async
CSV parsing for async
-
monoio
A thread per core runtime based on iouring
-
futures-locks
Futures-aware lock primitives
-
apalis
extensible multithreaded background job processing for Rust
-
web-push
Web push notification client with support for http-ece encryption and VAPID authentication
-
containerd-shim
containerd shim extension
-
axum-valid
validation extractors for your Axum application, allowing you to validate data using validator, garde, validify or all of them
-
command-group
Extension to Command to spawn in a process group
-
openraft
Advanced Raft consensus
-
futures-signals
Zero cost FRP signals using the futures crate
-
asynchronous-codec
encoding and decoding frames using
async/await
-
gix-actor
A way to identify git actors
-
failsafe
A circuit breaker implementation
-
tokio-graceful-shutdown
perform a graceful shutdown on a Tokio based service
-
tokio-graceful
util for graceful shutdown of tokio applications
-
tor-rtcompat
Compatibility layer for asynchronous runtimes, used by Tor
-
stream-download
streaming content to a local cache
-
unicycle
A scheduler for driving a large number of futures
-
madsim
Deterministic Simulator for distributed systems
-
capnp-futures
async serialization for Cap'n Proto messages
-
redis-async
An asynchronous futures based Redis client for Rust using Tokio
-
rxrust
Reactive Extensions
-
pi-async-rt
Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
-
pingora
A framework to build fast, reliable and programmable networked systems at Internet scale
-
actix
Actor framework for Rust
-
axum-streams
HTTP body streaming support for Axum: json/csv/protobuf/arrow/txt
-
rsmq_async
Async RSMQ port to rust. RSMQ is a simple redis queue system that works in any redis v2.4+. It contains the same methods as the original one in https://github.com/smrchy/rsmq
-
eventsource-stream
A basic building block for building an Eventsource from a Stream of bytes
-
swiftide
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
async-global-executor
A global executor built on top of async-executor and async-io
-
exponential-backoff
An exponential backoff generator with jitter
-
async-shutdown
one-stop solution for async graceful shutdown
-
async-task
Task abstraction for building executors
-
tokio-metrics
Runtime and task level metrics for Tokio applications
-
r2g_mlua
High level bindings to Lua 5.4/5.3/5.2/5.1 (including LuaJIT) and Roblox Luau with async/await features and support of writing native Lua modules in Rust
-
event-listener
Notify async tasks or threads
-
tokio-pipe
Asynchronous pipe(2) library using tokio
-
twilight-standby
filter wait for filtered incoming events for the Twilight ecosystem
-
service-async
A Service like tower in async style
-
volo
high-performance and strong-extensibility Rust RPC framework that helps developers build microservices
-
gearbox
Excessive tooling for Rust, boosting productivity and operations
-
esrs
A Prima.it-opinionated library to achieve cqrs/es
-
async-memcached
An Tokio-based memcached client for Rust
-
eyeball
Add observability to your Rust types!
-
rustix-uring
The low-level
io_uring
userspace interface for Rust -
async-walkdir
Asynchronous directory traversal for Rust
-
fluvio-future
I/O futures for Fluvio project
-
mio-serial
A serial port implementation for mio
-
tokio-io-utility
Some helper functions for tokio::io
-
tokio-retry
Extensible, asynchronous retry behaviours for futures/tokio
-
tor-rpcbase
Low level functionality for Arti's RPC service
-
kdbplus
Dual q/kdb+ interface for API to build a shared library and an IPC client
-
rusty_falcon
Rust bindings for CrowdStrike Falcon API
-
tmq
ZeroMQ bindings for Tokio
-
tauri-specta
Completely typesafe Tauri commands
-
tokio-native-tls
TLS/SSL streams for Tokio using native-tls giving an implementation of TLS for nonblocking I/O streams
-
future-queue
Adapters to manage a queue of futures, where each future can have a different weight
-
futures-bounded
bounding futures in size and time
-
crb
CRB | Composable Runtime Blocks
-
poll-promise
Poll the result of an async operation in a game or immediate mode GUI
-
specta
Easily export your Rust types to other languages
-
pharos
Observer pattern which generates a futures 0.3 stream of events
-
stream-cancel
interrupting asynchronous streams
-
wasm-bindgen-futures
Bridging the gap between Rust Futures and JavaScript Promises
-
fmmap
A flexible and convenient high-level mmap for zero-copy file I/O
-
deno_unsync
A collection of adapters to make working with Tokio single-threaded runtimes easier
-
svix
Svix webhooks API client and webhook verification library
-
nb
Minimal non-blocking I/O layer
-
ipc-queue
FIFO queue described in fortanix-sgx-abi used for asynchronous usercalls
-
async-graphql-value
GraphQL value for async-graphql
-
fn_graph
Runs interdependent logic concurrently, starting each function when predecessors have completed
-
cxx-async
interoperability between C++ coroutines and asynchronous Rust
-
poem-openapi
OpenAPI support for Poem
-
futures-rustls
Asynchronous TLS/SSL streams for futures using Rustls
-
yaque
disk-backed persistent queue for Rust
-
scoped-futures
imposing upper bounds on Future lifetimes
-
ws_stream_tungstenite
Provide AsyncRead/AsyncWrite over Tungstenite WebSockets
-
async-scoped
Spawn scoped (non 'static) asynchronous futures for async_std and tokio runtimes
-
dagrs
follows the concept of Flow-based Programming and is suitable for the execution of multiple tasks with graph-like dependencies. Dagrs has the characteristics of high performance and asynchronous execution…
-
async-tempfile
Automatically deleted async I/O temporary files
-
c-ares-resolver
An asynchronous DNS resolver, backed by c-ares
-
rustyline-async
A minimal readline with multiline and async support
-
mcp-attr
declaratively building Model Context Protocol servers
-
pty-process
spawn commands attached to a pty
-
hyper-multipart-rfc7578
multipart/form-data (RFC7578) for Hyper
-
motore
modular and reusable components for building robust clients and servers. Motore is greatly inspired by Tower.
-
lamellar
asynchronous tasking runtime for HPC systems developed in RUST
-
calloop
A callback-based event loop
-
polling
Portable interface to epoll, kqueue, event ports, and IOCP
-
async-lsp
Asynchronous Language Server Protocol (LSP) framework based on tower
-
trait-variant
working with impl traits in Rust
-
local-waker
A synchronization primitive for thread-local task wakeup
-
async-native-tls
Native TLS using futures
-
tokio_schedule
schedule tasks in tokio runtime
-
conogram
An async wrapper for Telegram Bot API
-
safina
Safe async runtime
-
dark-std
asynchronous containers build on tokio. It uses a read-write separation design borrowed from Golang
-
compio
Completion based async runtime
-
popol
Minimal non-blocking I/O
-
binary-stream
Binary stream reader and writer
-
fang
Background job processing library for Rust
-
tower-fallback
A Tower service combinator that sends requests to a first service, then retries processing on a second fallback service if the first service errors
-
mml-lib
Emacs MIME message Meta Language (MML)
-
triggered
Triggers for one time events between tasks and threads
-
async-speed-limit
Asynchronously speed-limiting multiple byte streams
-
actix-web-flash-messages
Flash messages for actix-web applications
-
a10
io_uring library
-
kill_tree
🌳 Kill Tree is a library designed to terminate a specified process and all its child processes recursively, operating independently of other commands like kill or taskkill
-
rocketmq-rust
Unofficial Rust implementation of Apache RocketMQ
-
delay_timer
Time-manager of delayed tasks. Like crontab, but synchronous asynchronous tasks are possible, and dynamic add/cancel/remove is supported.
-
partial-io
Helpers to test partial, interrupted and would-block I/O operations, with support for property-based testing through proptest and quickcheck
-
busybody
Service Container and Dependency injector crate
-
wg
Golang like WaitGroup implementation for sync/async Rust
-
async-ssh2-lite
Asynchronous ssh2
-
countio
Byte counting for std::io::{Read, Write, Seek} and its async variants from futures and tokio
-
filebuffer
Fast and simple file reading
-
kube-lease-manager
Ergonomic and reliable leader election using Kubernetes Lease API
-
bluest
A cross-platform Bluetooth Low Energy (BLE) library
-
syslog-rs
A native Rust implementation of the glibc/libc syslog
-
interruptible
Stops a future producer or stream from producing values when interrupted
-
ginepro
A client-side gRPC channel implementation for tonic
-
scc2
High-performance containers and utilities for concurrent and asynchronous programming
-
viz
Fast, robust, flexible, lightweight web framework for Rust
-
fmodel-rust
Accelerate development of compositional, safe, and ergonomic applications/information systems by effectively implementing Event Sourcing and CQRS patterns in Rust
-
suppaftp-cli
FTP command line client, based on suppaftp
-
blockstore
An IPLD blockstore capable of holding arbitrary data indexed by CID
-
noveum-ai-gateway
A high-performance AI Gateway proxy for routing requests to various AI providers, offering seamless integration and management of multiple AI providers
-
celery
Rust implementation of Celery
-
factorio-mlua
High level bindings to Lua 5.4/5.3/5.2/5.1 (including LuaJIT) and Roblox Luau with async/await features and support of writing native Lua modules in Rust. Fork with added Factorio Lua support
-
lcode
An application of terminal write leetcode.一个终端刷力扣的应用
-
containerd-client
GRPC bindings to containerd APIs
-
ferrisgram
An elegent rust client for the Telegram Bot API
-
deli
ergonomic way to define data models that are seamlessly converted into IndexedDB object stores, utilizing derive macros
-
async-object-pool
object pool implementation that uses asynchronous synchronization primitives only
-
async-ringbuf
Async SPSC FIFO ring buffer
-
nuclei
Proactive IO & runtime system
-
daktronics-allsport-5000
decoders for the Daktronics All Sport 5000's serial output
-
futures-channel
Channels for asynchronous communication using futures-rs
-
hypercore
Secure, distributed, append-only log
-
rusty-penguin
A fast TCP/UDP tunnel, transported over HTTP WebSocket
-
round-based
Driver for MPC protocols
-
stakker
A lightweight low-level single-threaded actor runtime
-
stream_throttle
Stream combinator, to limit the rate at which items are produced
-
aqueue
fast speed thread safe async execute queue
-
tiny_kafka
A tiny Kafka client library with producer and consumer functionalities
-
tower-sessions-sqlx-store
SQLx session stores for
tower-sessions
-
actix-rt
Tokio-based single-threaded async runtime for the Actix ecosystem
-
tokise
An asynchronous runtime compatible with WebAssembly and non-WebAssembly targets
-
tokio-rusqlite
Asynchronous handle for rusqlite library
-
hedwig
message bus for Rust
-
rust-parallel
Fast command line app in rust/tokio to run commands in parallel. Similar interface to GNU parallel or xargs.
-
jsoncall
asynchronous JSON-RPC 2.0 library leveraging Rust's type system
-
google-places-api
Unofficial Google Places API for rust
-
tigerbeetle-unofficial
Safe high level async bindings to tigerbeetle client library
-
rh2
An HTTP/2 client and server
-
rxr
Reactive extensions for event-driven applications
-
rocketmq-client-rust
Apache rocketmq client
-
common-multipart-rfc7578
multipart/form-data (RFC7578)
-
monoio-transports
Monoio Transporter
-
tonic-middleware
Async middleware and interceptor for Tonic services
-
faktory
API bindings for the language-agnostic Faktory work server
-
another-rxrust
A different implementation than
rxRust
for easier use ofReactiveX
inRust
-
swiftide-integrations
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
tokio-retry2
Extensible, asynchronous retry behaviours for futures/tokio
-
get_chunk
File iterator or stream with auto or manual chunk size selection
-
mutringbuf
lock-free SPSC ring buffer, with in-place mutability
-
futures-rx
Rx implementations for the futures crate
-
floxide-timer
Timer node abstractions for the floxide framework
-
rust-multipart-rfc7578_2
multipart/form-data (RFC7578)
-
krecik
Asynchronous, parallel external service checker (and reporter), using industry standard libraries: Curl, ngHTTP2 and OpenSSL
-
pexels-cli
client for the Pexels API
-
dataloader
Facebook's DataLoader using async-await
-
windmark
An elegant and highly performant async Gemini server framework
-
rocketmq-filter
A filter for RocketMQ messages
-
async_cache
Async refresh cache
-
peace_cli
Command line interface for the peace automation framework
-
async-dropper
The least-worst ad-hoc implementation of AsyncDrop as a Derive macro
-
ntex-neon
Async runtime for ntex
-
minior
Ergonomic Minio Client
-
mio_wasi
Lightweight non-blocking IO
-
hypercore-protocol
Replication protocol for Hypercore feeds
-
hakuban
Data-object sharing library
-
peekable
reader and async reader, which enhance your network programming experience
-
tower-lsp-server
Language Server Protocol implementation based on Tower
-
async-cuda
Async CUDA for Rust
-
clia-async-openai
OpenAI (with rustls)
-
reord
Run your tests multi-threaded, but in a reproducible way
-
ate
Distributed immutable data store with strong encryption and authentication
-
async_executors
Implements Spawn, SpawnLocal and SpawnHandle for commonly used executors
-
rio
GPL-3.0 nice bindings for io_uring. MIT/Apache-2.0 license is available for spacejam's github sponsors.
-
springtime-di
Dependency injection framework based on automatic component discovery and runtime autowiring
-
xscript
writing robust shell-script-like programs and running commands with ease
-
srt-c
API compatabile libsrt reimplementation using srt-tokio
-
syndicate-server
Dataspace server
-
b2_backblaze
basic async library to upload small files to backblaze b2 service
-
dptree
An asynchronous event dispatch mechanism for Rust
-
try-again
Retry synchronous and asynchronous operations
-
dynamo-runtime
Dynamo Runtime Library
-
mail-message
A program for easy, quick, and fault tolerant sending of emails from the command line
-
ractor_actors
actors built with Ractor
-
go-zoom-kinesis
A robust AWS Kinesis stream processor with checkpointing and retry capabilities
-
polkadot-omni-node
Generic binary that can run a parachain node with u32 block number and Aura consensus
-
async-bincode
Asynchronous access to a bincode-encoded item stream
-
fundamentum-edge-daemon
The supported way to access Fundamentum's ecosystem from linux devices
-
irelia
wrapper around the native LoL APIs
-
ya-gcp
APIs for using Google Cloud Platform services
-
async_smux
Asynchronous smux multiplexing library
-
s3-tokio
working with AWS S3 and compatible object storage APIs
-
lazy_async_promise
Primitives for lazily getting data from futures with tokio for immediate mode guis
-
pi_async_buffer
Asynchronous Buffer for IO
-
netidx-protocols
Protocols built on top of netidx
-
disintegrate
build event-sourced applications
-
wiremocket
Websocket mocking to test Rust applications
-
tokio-io-timeout
Tokio wrappers which apply timeouts to IO operations
-
tiny-tokio-actor
tiny actor library on top of tokio
-
tokio-par-util
running computations in parallel on top of Tokio
-
bounded_join_set
A Concurrency-Limited JoinSet for Tokio
-
async-io-mini
Async I/O fork for embedded systems
-
tokio-cadence
Tokio-based metric sinks for Cadence
-
futures-util
Common utilities and extension traits for the futures-rs library
-
v_exchanges
Implementations of HTTP/HTTPS/WebSocket API methods for some crypto exchanges, using crypto-botters framework
-
rst_parser
a reStructuredText parser
-
certsd
automated, asynchronous LE certificate issuer
-
eureka-mmanager
An Actix actor collection for downloading manga, chapters, covers from Mangadex
-
keyring-lib
High-level, asynchronous API for keyring-rs, a cross-platform Rust library to manage credentials
-
architect-tonic
A gRPC over HTTP/2 implementation focused on high performance, interoperability, and flexibility
-
reactio
Low-Latency Event Driven Nonblocking Reactor Pattern
-
executor-trait
A collection of traits to define a common interface across executors
-
array__ops
A selection of useful array operations
-
madsim-tokio
The
tokio
simulator on madsim -
fama
Pipeline Manager
-
rabbit-auto
Wrappers for lapin publishers and consumers
-
task-supervisor
Tokio tasks Supervisor
-
speare
actor-like thin abstraction over tokio::task and flume channels
-
mountain-mqtt
A no_std compatible, async MQTT v5 client for tokio and embedded use
-
multishot
An async, lock-free, reusable channel for sending single values to asynchronous tasks
-
specta-typescript
Export your Rust types to TypeScript
-
blocking
A thread pool for isolating blocking I/O in async programs
-
flourish
Convenient and full-featured signals for Rust
-
etcdv3client
etcdv3 client
-
rdkafka-sys
Native bindings to the librdkafka library
-
vkapi2
vk api wrapper for rust
-
async-change-tracker
reactive change notifications using futures
-
idcurl
Idiomatic synchronous http client based on curl
-
mini_exercism
Minimalistic Rust library to interact with the Exercism.org APIs
-
futures-io
The
AsyncRead
,AsyncWrite
,AsyncSeek
, andAsyncBufRead
traits for the futures-rs library -
xan-actor
Akka actor
-
mpi-sys
Message Passing Interface bindings for Rust
-
stilgar
A lightweight, no-fuss, drop-in replacement for Rudderstack
-
llm_client
easiest Rust interface for local LLMs
-
histlog
hdrhistogram crate, provides off-thread serialization of HdrHistogram interval logs to file
-
tokio-zookeeper
Asynchronous client library for interacting with Apache ZooKeeper
-
apalis-sql
SQL Storage for apalis. Use sqlite, postgres and mysql for background job processing
-
kafru
Python Celery-inspired queuing library for Rust, using cron for scheduling and SurrealDB for storing queues, metrics, and schedules
-
twilight-http-ratelimiting
Discord REST API ratelimiter implementations for the Twilight ecosystem
-
crossmist
Efficient and seamless cross-process communication, both synchronously and asynchronously
-
async-lazy
A value which is initialized on the first access, with an async function
-
async-hid
A async library for interacting with HID devices
-
keen-retry
-- yet powerful -- zero-cost-abstractions & zero-copy lib for error handling & recovery
-
type-toppings
Opinionated extensions to standard types
-
async-openai-compat
OpenAI
-
mobc
A generic connection pool with async/await support
-
unkey
An asynchronous Rust SDK for the Unkey API
-
dynosaur
Dynamic dispatch for return position impl traits and async in Rust
-
kwi-kraken-rest
Unofficial kraken trading platform REST API implementation
-
coc-rs
wrapper around the Clash of Clans public API
-
s3-simple
fast and efficient s3 client for bucket operations
-
decoyssh
A compact and portable SSH tarpit server
-
named-retry
retrying fallible asynchronous operations
-
lighthouse-client
Client SDK for Project Lighthouse
-
notifier_hub
cannal subscribtion system
-
messagebus
allows intercommunicate with messages between modules
-
quick-protobuf-codec
Asynchronous de-/encoding of Protobuf structs using asynchronous-codec, unsigned-varint and quick-protobuf
-
bb8-lapin
r2d2-lapin, but for async tokio based connections
-
io-tether
A small library for defining I/O types which reconnect on errors
-
fourche
task queue named after a lion with forked tail (queue fourché), works with Redis
-
laminarmq
A scalable, distributed message queue powered by a segmented, partitioned, replicated and immutable log
-
mikrotik-rs
Asynchronous Rust library for interfacing with MikroTik routers
-
linemux
providing asynchronous, multiplexed tailing for (namely log) files
-
actix-casbin
An Actix actor for casbin
-
firecracker-rs-sdk
🧨🦀🚀 The Firecracker Rust SDK. A pure Rust crate for interacting with Firecracker.
-
corcovado
Non-blocking IO library
-
axum-extra
Extra utilities for axum
-
flatline
ssh-2.0 client library
-
hooks
Compile-time, async hooks
-
drop-stream
A stream that wraps another stream with a closure that is called once it is dropped
-
biscuit-actix-middleware
Biscuit middleware for actix-web
-
sipper
A type-safe future that can notify progress
-
scuffle-context
Go-like context utilities for Rust
-
cassette
single-future, non-blocking executor intended for building state machines
-
aranya-policy-ifgen
Tools for generating Rust interfaces to Aranya Policies
-
tokio-stream
work with
Stream
andtokio
-
reactive-mutiny
async Event-Driven Reactive Library with advanced & optimized containers (channels) and Stream executors
-
tor-rtmock
Testing mock support for tor-rtcomapt
-
flo_binding
Declarative binding library for Rust
-
tros
Your tros from tarantool TX thread to tokio(..and others!)
-
tools_interface
Abstractions of serveral Wikipedia/Wikimedia/Wikidata-related tools
-
parquet_opendal
parquet Integration for Apache OpenDAL
-
synchronized-writer
A tiny implement for synchronously writing data
-
fundamentum-sdk-mqtt
MQTT client targeting Fundamentum IoT's MQTT broker
-
qbittorrent_rust
An asynchronous library to interface with the qbittorrent WeBUI API
-
oneshot-uniffi
Patched version of oneshot specifically for the UniFFI project. This removes the
loom
target and dependency which helps with UniFFI’s downstream consumers -
pasts
Minimal and simpler alternative to the futures crate
-
cyberex
Utilities Library
-
rust-utils
Various utility routines used in the rust programs I have written
-
turmoil
Simulation testing framework for distributed systems
-
stackfuture
wrapper around futures that stores the wrapped future in space provided by the caller
-
ghost_actor
GhostActor makes it simple, ergonomic, and idiomatic to implement async / concurrent code using an Actor model
-
call-agent
A multimodal chat API library with tool support, OpenAI API compatible
-
cancel-safe-futures
Alternative futures adapters that are more cancellation-aware
-
async_zmq
Async version for ZeroMQ bindings
-
whirlwind
Collection of thread-safe, asynchronous data structures
-
openrouter_api
client library for the OpenRouter API
-
odem-rs
Object-based Discrete-Event Modelling in Rust using async/await
-
ruloom
A thin wrapper around 'corosensei' that provides support for stackful coroutines in Rust (like Loom in Java or goroutines in golang)
-
pgboss
job queueing service
-
monzo-lib
async Monzo client in pure rust
-
automerge_repo
automerge-repo
-
kioto-serial
Provide serial port I/O using tokio
-
with-async-context
managing contextual data across async tasks
-
bunbun-worker
An rpc/non-rpc AMQP worker library
-
iroh-io
async local io
-
process-lib
Cross-platform, asynchronous Rust library to run commands in pipelines
-
wgpu-async
Converts some WGPU callback methods to async methods
-
tipsy
Cross-platform IPC for Tokio
-
s3tui
TUI application for multiple s3 account operations
-
monoio-codec
Codec for Monoio
-
safe-vk
create your own vk bot for conversations
-
futures-scopes
Runtime agnostic, nestable, scopes for spawning non-static futures
-
winctx
A minimal window context for Rust on Windows
-
messagepack-async
functional library for read/writing messagepack with tokio
-
infect
Intent/effect/task - A variation on the Model View Intent (MVI) and State Action Model (SAM) paradigms
-
glommio
thread-per-core crate that makes writing highly parallel asynchronous applications in a thread-per-core architecture easier for rustaceans
-
agnostic-net
Agnostic abstraction layer of
std::net
for any async runtime -
irondash_run_loop
Consistent, platform-independent interface to system run loop
-
sluice
Efficient ring buffer for byte buffers, FIFO queues, and SPSC channels
-
skedgy
asynchronous job scheduler
-
rseip
Ethernet/IP (CIP) client in pure Rust
-
async-ffi
FFI-compatible
Future
s -
mlua-codemp-patch
High level bindings to Lua 5.4/5.3/5.2/5.1 (including LuaJIT) and Roblox Luau with async/await features and support of writing native Lua modules in Rust
-
meltdown
A lightweight service manager to help with graceful shutdown of asynchronous applications
-
super-visor
ordered startup and shutdown for long-running tokio processes
-
axum-server2
High level server designed to be used with axum framework
-
miow
A zero overhead I/O library for Windows, focusing on IOCP and async I/O abstractions
-
c-ares
wrapper for the c-ares library, for asynchronous DNS requests
-
gql_client
Minimal GraphQL client for Rust
-
basu
Eventbus crate with sync and async features
-
async-graphql-axum
async-graphql for axum
-
rusftp
SFTP library based on russh
-
claude-client
client for the Anthropic Claude API
-
vmcircbuffer
Double Mapped Circular Buffer
-
stdout-channel
Write stdout to an async queue
-
future-local-storage
An init-once-per-future cell for thread-local values
-
futures-batch
An adaptor that chunks up elements and flushes them after a timeout or when the buffer is full. (Formerly known as tokio-batch.)
-
async-injector
Reactive dependency injection for Rust
-
effectum
An embeddable task queue based on SQLite
-
actor-core-client
Rust client for ActorCore - the Stateful Serverless Framework for building AI agents, realtime apps, and game servers
-
translators
Free Google Translator without API key and limits
-
asteroid-mq
An embeddable message queue system
-
pi_rt_file
async file 的封装,添加了多线程竞争排序。
-
ctrlgen
Generate enums for message-passing services
-
peace_item_model
Data types for resource interactions for the Peace framework
-
ads_client
An asynchronous, non-blocking ADS client
-
futures-signals-ext
Extension to futures-signals: MutableOption with combinators, spawning, predicate driven selections from SignalVec
-
constellation-rs
Constellation is a framework for Rust (nightly) that aides in the writing, debugging and deployment of distributed programs
-
cache_loader_async
A thread safe loading cache with async loader functions based on tokio
-
log-tracing-layer
Build your own custom tracing layer
-
rs_ctx
Context propagation for rs framework
-
async-tls
Asynchronous TLS/SSL streams using Rustls
-
simple-git
git interface for gix suitable for async context (with tokio)
-
xjbutil
A xjbly created utility library for my own use
-
ffi_rpc
Use FFI with RPC
-
sn_sdkg
Safe Network Synchronous Distributed Key Generation: enables dealerless section key generation
-
xelf
A versatile Rust toolkit for self-use
-
swait
Blocking on Futures
-
mio-pidfd
mio support for Linux's pidfd
-
busstop
A command and query bus
-
native_messaging
Async implementation of MDN native messaging. Provides the ability to install host manifest.
-
axum-serde
multiple serde-based extractors / responses for the Axum web framework, also offers a macro to easily customize extractors / responses
-
read_until_slice
AsyncBufRead::read_until extension to take a slice as a delimiter instead of a single u8
-
mal-api
An asynchronous MyAnimeList (MAL) API library for Rust
-
fastcgi-client
Fastcgi client implemented for Rust
-
axum-standardwebhooks
Axum extractor that verifies signature for Standard Webhooks
-
async-mcp
Async Implementation of Model Context Protocol (MCP)
-
pgp-lib
High-level, asynchronous API for rPGP, a pure Rust implementation of OpenPGP
-
async-duplex-channel
An asynchronous duplex communication channel between multiple clients and a single responder in different asynchronous blocks
-
clamav-client
ClamAV client library with optional Tokio and async-std support
-
gem-rs
that serves as a wrapper around the Google Gemini API, providing support for streaming
-
async-fn-stream
Lightweight implementation of
async-stream
without macros -
daemon-base
A flexible and configurable Rust daemon library with lifecycle management, logging, callbacks, and optional async support. Works on Linux, macOS, and Windows.
-
my-awesome-rabbitmq-lib
working with RabbitMQ and asynchronous operations
-
tcpclient
Asynchronous tcpclient based on aqueue actor
-
kompact
Kompics component model combined with the Actor model
-
splaycast
Stream-specific broadcast channel
-
async-borrow
Async compatible ownership semantics using futures instead of lifetimes
-
bisync
write async-generic code
-
resident-utils
Resident program library
-
kuska-handshake
Secure Scuttlebutt handshake + boxstream library
-
async-openai-alt
OpenAI
-
n0-future
Number 0's way of doing rust futures. Re-exports what we think are useful abstractions and good implementations.
-
tokio-rayon
Mix async code with CPU-heavy thread pools using Tokio + Rayon
-
tokio-muxt
Timer for a limited set of events that multiplexes over a single tokio Sleep instance
-
retainer
Minimal async cache in Rust with support for key expirations
-
dicebear
An unofficial dicebear wrapper for Rust
-
tokio-agent
Agents are a simple abstraction around state, inspired by Elixir's Agent
-
next-gen
Safe generators on stable Rust
-
tokio-rusqlite-new
Asynchronous handle for rusqlite library
-
rxqlite-tests-common
A distributed sqlite database built upon
openraft
,sqlx
andsqlite
-
lazy-pool
Experimental lazy object pool
-
pierport
Urbit pier import protocol implementation
-
pinky-swear
Futures and async/await-ready Promises
-
passivized_vault_client
Vault Client - initialize and monitor Hashicorp Vault nodes
-
tokio-process-tools
Interact with processes spawned by tokio
-
thread-waker
Waker implementation using current thread token
-
tower-batch-control
Tower middleware for batch request processing
-
upc
USB packet channel (UPC): provides a reliable, packet-based transport over USB
-
pi_async_file
A async file tools library
-
trale
minimalistic Rust async executor using io_uring for efficient, correct task execution
-
notify-future
Support asynchronous notification completion future
-
orengine
Optimized ring engine for Rust. It is a lighter and faster asynchronous library than tokio-rs, async-std, may, and even smol
-
mm1-node
M/M/1! Queueing, do you speak it?!
-
brig
mar here, Briganteen—General Sir A. I. Magnus, the flapper-
-
poster
MQTTv5 client library written in Rust
-
swiftide-docker-executor
A docker executor for swiftide agent tools
-
bb-downloader
async downloader for applications
-
ctrlc-async
Easy asynchronous Ctrl-C handler for Rust projects
-
async-event-emitter
Lightweight AsyncEventEmitter
-
ntex-rt
ntex runtime
-
aws-multipart-upload
AWS S3 multipart upload sinks
-
futuresdr
An Experimental Async SDR Runtime for Heterogeneous Architectures
-
tokio-scheduler-rs
JobScheduler written with tokio runtime, automatic retry, hook and custom storage supported
-
patharg
Treat "-" (hyphen/dash) arguments as stdin/stdout
-
ector
open source async, no-alloc actor framework for embedded devices
-
timeout-iterator
TimeoutIterator is a wrapper over any iterator that adds peek_timeout and next_timeout functions. The canonical use-case is parsing multi-line free-form records (such as tailing a log fime)…
-
product-os-async-executor
Product OS : Async Executor provides a set of tools to handle async execution generically so that the desired async library (e.g. tokio, smol) to be used can be chosen at compile time.
-
async-rate-limit
Common traits for rate limiting and implementations in async contexts
-
redis-work-queue
A work queue, on top of a redis database, with implementations in Python, Rust, Go, Node.js (TypeScript) and Dotnet (C#)
-
libmqm-default
IBM® MQ Interface (MQI) and MQ Administration Interface (MQAI) structure defaults
-
serial-thread
Asynchronous, multithreaded serial port communication library using mpsc::cjhannels or async-channels for efficient data handling
-
kube-coordinate
Kubernetes leader election using the coordination.k8s.io API
-
pubnub
SDK for Rust
-
nominatim
Bindings to the reverse geocoding API powered by openstreetmap
-
async-tensorrt
Async TensorRT for Rust
-
makepad-futures-legacy
Makepad futures legacy
-
eventastic_postgres
An example postgres event store for eventastic
-
kafka-threadpool
An async rust threadpool for publishing messages to kafka using SSL (mTLS) or PLAINTEXT protocols
-
agzip
Async compatible gzip (de)compressor
-
gasket
Staged Event-Driven Architecture (SEDA) framework
-
stopper
an async stream and future stopper mechanism
-
asyncgit
allow using git2 in a asynchronous context
-
didcomm-rs
DIDComm messaging v2 specifications implementation: https://identity.foundation/didcomm-messaging/spec/
-
tokio-hrtime
Hires timers for tokio
-
async-rt
A small library designed to utilize async executors through an common API while extending features
-
ics-watcher
A lightweight crate for monitoring ICS files or links and detecting changes, additions, and removals
-
async_io_stream
IntoAsyncRead on steriods
-
debounced
building delayed
Future
s and debouncedStream
s that wait a given duration before yielding the most recent item -
async-rdma
async wrapper for RDMA ibvers lib
-
nosy
Change notification / observation / broadcast channels, with filtering and coalescing. no_std compatible.
-
girlboss
async job manager with progress tracking
-
tokio_kcp
A kcp implementation for tokio
-
recurring-tasks
Define tasks and run them in an app forever, ala cronjobs. And don't run already/still running tasks.
-
deepseek_rs
client library for the DeepSeek API
-
pingora-timeout
Highly efficient async timer and timeout system for Tokio runtimes
-
est
Extensions for the rust Standard library and Tokio
-
tower-sessions-redis-store
Redis session store for
tower-sessions
-
eventbuzz
A safe, fast, concurrent event publish/subscribe system based on tokio(async), inspired by Spring events
-
bsky-cli
CLI application for Bluesky using ATrium API
-
stressed
Universal CLI stress tester for competitive programming
-
acton-core
Acton Core provides the core functionality and abstractions used by the Acton Reactive crate. It includes the essential building blocks for creating reactive and distributed systems.
-
retrier
A wasm-compatible retry library for futures
-
serio
providing traits and utilities for typed IO using format agnostic serialization built on serde
-
containerd-shim-protos
TTRPC bindings for containerd shim interfaces
-
async_async_io
AsyncRead
,AsyncWrite
traits but withasync fn
methods -
genawaiter2
Stackless generators on stable Rust
-
warnings
defining debug only runtime warnings with a way to opt-out
-
waldl
A command line wallpaper downloader
-
proptest_async
proptest macro supporting async tests
-
dora-coordinator
dora
goal is to be a low latency, composable, and distributed data flow -
async-transmit
Trait for transmitting data to peers asynchronously
-
py_mcai_worker_sdk
AMQP Worker to listen and provide trait to process message
-
webex
Interface to Webex Teams REST and WebSocket APIs
-
nonblock
Read available data from file descriptors without blocking (e.g. sockets, streams, child stdout, named pipes)
-
co_managed
Create managed sub coroutines. Managed sub coroutines will be cancelled when the parent exit
-
prin
reverse proxy terminal utility
-
tarpc-copy
An RPC framework for Rust with a focus on ease of use
-
hooch
A small async runtime that's been bootlegged for my projects
-
railsgun
Excessive tooling for Result handling - If you want rails you got RAILS!
-
myust
A rich and hybrid mystb.in API wrapper for Rust 🦀
-
tower-lsp-f
Language Server Protocol implementation based on Tower
-
megaphone
Client library that can be used to subscribe to megaphone channels
-
longport-httpcli
LongPort HTTP SDK for Rust
-
collections-futures
working with futures through collections types
-
async-eris
Async ERIS encoding library
-
hyperbee
Peer to Peer B-tree
-
twinkle_client
Helper for making stateful clients that can notify on change
-
socksv5
SOCKS v4a and v5 basic building blocks to build your own async SOCKS application
-
tempo-rs
& minimal client to connect and interact with RTE's 'Tempo Like Supply Contract' API
-
caryatid_process
building a Caryatid process
-
wasmcloud-interface-factorial
Interface library for the wasmcloud factorial capability, wasmcloud:example:factorial
-
streamunordered
An efficient async stream multiplexer
-
syndicus
Publish/Subscribe with types for topics and subscriber (re)synchronisation
-
wtx-ui
Different user interfaces for WTX
-
cloudformatious
Extension traits for rusoto_cloudformation
-
some_executor
A trait for libraries that abstract over any executor
-
procsem
Semaphore used to lock thread/task-spanning sequence of operations
-
passivized_docker_engine_client
Docker Engine Client - manage and run containers, images, and volumes
-
robotxt
Robots.txt (or URL exclusion) protocol with the support of crawl-delay, sitemap and universal match extensions
-
zephyrus
A slash-command framework meant to be used with twilight
-
futures-timeout
that provides timeouts for futures and streams
-
madruga
Retry resiliente com backoff
-
syndicate-tools
Syndicate command-line utilities
-
tokio-send-fd
A wrapper for tokio::net::UnixStream to send file descriptors
-
tub
Async Pool
-
rasi-spec
The Official RASI Specification Test Suite
-
state_machine_future
Easily create type-safe
Future
s from state machines — without the boilerplate -
spin_on
inefficient Future executor
-
apis
Reactive, session-oriented, asynchronous process-calculus framework
-
mailfred
Process emails as an HTTP server
-
parquet-format-async-temp
Temporary crate containing thrift library + parquet definitions compiled to support read+write async
-
rust-paper
Rust Wallpaper manager from ( https://wallhaven.cc/ ) for Linux/UNIX only
-
rustygram
minimal and blazing fast telegram notification framework for Rust
-
smol-cancellation-token
cancellation token implementation for Smol, copied from tokio-util’s cancellation token, and replace the
waker
withEventListener
to make it cross async runtime compatible -
php-tokio
Use any async Rust library from PHP!
-
async-time-mock-async-std
Mockable time for use in async runtimes (async-std compatibility)
-
tokio-socketcan
Asynchronous Linux SocketCAN sockets with tokio
-
rasi-mio
a rasi drivers implementation base on mio
-
watchfile
An async utility trait to subscribe to file changes of a serializable file
-
z21_api
Rust API for Roco Z21 model railway control system
-
async-io-bufpool
A helper crate to read from AsyncReads in an extremely memory-efficient way
-
kafcat
cat but with kafka
-
anthill-di
Rust di containers system
-
fb_futures_ext
future crate extensions
-
letslogic
providing interaction with the Let's Logic API
-
hop
Rust client library for the Api
-
freedom-api
Freedom API for Rustaceans
-
smol
A small and fast async runtime
-
aldrin-broker
Broker library of Aldrin, a message bus for service-oriented RPC and interprocess communication
-
lsp-async-stub
An LSP server stub for futures
-
rocketmq-runtime
Unofficial Rust implementation of Apache RocketMQ
-
jni-utils
Extra Utilities for JNI in Rust
-
tasklet
An asynchronous task scheduling library
-
okstd
The standard library that's ok
-
deferred-future
模仿 jQuery.Deferred(),允许从 Future 实现类实例的外部对正在 pending 的 Future 对象进行 resolve 或 reject 处理。
-
mulligan
A flexible retry library for Rust async operations with configurable backoff strategies and jitter
-
secret-lib
Cross-platform, asynchronous Rust library to retrieve secrets from different sources
-
embedded-runtime
A tiny async runtime for embedded devices
-
noosphere-into
Transformations of Noosphere content into various target formats
-
tokio-i3ipc
Bindings for i3 and tokio allowing async applications to communicate with i3 over it's IPC interface. Contains futures implementations and convenience functions for working with i3.
-
ipc-rpc
A wrapper over servo/ipc-channel which provides many high level features
-
peace_resource_rt
Runtime resources for the peace automation framework
-
rendezvous
Easier rendezvous channels for thread synchronization
-
async-codec
creating async codecs
-
sacs
Async Cron Scheduler for Tokio
-
tokio-fastcgi
FastCGI handler (responder, authorizer, filter) library for Tokio
-
flowync
multithreading a/synchronization
-
kble-socket
Virtual Harness Toolkit
-
borrow_mutex
Async Rust Mutex which does not require wrapping the target structure
-
par_io
Parallel, async file I/O library with control over memory usage with no dependencies
-
async-task-tracker
A task tracker used for waiting until tasks exit
-
async-select
select!
multiplex asynchronous futures simultaneously -
pending_unwind
converting unwindings into
pending
-
okkoi
-
minos
Authorization library
-
rak-rs
A fully functional RakNet implementation in pure rust, asynchronously driven
-
genawaiter
Stackless generators on stable Rust
-
warp-rate-limit
Rate-limiting middleware for the Warp web framework
-
embedded-io-convert
Convert embedded-io-async types back to futures ones (nightly only)
-
gcp_access_token
pure rust implimentation to get google cloud access token for servers with service account credentials
-
tokio-tasks
Task managment for tokio
-
yosemite
Asynchronous SAMv3 library
-
alicemq
Wapper for the amqprs rabbitMQ library
-
ksoft
KSoft.SI api wrapper written in pure Rust
-
medusa-zip
A command-line interface to high-performance parallelized implementations of common zip file operations
-
future-metrics
Instrument futures with execution metrics
-
actix-multipart-rfc7578
multipart/form-data (RFC7578) for Actix
-
realhydroper-lsp
Language Server Protocol implementation based on Tower
-
async-gate
A Tokio-powered asynchronous gate (analogous to a flag and highly inspired by Python’s
asyncio.Event
, but can be waited for to become ‘false’ too) -
synch
A basic asynchronous timer implementation that uses the cortex-m SysTick peripheral
-
apalis-cron
extensible library for cron-like job scheduling for rust
-
scoped-stream-sink
Easy way to make streams and sinks
-
rocketmq-remoting
Apache rocketmq remoting
-
epson
support for communicating with Epson brand thermal POS printers
-
woddle
An async, synchronized, database-backed Rust job scheduler
-
must_future
A wrapper future marked must_use - mainly to wrap BoxFutures
-
typed-emitter
Typed Async event emitter
-
ractor-supervisor
Supervisor module for ractor framework
-
fastpool
This crates implements a fast object pool for Async Rust
-
knien
Typed RabbitMQ interfacing for async Rust
-
torznab-toolkit
A safe, multi-threaded, async toolkit for adding Torznab APIs to programs
-
lunatic-messaging-api
Lunatic host functions for message sending
-
dco3
Async API wrapper for DRACOON in Rust
-
wtr-watcher
Filesystem watcher. Works anywhere. Simple, efficient and friendly.
-
stop-token
Experimental cooperative cancellation for async Rust
-
persway
Sway IPC daemon
-
mosquitto-rs
An async MQTT client based on libmosquitto
-
rusturn
TURN server and client
-
irox-threading
Blocking and Asynchronous Threading Tools
-
vexide-async
The async executor at the core of vexide
-
tokio-task-scheduler
A non-blocking task scheduler for Rust with fluent API, supporting interval-based and cron-like scheduling
-
async-minecraft-ping
An async Rust client for the Minecraft ServerListPing protocol
-
futures-map
Futures-based and hashmap-based alogrithms
-
tower-sessions-rusqlite-store
(tokio-)rusqlite session store for
tower-sessions
-
mpart-async
Asynchronous (Futures-Base) Multipart Requests for Rust
-
tor-log-ratelim
Facility for rate-limiting log messages in Arti
-
discro
DISCRete Observables for asynchronous Functional Reactive Programming (FRP)
-
senders_receivers
Senders/Receivers implementation for Rust
-
pegy
A derive based parser generator
-
postage
An async channel library
-
apocalypse
actor framework for Rust
-
crb-agent
CRB | Composable Runtime Blocks | Agent
-
aide-de-camp
backend agnostic delayed job queue
-
short_future
Future with shorter lifetime for async closures
-
hikvision-rs
High-level asynchronous library for controlling cameras from Hikvision using the PTZ API
-
toy-rpc
An async RPC that mimics golang net/rpc's usage and supports both async-std and tokio
-
nats-handling
async NATS client library
-
until_needle
An extension to the BufRead trait that allows reading until a specified pattern (needle) is found
-
swimos_downlink
SwimOS Downlink Runtime
-
l337
connection pooler
-
upstox-rust-sdk
SDK to access Upstox's Uplink v2 APIs programmatically
-
logic-mesh
Control logic engine using event based and reactive blocks written in Rust
-
aws-parameters-and-secrets-lambda
Cache AWS Secrets Manager secrets in your AWS Lambda function
-
ts3
A TeamSpeak3 Query library
-
cassandra-protocol
Cassandra protocol implementation
-
async-graphql-rocket
async-graphql for Rocket.rs
-
actix-mqtt-client
A MQTT client based on the actix framework
-
id_list_txt_reader
read a txt
-
singleflight-async
Singleflight in async style
-
kx-utils
Common utils incubator
-
background-jobs-sled
Sled storage backend for background-jobs
-
shenyu-client-rust
Apache ShenYu Rust client SDK
-
slim-futures
Asynchronous tools that intends for smaller binary size
-
dbus-async
Asynchronous DBus library
-
tokio-test
Testing utilities for Tokio- and futures-based code
-
madsim-real-tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
rseek
adapter for reqwest that allows seeking in the response body stream using AsyncSeek
-
transform-stream
Lightweight async stream wrapper
-
tonic-side-effect
Tower service that can monitor if a Tonic request frame was produced prior to error
-
wae
Async executor that use Winit event loop
-
amqp-client-rust
An asynchronous AMQP client library for Rust, designed for high-performance communication with RabbitMQ. Features include automatic queue and exchange management, message publishing, subscribing, and RPC support.
-
reactor-trait
A collection of traits to define a common interface across reactors
-
erl_dist
Erlang Distribution Protocol
-
ticks
ergonomic Rust wrapper for the TickTick Open API
-
haiyuu
experimental actor-like library
-
lwactors
Lightweight actors for Rust using futures-rs
-
wiremock_logical_matchers
Logical matchers for use with wiremock
-
ethercat-device-control
A command line utility to control Ethercat devices
-
dialectic
Transport-polymorphic, asynchronous session types for Rust
-
stund
An SSH tunnel maintenance daemon
-
async_cell
A Cell<Option<T>> that you can await on
-
vss
A dead simple library to allow for easily reused shutdown signal handling
-
coroutine-state
Inspect the state of a Future created by an async function
-
tokio_wasi
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
async-raft
An async implementation of the Raft distributed consensus protocol
-
smelling_salts
Abstraction over OS APIs to handle asynchronous device waking
-
suika_utils
A small utility library for the suika web stack
-
cbsk_socket_tokio
socket callback tool by tokio
-
salvo-oapi
OpenApi support for Salvo web framework
-
prokio
An asynchronous runtime compatible with WebAssembly and non-WebAssembly targets
-
rspl
A stream processor language
-
tower-memlim
Tower based middleware layer to limit requests based on the host's computer memory usage
-
elfo
An asynchronous distributed actor framework with robust observability
-
scipio
A set of utilities to allow one to write thread per core applications
-
uid-mux
Async multiplexing library with user provided stream ids
-
libublk
building linux block device in userspace
-
async_zip_futures
An asynchronous ZIP archive reading/writing crate using futures-rs
-
handle
Trait for asynchronous context pipeline
-
asynclog
asynchronous log library
-
elegant-departure
simplify graceful shutdown
-
ptask
Spawning parasitic tasks
-
bp3d-threads
threading library intended to simplify concurrency in BP3D
-
baildon
B+Tree library
-
timer-lib
A feature-rich Rust library for creating and managing timers
-
reusable-box-future
A reusable
Pin<Box<dyn Future<Output = T> + Send>>
-
async-utf8-decoder
Convert AsyncRead to incremental UTF8 string stream
-
esrc
Primitives for implementing event sourcing and CQRS systems
-
zookeeper-async
An async ZooKeeper client
-
selecting
Cross-platform wrapper over select
-
starbase_events
Async and mutable event system
-
tokio-async-drop
macro to enable async drop in a tokio multithreaded runtime
-
tokio-file
Asynchronous file I/O for Tokio
-
foreback
Future adapters for running aditional work in the background
-
async-executor
Async executor
-
miniloop
The simpliest async executor without heap memory allocation
-
goods
Async assets system
-
abar
An interface for creating dynamic, "blocks"-style status strings
-
async-zeroconf
Async library for wrapping Zeroconf implemenations for use with Tokio
-
stream-find
Add a
find
andfind_map
methods to any stream -
crius
hystrix-like circuit breaker
-
ultra-batch
Tokio-based library to batch and cache database queries or other data lookups
-
bevy_impulse
Reactive programming and workflow execution for bevy
-
thin_main_loop
Thin, cross-platform, main event loop. A building block for native GUI applications, among other use cases.
-
tower-service
Trait representing an asynchronous, request / response based, client or server
-
any-mpsc
An mpsc that allows arbitrary types to be passed through
-
futures-await-test
Async test support for Rust through a procedural macro. This crate defines the
#[async_test]
attribute to make writing tests that use async/await easier. -
packet-ipc
Share packets between services using servo ipc
-
nolocal-block-on
futures_lite::future::block_on that can run without using thread-locals
-
clia_deepseek_rs
client library for the DeepSeek API (use rustls)
-
aiven_rs
sdk to interact with aiven-cloud apis
-
flurx
Create reactive asynchronous data flow
-
ractor_cluster
Distributed cluster environment of Ractor actors
-
legend-saga
working with RabbitMQ and asynchronous operations
-
task_forge
A flexible and simple task pool for asynchronous execution
-
windows-future
Windows async types
-
mfio
Flexible completion I/O primitives
-
docker_engine_api
way to interact with the Docker Engine API
-
tower-sessions-libsql-store
A small library for using tower-sessions with libsql
-
miau
Async aware and extensible layered configuration system
-
sonor
controlling sonos speakers
-
async-ringbuffer
A nonblocking spsc ring buffer with fixed capacity
-
medea-reactive
Reactive mutable data containers
-
aoc_leaderboard
Strongly-typed wrapper for Advent of Code leaderboard data
-
bb8-ruarango
bb8 connection pooling impmentation for the ArangoDB database
-
lictool
that will help you quickly add a spdx license to your project right from the command line
-
charred
char checking
-
lichess-api
client for Lichess API v2.0.0
-
stackful
Bridge between sync and async
-
waitgroup
Async waitgroup for a collection of task to finish
-
gcal_rs
A blazingly fast, hand written Google calendar API in Rust
-
send-future
Ergonomic and performant fix for https://github.com/rust-lang/rust/issues/96865
-
ng-repo
Repository library of NextGraph, a decentralized, secure and local-first web 3.0 ecosystem based on Semantic Web and CRDTs
-
async-fs
Async filesystem primitives
-
turbocharger
Autogenerated async RPC bindings that instantly connect a JS frontend to a Rust backend service via WebSockets and WASM
-
rust-cutil
cutil
-
sparkle-convenience
A wrapper over Twilight designed to make it more convenient to use
-
eyeball-im
Observable collections based on the
im
crate -
makepad-futures
Makepad futures
-
ordered-stream
Streams that are ordered relative to external events
-
heim
Cross-platform framework for system information
-
stdinix
function to reduce boilerplate for reading from stdin
-
luis_sys
FFI bindings for Microsoft LUIS API
-
zeebe
client for defining, orchestrating, and monitoring business processes across microservices using Zeebe
-
termusix
A terminal-based music player with a user-friendly terminal UI, built with Rust
-
vampirc-io
asynchronous, non-blocking, UCI protocol–based communication between chess UIs and chess engines
-
xilinx-dma
Userspace Xilinx AXI DMA Interface
-
booru-rs
An async Booru client for Rust
-
tokio-stomp-2
Unofficial successor to Asynchronous streaming STOMP client
-
flynn-openai
OpenAI
-
async-iterator
An async version of iterator
-
felicia
service for accessing and sharing lists of bad actors
-
async-io-typed
Adapts any AsyncRead or AsyncWrite type to send serde compatible types
-
zino-connector
Unified connector to data sources for zino
-
akinator-rs
wrapper around the undocumented Akinator API
-
stakker_mio
Mio I/O polling integration for the Stakker crate
-
simple-delay-queue
delay queue for Tokio
-
mapped_futures
A collection of futures based on FuturesUnordered that supports insertion, removal and mutation of futures by key
-
awak
A small async runtime for Rust
-
anchor-chain
A statically typed async framework for building LLM-based applications
-
google-cloud-ai
A gRPC-based crate designed to interact with Google Cloud AI API
-
rumqttlog
kafka inspired rumqtt's mqtt commitlog
-
actix-daemon-utils
Daemon Utilities by actix
-
smolscale
A high-performance async-task scheduler
-
inngest
Rusk SDK
-
napi_ext
Extends napi-rs with the ability to run local futures
-
telegram-bot-ars
creating Telegram bots
-
swiftide-agents
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
multiqueue
A fast mpmc broadcast queue
-
abort-on-drop
A wrapper of Tokio's JoinHandle that aborts the task when it's dropped, while still allowing it to be awaited for joining
-
async-rate-limiter
Implements a token bucket algorithm that can be used to limit API access frequency. Written in pure Rust.
-
mobc-lapin
RabbitMQ support for the async mobc connection pool
-
agnostic
abstraction layer for any async runtime
-
ora
Part of the Ora scheduler framework
-
hexpm
client for the Hex package manager
-
futures-core
The core traits and types in for the
futures
library -
thread-executor
Lightweight futures executor using std::thread::park
-
libhoney-rust
sending data to Honeycomb
-
clia-rcproxy
A lightweight, fast and powerful Redis Cluster Proxy written in Rust
-
unsync
Unsynchronized synchronization primitives for async Rust
-
constellation-internal
Common components for the
constellation
framework -
hypixel_api
Generic wrapper around the hypixel api (automatic rate-limiting on client-side)
-
async-sleep
Async Sleep
-
rx_rust_mp
A protoype implementation of the ReactiveX API in Rust using a message passing approach
-
kernel
Abstract Reactive Streams
-
service-io
Build your service-server fast, easy (and without hosting!)
-
async-scgi
Async SCGI Client & Server
-
capp
Common things i use to build Rust CLI tools for web crawlers
-
openraft-rocksstore
A rocksdb based implementation of the
openraft::RaftStorage
trait -
kvarn-quinn-proto
Temporary Kvarn fork: State machine for the QUIC transport protocol
-
pinned
Synchronisation primitives for !Send tasks
-
noosphere-storage
Pluggable backing storage for the Rust Noosphere implementation
-
releez
run application release-checklist safely
-
lazy_async_pool
An asyncronous object pool that generates objects on the fly
-
ssip-client-async
Client API for Speech Dispatcher
-
async-read-progress
Extension traits for inspecting
AsyncRead
progress -
rasi-sqlite3
rais database driver for sqlite3
-
compio-driver
Low-level driver for compio
-
backdrop
Drop your large or complex objects in the background with Backdrop! (later, on another thread, or both! Fully customizable! Tokio supported!)
-
certstreamrs
streaming Certificate Transparency Log events from the certstream service
-
dynalock
A lease based distributed locking algorithm with support for DynamoDB
-
async-time-mock-core
Mockable time for use in async runtimes (core package)
-
batch-channel
async channel that reduces overhead by reading and writing many values at once
-
msq
legacy Master Server Query Protocol
-
extreme
Extremely boring async function runner. MIT/Apache-2.0 license is available for spacejam's github sponsors.
-
specta-serde
Serde support for Specta
-
task-group
manage groups of tokio tasks
-
swiftide-query
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
pw-telegram-bot-fork
creating Telegram bots
-
handy_async
A handy library for describing asynchronous code declaratively
-
monoio-thrift
Thrift for Monoio
-
rxqlite-lite-common
A distributed sqlite database built upon
openraft
,sqlx
andsqlite
-
fibers
execute a number of lightweight asynchronous tasks (a.k.a, fibers) based on futures and mio
-
prost-codec
Asynchronous de-/encoding of Protobuf structs using asynchronous-codec, unsigned-varint and prost
-
tokio-shutdown
Wait for a stop signal across multiple threads
-
scylla-rs
An async ScyllaDB driver built on an actor-model framework
-
aws-smithy-http-server-python
Python server runtime for Smithy Rust Server Framework
-
dd-tracing-layer
Send your logs to Datadog
-
async_msp_cli
Async msp cli for iNav and BetaFlight
-
libaio-futures
Straightforward Linux AIO using Futures/async/await
-
layern
-
spekt
std::future::Future and Result-based testing trait for managing the lifecycle of stateful, asynchronous tests
-
async_sync
handling asynchronous and synchronous operations seamlessly
-
zsync
A Zero Dependency async net runtime thats truly cross-platform, including Windows, Linux, and MacOS
-
fastimer
This crates implements runtime-agnostic timer traits and utilities
-
polly-scheduler
A robust task scheduling system leveraging Tokio, with built-in fault tolerance, persistence, and recovery capabilities to ensure seamless task management and execution
-
future-utils
Extensions to Rust's Future and Stream traits
-
airlock
no_std async communication
-
libmqm-sys
IBM® MQ Interface (MQI) and MQ Administration Interface (MQAI) bindings
-
tk-listen
A set of helper futures allowing to listen TCP (or unix) socket with resource limits and proper error handling
-
tower-sesh
A Tower middleware for strongly typed, efficient sessions
-
channels-io
Async agnostic/Sync IO & buffer management abstractions
-
pwner
Process Owner crate that allows ergonomic access to child processes
-
register-count
Counting
Register
s created by aCounter
-
danube-client
The async client for Danube Messaging Broker platform
-
mio-extras
Extra components for use with Mio
-
clap-port-flag
Easily add a --port flag to CLIs using Structopt
-
futures_codec
encoding and decoding frames using
async/await
-
cb_fut
Call function that return value via callback without a callback
-
borrow-count
Memory that can be shared with a smart pointer and then reaquired with a future
-
yadwh
Discord Webhook Crate
-
kvarn-quinn-udp
Temporary Kvarn fork: UDP sockets with ECN information for the QUIC transport protocol
-
zeroconf-tokio
Tokio-based wrapper around the zeroconf crate, which provides mDNS service discovery and registration capabilities
-
booru-dl
A command line tool to download images and tags txt from booru
-
axum-router-plugin
Shared library-based plugins for Axum
-
cntrlr
async embedded framework
-
blec
cross-platform ble client library based on btleplug
-
futures-async-combinators
toy futures combinators
-
eventuals
Eventually consistent values
-
async-alloc-counter
measures max allocations in a future invocation
-
paho-mqtt-sys
Low-level, unsafe Rust wrapper for the Paho MQTT C Client Library. This is part of the official Eclipse Paho Rust Client Library
-
compio-net
Networking IO for compio
-
eventure
Event-Driven messaging library for Rust
-
tiny_future
Condvar
based future with automatic cancellation on drop -
zookeeper-cache
ZooKeeper client cache
-
negahban
🧐 A simple file watcher, based on
notify
, designed to be fast, easy-to-use and async friendly -
tokio-stdin-stdout
Thread- and future::sync::mpsc-based AsyncRead/AsyncWrite stdin/stdout with little buffering
-
blocking-permit
Permits and a thread pool for blocking operations
-
crossbus
A Platform-Less Runtime-Less Actor Computing Model
-
yamaha-rcp
Remote control of Yamaha mixing consoles using TCP/IP networking
-
chipp_http
curl-based HTTP client library
-
discern
implementing the Command Query Responsibility Segregation (CQRS) pattern
-
logimesh
RPC Microservice 2.0 framework
-
gprs
A set of filtered and optimized Rust libraries creates a foundation for building modern web frameworks
-
tokio-util_wasi
Additional utilities for working with Tokio
-
orsomafo
Event dispatcher crate
-
promising-future
Promise/Future pairs
-
viaduct
A duplex communication channel between a parent and child process, using unnamed pipes
-
micro_http_async
A small, lightweight and hassle-free crate using async to serve web pages or web apis with high performance and extremely low overhead
-
lib-wc
Will's Programming Toolbox
-
aggligator-transport-websocket
Aggligator transport: WebSocket
-
mini-c-ares-resolver
An asynchronous DNS resolver, backed by mini-c-ares
-
svix-webhook-with-clone
Svix webhooks API client with derive Clone added to Webhook struct
-
radix-router
Rust port of httprouter
-
pollable-map
Utilites for storing futures and streams in as a pollable map
-
crb-core-std
CRB | Composable Runtime Blocks | STD
-
oports
Async library to retrieve open ports for a given IP address
-
bufstream
Buffered I/O for streams where each read/write half is separately buffered
-
peace-performance
osu! pp & stars calculation. Peace edition
-
futures_ringbuf
Mock Type implementing AsyncRead/AsyncWrite for testing and examples
-
async_ui_internal_utils
for internal use only
-
async-os-pipe
Cross platform implementation of a bidirectional async pipe
-
prometheus-utils
built on top of the prometheus crate
-
tobytcp
A little library for sending messages over a tcp stream
-
safina-timer
Safe async timers - ARCHIVED: Code moved to
safina
crate -
prevayler-rs
System prevalence in rust
-
futures-executor
Executors for asynchronous tasks based on the futures-rs library
-
peace_webi_model
Web interface data types for the peace automation framework
-
curseforge
A straightforward asynchronous wrapper around the CurseForge Core API. Public API is subject to change before 1.0.0.
-
fluxor_cli
Fluxor CLI: a command-line tool that allows developers to quickly and efficiently create project starters for the Fluxor web framework
-
queen
message queue
-
sodium
FRP (Functional Reactive Programming)
-
futures-jsonrpcv2
Futures-based jsonrpc v2.0 crate
-
git-next-server-actor
Server actor for git-next, the trunk-based development manager
-
auto-future
For quickly making a struct into a future via an async fn
-
alopecosa
Pure rust async Tarantool 1.6+ connector built on tokio
-
async-xml
deserializing XML data asynchronously
-
freeswitch-esl
FreeSwitch ESL implementation for Rust
-
async-graphql-poem
async-graphql for poem
-
async-pipes
building concurrent data processing pipelines
-
aoc_leaderbot_lib
Support library for aoc_leaderbot, an Advent of Code leaderboard-watching bot
-
dioxus-v04-optional-hooks
Optional futures for Dioxus 0.4.0-0.4.3
-
pirates
async RPC lib
-
plumbing
An async abstraction to pipeline requests through a channel
-
baton
channel for receiving updates per field
-
futures_cbor_codec
A codec for framing an AsyncRead/AsyncWrite with cbor for all types that are serializable with serde
-
tower-etag-cache
A tower middleware for implementing ETag-based HTTP caching
-
assets
asynchronous asset management
-
futures-retry
Retry your Futures and Streams!
-
rlua-async
Async support for rlua, via coroutines
-
synerlogikos
A high-level, generic, abstracted Rust library for building any integration. It is designed to abstract away common patterns found in all integrations multiple times.
-
simple-scheduler
Schedule periodic tasks to run asynchronously
-
tokio-stomp-rs-rs
Asynchronous streaming STOMP client fork
-
shutdown-handler
A shutdown handler that allows all parts of an application to trigger a shutdown
-
truba
The minimal tokio runtime based actors for Rust
-
screeps-async
Tick-aware Async runtime for Screeps
-
mmapio
Cross-platform Rust API for memory-mapped file IO
-
tokio-duplex
Combine seperate
AsyncRead
andAsyncWrite
types into a singleAsyncRead + AsyncWrite
type -
noob
A WIP futures-based Discord bot library
-
kad
A generic / futures based implementation of the Kademlia Distributed Hash Table (DHT)
-
event_iterator
Asynchronous lending iterator
-
retry_future
Retry futures mechanism
-
simple-middleware
General purpose middleware crate
-
a2
A native, asynchronous Apple push notification client
-
client-util
Help you to build requests and handle responses by several extension trait!
-
utapi-rs
wrapper around the UploadThing API
-
deadpool-fantoccini
Dead simple async session pool for fantoccini
-
linked-futures
Link futures into a block, which stops all of the included futures when any of the futures complete
-
cancellation-token
C#'s CancellationToken API
-
tokio-nsq
NSQ client built on Tokio. Tokio NSQ aims to be a feature complete NSQ client implementation.
-
kafka-rs
Native Rust Kafka client, built upon kafka-protocol-rs and Tokio
-
alan-runtime
A runtime in Rust to run AGC or Alan Graphcode, alan's bytecode format
-
mio-uds
Unix domain socket bindings for mio
-
rad
A type-safe, high-level interface to librados using the low-level C bindings from ceph-rust
-
piston_rs
An async wrapper for the Piston code execution engine
-
ya-etcd-rs
etcd client for rust
-
cbsk_run
async pool tool
-
godot_tokio
The tokio-async runtime wrapped in a gdextention object to be used as an engine singleton in your gdext project
-
deadpool-lapin
Dead simple async pool for lapin
-
tokio-util
Additional utilities for working with Tokio
-
key-rwlock
keyed asynchronous reader-writer locks
-
wd_event
event system
-
this-state
way to store state in a thread-safe manner as well as a way to asynchronously wait for state changes
-
taskline
distributed task queue for Rust
-
async-dropper-simple
struct-wrapper (i.e. AsyncDropper<T>) based implementation of AsyncDrop
-
hls_lfcd_lds_driver
Rust driver for ROBOTIS HLDS HLS-LFCD-LDS (LDS-01)
-
fb_futures_01_ext
Extensions for future 0.1 crate
-
async_singleflight
Async singleflight
-
async-weighted-semaphore
An async weighted semaphore
-
visiting_ref
Container types that asynchronously return ownership of a value to another context upon exiting scope
-
async-waitgroup
Golang like WaitGroup implementation that supports both sync and async Rust
-
tokio-lk
Futures-aware lock-by-id primitives
-
troupe
modelling Rust applications with actors
-
bongonet-timeout
Highly efficient async timer and timeout system for Tokio runtimes
-
swimos_errors
SwimOS Error Utilties
-
tasc
A minimnal, asynchronous threadpool
-
naumi
Lightweight and fast data transfer protocol. Fast de/serialization and tiny size!
-
vesper
A slash-command framework meant to be used with twilight
-
stow
Cloud storage abstraction package for Rust
-
async-copy-progress
Asynchronous copying with progress callbacks
-
maelstrom-node
Maelstrom Rust node framework
-
tokio-graceful-shutdown-without-anyhow
perform a graceful shutdown on a Tokio based service
-
oneshot-handshake
providing a symmetric one time use channel type
-
kvarn_async
Async utilities used in the Kvarn web server
-
saas-zmq
ZeroMQ tools by using Publish-Federation
-
asynk
Multithread asynchronous runtime and reactor
-
yrs
High performance implementation of the Yjs CRDT
-
streammap-ext
StreamMap of Tokio with altered
next
that returns when stream is dropped -
deadline
A one-macro crate to ensure assertions meet their deadlines
-
ipstack-geph
Asynchronous lightweight userspace implementation of TCP/IP stack for transparent proxies
-
wait
Syntactic sugar for calling async functions outside of an async context
-
tezaursapi
api wrapper for tezaurs.lv
-
qp
Quick Pool: High Performance Async Generic Pool
-
tokio-serde-cbor
Integration of serde_cbor into tokio-io, to allow sending CBOR encoded frames across network (and possibly through other transports)
-
futures-test
Common utilities for testing components built off futures-rs
-
nasu
Command-line utility which poll on remote addresses in order to perform status checks periodically
-
lookit
Asynchronously connect to devices
-
gmf
An RPC library using Glommio and Tonic. Note: This package only works on Linux.
-
tokio-socks
Asynchronous SOCKS proxy support for Rust
-
app_ctx
An AppCtx implementation in Rust, like ApplicationContext in SpringBoot
-
aa-sms
Send messages from with Andrews & Arnold’s SMS API
-
bipe
asynchronous I/O pipe
-
pseudoterminal
A cross-platform pseudoterminal implementation with async support
-
gandi-v5-livedns-api
Gandi LiveDNS Api
-
cbsk_socket_rayon
socket callback tool by rayon
-
async-send-fd
A wrapper for async UnixStream's to send file descriptors
-
background-jobs-tokio
in-process jobs processor based on Tokio
-
shinyframework_jobs
Shiny Jobs
-
paperless-rs
An asynchronous Rust library for the Paperless-ngx document manager
-
pingora-runtime
Multithreaded Tokio runtime with the option of disabling work stealing
-
conva_ai
Rust SDK for using CONVA AI Copilots
-
maudit_rolldown_utils
Fork of Rolldown for the Maudit project until Rolldown is published on crates.io
-
alith-client
The Easiest Rust Interface for Local LLMs, and an Interface for Deterministic Signals from Probabilistic LLM Vibes
-
dyn-future
Convenient and fast dynamic Futures for Rust
-
cannyls_rpc
RPC library for operating cannyls's devices from remote nodes
-
tokio-easy-timer
A tokio-based task scheduler, with a user-friendly API
-
moxie
Incremental runtime for interactive software
-
speedracer
racing futures and ranking the results
-
mm1-common
M/M/1! Queueing, do you speak it?!
-
sntpc
making SNTP requests
-
async-mavlink
An async adapter for mavlink conections
-
yap2p
Experimental yet another peer-to-peer library
-
domain-resolv
An asynchronous DNS stub resolver
-
swarm-commander
Manage tons of commands asynchronously
-
patoka
Try this if you can decompose your problem into actors
-
tidy-browser
Tidy up browser information
-
acton-reactive
Acton Reactive is the main crate of the Acton framework, designed for building reactive, event-driven, and asynchronous systems. It provides intuitive abstractions to make working with…
-
zeebest
An unofficial zeebe client for the future!
-
tija_tools
tija_tools
is a Rust library providing a set of utilities designed to perform common tasks in Rust programming. This library is open for use and can be utilized in various applications… -
ctp-common
Common types and utilities for CTP (China Financial Futures Exchange) API
-
slog-scope-futures
slog-scope for
Future
s -
terminusdm
Terminus Download Manager. Download files, resume interrupted downloads, and keep a history of your downloads - within terminal UI.
-
maily
easy, quick, and fault tolerant sending of emails
-
awaitable
type with input and output that can be stored in container
-
gentian
proc macro that transforms generators to state machines
-
crabler
Web scraper for Crabs
-
viz-router
The router for Viz
-
agnostic-dns
agnostic-dns
is an agnostic abstraction layer overhickory-dns
-
compio-fs
Filesystem IO for compio
-
async-notify
A general version async Notify, like
tokio
Notify but can work with any async runtime -
pantry
Temporary storage for reusing values that may decay
-
aem-eye
a very fast aem detection tool
-
isoprenoid
signals runtime framework backing flourish
-
js-sys-futures
working with the futures and js-sys crates
-
raftlog
distributed replicated log based on the Raft algorithm
-
f289ctrl
Communication library for Fluke 289 digital multimeter
-
noosphere-collections
Collection data types that are needed by an efficient implementation of Noosphere's IPLD data structures
-
async-psec
Asynchronous PSEC implementation
-
poison_pill
A tiny wrapper for managing children in async environment
-
act_rs
Act.rs is an actor library built to be used with the standard library and Tokio
-
nsq-client
Rust client for the NSQ realtime message processing system
-
zippyst
Resolve zippyshare.com download links
-
tokio-vsock
Asynchronous Virtio socket support for Rust
-
rust-rsm
RSM:A Realtime Software Middleware framework. Asynchronous, event driven framework
-
mq
Message Queue
-
senax-linker
Senax linker
-
lunatic-registry-api
Lunatic host functions for registering named processes
-
deferred
help perform deferred execution of code logic
-
yacme-service
ACME high-level client library
-
moeval
a toy interpreter
-
rumpsteak
Session types for asynchronous communication between multiple parties
-
northstar-rcon-client
Asynchronous RCON client for the Northstar mod
-
futures-cache
Futures-aware cache backed by sled
-
happyeyeballs
Happy Eyeballs implementation in Tokio (not RFC compliant atm)
-
monoio-compat
A compat wrapper for monoio
-
async-jobs
Asynchronous job orchestration for Rust
-
leptos_async_signal
Async signal for leptos Rust web framework
-
elf_loader
A pure-rust library for loading all ELF format files from both memory and files
-
mio-misc
Miscellaneous components for use with Mio
-
signal-hook-tokio
Tokio support for signal-hook
-
tracing-orchestra
Give me more instruments!
-
maybe-future
Future that can be None
-
rasi
Asynchronous IO System Interface
-
page-turner
A generic abstraction of APIs with pagination
-
b961fce
-
tokio-switching-sleep
A tokio Sleep with a switchable state
-
dndx-fork-tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
write-journal
Write to files with a journal
-
random-access-storage
Abstract interface to implement random-access instances
-
tokio-xmpp
Asynchronous XMPP for Rust with tokio
-
napmap
Async HashMap that halts requester tasks until the requested data is accessible
-
rants
An async NATS client library
-
futures-ratelimit
Bounded flavors of futures' FuturesUnordered and FuturesOrdered
-
conquer-struct
macros to perform concurrent future resolution, while populating struct fields
-
ticque
Take a queue for a resource
-
fundamentum-sdk-api
HTTP client targeting Fundamentum IoT devices RestAPI
-
space-traders
Async SpaceTraders API client for Rust
-
tokio-js-set-interval
Allows you to use
setInterval(callback, ms)
andsetTimeout(callback, ms)
as in Javascript inside atokio
runtime. The library provides the macrosset_interval!(callback, ms)
andset_timeout!(callback, ms)
-
gcs-rsync
rsync support for gcs with higher perf than gsutil rsync
-
bonsaimq
Message/job queue based on bonsaidb, similar to sqlxmq
-
async-uci
An async UCI Implementation over the tokio runtime
-
titdb
Trails in the Database API
-
mioco
Scalable, asynchronous IO coroutine-based handling (aka MIO COroutines)
-
crown
jewel of rust libraries
-
agnostic-process
Agnostic abstraction layer of
std::process
for any async runtime -
zonyitoo/coio
Coroutine scheduler with non-blocking I/O support
-
contained-actors
contained is a research project implementing the proposed harmonic runtime for orchestrating cloud-native systems
-
agixt-sdk
Rust SDK for AGiXT - A powerful AI agent framework
-
fut_rwlock
A read-write lock that is read and written via Futures
-
volo-http
HTTP framework implementation of volo
-
mycelium_lib
Mycelium DDM
-
awaitgroup
Wait for a collection of async tasks to finish
-
async-ctrlc
Async wrapper of
ctrlc
-
pausable_future
Pausable and resumable future, useful in background tasks
-
izihawa-common-multipart
multipart/form-data
-
async-select-all
A futures library adapter for selecting over a list of futures
-
tower-sessions-file-based-store
File-based session store for
tower-sessions
-
tcp-channel-client
Asynchronous tcpclient based on aqueue actor
-
hydrus-ptr-client
A http client for the hydrus ptr
-
bean_factory
bean factory,support inject reference bean
-
kumoko
asynchronous server/client crate built on tokio for easy two-way streaming
-
io-tubes
functionality like pwntools tube for async io in rust
-
aggligator-transport-usb
Aggligator transport: USB
-
nbchan
Highly optimized non-blocking communication channels
-
smol-potat
Proc macro for smol runtime
-
wookie
Async test/bench toolkit including single stepping executors. No-std compatible.
-
ctp-futures
A short description of your crate
-
async-signals
easier and safe Unix signal handling with async Stream
-
ianaio-file
Convenience crate for working with JavaScript files and blobs
-
signald-rust
interface with Signald
-
mustang
Rust programs written entirely in Rust
-
graceful-shutdown
Graceful Shutdown for async code
-
rfm69-async
async driver for the rfm69 radio transceiver
-
django-query
Tools for mocking Django-style endpoints
-
dabus
Dynamic Aplication Controll Bus - an asynchronous, event based module system for thoes who want to move fast and *not* break things
-
rspc-axum
Axum adapter for rspc
-
scoped_tasks_prototype
A quick-and-dirty attempt to get scoped tasks in Rust
-
untokio
Automatically create tokio runtimes
-
event-listener-strategy
Block or poll on event_listener easily
-
peace_webi_output
Web interface output for the peace automation framework
-
wasmcloud-interface-sleepy
Interface for interacting with the sleepy capability provider
-
evdev-shortcut
Global shortcuts using evdev
-
night
A scalable Task Queue for executing asynchronous tasks in topological order
-
tokio-shield
Prevent futures from being aborted by wrapping them in tasks
-
quick_crawler
QuickCrawler is a Rust crate that provides a completely async, declarative web crawler with domain-specific request rate-limiting built-in
-
pyo3-anyio
PyO3 utility bindings for Anyio's event loop
-
async-anyhow-logger
An easy crate for catching anyhow errors from an asynchronous function, and passing them to your logger
-
tokio-prepend-io
Wrapper types that prepends data when reading or writing with AsyncRead or AsyncWrite
-
zstd-framed
zstd seekable format compression and decompression. Supports sync and async I/O
-
simple_futures
futures for use in async operations
-
merge-io
Merge two separate
AsyncRead
andAsyncWrite
objects into a single I/O stream -
circulate
Lightweight PubSub framework that supports both sync and async
-
tower-async-http
Tower Async middleware and utilities for HTTP clients and servers. An "Async Trait" fork from the original Tower Library
-
agnostik
Executor Agnostic Runtime that can run your futures with your favourite Executor
-
indexed_db_futures
Future bindings for IndexedDB via web_sys
-
cyfs-bdt
package
-
flv-future-aio
I/O futures for Fluvio project
-
tokactor
A actor model framework wrapped around tokio
-
stream-wave-parser
The
stream-wave-parser
is a crate that treats a stream from WAVE file -
laizy
stable and thread-safe implementation of a lazy value
-
unblock
A thread pool for isolating blocking in async programs
-
nyantrack-common
Common data types and functionality for NyanTrack
-
chunnel
Async mpmc(multi producer multi consumer) channel
-
git-event
Customizable event handler for updates in remote git repositories
-
heph
actor framework based on asynchronous functions
-
promise
future/promise library for rust
-
simple-async-pipe
Aims to provide a simple pipe-like functionality for async code
-
reception
creating TCP listeners that spawns clients providing model abstraction layer
-
susync
An util crate to complete futures through a handle. Its main purpose is to bridge async Rust and callback-based APIs.
-
heim-cpu
Cross-platform CPU information
-
tor-general-addr
Generalized socket address type used by Tor
-
zino-storage
Files and storage services for zino
-
springtime
Dependency injection based application bootstrapping and execution crate
-
tokio-beanstalkd
Asynchronous client library for interacting with Beanstalkd work queue
-
twistrs
An asynchronous domain name permutation and enumeration library
-
standardwebhooks
creating and verifying webhook signatures
-
async-log
Async tracing capabilities for the log crate
-
metalmq
server
-
async-refresh
Create values that refresh automatically and asynchronously after a given duration
-
bband-rs
Bollinger Bands (BBand) implementation In Rust
-
gossip-relay-picker
A relay picker for nostr, used by gossip
-
bb8-bolt
A bolt-client adaptor for the bb8 connection pool
-
tokio-libtls
Tokio bindings for LibreSSL's libtls
-
replay-channel
A broadcast channel where new receivers replay all past messages before receiving new ones
-
pi_futures
feature select
-
merge-streams
Merge multiple streams into one
-
jarust
A janus client SDK in Rust
-
wgp
waitgroup implementation
-
tonic-arcanyx-fork
A gRPC over HTTP/2 implementation focused on high performance, interoperability, and flexibility
-
poolparty
Added functionality for the
futures::executor::ThreadPool
futures executor -
async_chanx
Implement
Sink
for some channel implementations -
wait_not_await
awaiter implementation
-
blockz-futures
working with futures for the tokio stack
-
arta-async-std
Async abstractions implementation for async-std
-
scout
Friendly fuzzy finder for the command line
-
joyent-tokio-zookeeper
Asynchronous client library for interacting with Apache ZooKeeper
-
eventually-postgres
Event Store implementation using PostgreSQL for the Eventually crate
-
libevent
Rust bindings to the libevent async I/O framework
-
write-hasher
Transparently calculate hash on (asynchronously) writing to an type
-
tokio_interval
基于Tokio实现了 setInterval(callback, ms) 和 setTimeout(callback, ms) 类似于Javascript的API
-
io_uring_actor
Near-zero overhead pipelined io_uring api via actor model so you don't have to use Arc<Mutex<IOUring>>
-
mak
but mak it faster
-
mio-wakeq
mio support for custom event queue via Waker
-
limitation
A rate limiter using a fixed window counter for arbitrary keys, backed by Redis
-
relm
Asynchronous, GTK+-based, GUI library, inspired by Elm, written in Rust
-
fates
creating reactive declarations
-
tinkoffpay
tinkoff integration (the seller receives a link to the payment form and redirect the buyer to it); NB: with callback method
-
mcp-client-fishcode2025
Client SDK for the Model Context Protocol
-
libremexre
A bunch of utilities I found myself needing over and over again
-
metatrait
RPITIT Monads
-
async-recursion
Recursion for async functions
-
mio-signals
handling signals with Mio
-
nrf52840-platform
Holistic embedded device support for nrf52840-based devices in a batteries-included manner
-
ws-gonzale
Naive websocket server implemented using async / await
-
async-observable
Async & reactive synchronization model to keep multiple async tasks / threads partially synchronized
-
newsblur_api
NewsBlur-API
-
syndicate
Syndicated Actor model for Rust, including network communication and Dataspaces
-
dwbhk
dwbhk-rs is a library for working with Discord Webhooks
-
tokio-tower
Bridging the protocol gap between Tokio and Tower
-
future-clicker
Reimplementation of manual_future without using
futures
unstable -
clap-and-async-test
Is a example to use clap with tokio and futures, how run concurrently some functions with a loop inside
-
hypixel
Rust wrapper for the Hypixel public API
-
async-defer
Asynchronous Deferred Calls
-
mrwei
that implements the common promise primitive for rust based on std future
-
streamies
More features for your streams
-
tokio-io-compat
Compatibility wrapper around std io traits that implements tokio io traits
-
r2d2_pulsar
Connection pooling for pulsar client
-
dbus-tokio
Makes it possible to use Tokio with D-Bus, which is a bus commonly used on Linux for inter-process communication
-
crb-system
CRB | Composable Runtime Blocks | System Integration
-
lava-api
Helper crate to work with the LAVA REST APIs
-
nr-tracing-layer
Send your logs to New Relic
-
wag
Go like sync.WaitGroup implementation in Rust. (sync/async)
-
rustpub
Activitypub types
-
dummy-waker
Get a
core::task::Waker
that does absolutely nothing -
wait-for-me
Async CountDownLatch
-
hydra-websockets
A websocket server for the hydra framework
-
bing_client
Async reverse client for Bing copilot
-
aligne
A small crate using tokio to synchronize asynchronous request/response with Ids
-
allochronic-util
Private utility crate for allochronic and khonsulabs
-
fbinit-tokio
detail of fbinit crate
-
nextgraph
client library. Nextgraph is a decentralized, secure and local-first web 3.0 ecosystem based on Semantic Web and CRDTs
-
rust-with-kafka-tls
Rust messaging with a Strimzi Kafka cluster secured with self-signed tls assets for encryption in transit with mTLS for client authentication
-
cucumber
testing framework for Rust, with async support. Fully native, no external test runners or dependencies.
-
ruchei-route
Sinks with routes
-
tower-async
Tower Async is a library of modular and reusable components for building robust clients and servers. An "Async Trait" fork from the original Tower Library.
-
russh-agent
Asynchronous ssh-agent client
-
taskwait
Runtime agnostic way to wait for a group of async tasks
-
retry_fn
retry function with versions for blocking or non-blocking, tokio or async-std
-
loading-bytes
Load bytes from paths on native and WASM
-
libevent-sys
Rust FFI bindings to the libevent library
-
rusty_tarantool
Tarantul async client based on tokio framework
-
tastyworks
Unofficial Tastyworks API
-
tokio-socketcan-bcm
Asynchronous Linux SocketCAN - Broadcast Manager support (BCM) with tokio
-
pipebuf_websocket
PipeBuf support for websockets
-
sfio-tokio-ffi
An oo-bindgen model for using Tokio in an FFI environment
-
futures-diagnose
Wraps around a Spawn and provides lots of diagnostics
-
asyncs
async runtime agnostic facilities
-
rule_rs
A lightweight rule engine implemented in Rust that supports asynchronous execution, component extension, and rule chain orchestration
-
anchored
things can't cross the .await point
-
batch-renamer
Framework and command line utilities for interactive renaming of a potentially large number of files
-
interval_future
Wraps a synchronous, waker-less polling function in an interval-based future
-
andiskaz
A convenience library for writing games and other apps in TUI
-
zusammen
Download files in parallel
-
completion
writing completion-based asynchronous code
-
td_revent
Event library for Rust, Async IO similar to libevent
-
atcoder
A template for Rust project
-
tokio_delayed_queue
Asynchronous delayed queue for Tokio runtime
-
pinarcmutex
PinArcMutex
type, for shared mutable access to pinned data -
rs-copier
Copy and move files asynchronously
-
stream-guard
RAII wrapper around Stream that invokes a custom action on drop
-
containerd-snapshots
Remote snapshotter extension for containerd
-
tarpc-lib
An RPC framework for Rust with a focus on ease of use
-
io_uring_buf_ring
Help user create and manage io-uring buffer-ring
-
fb-api
Facebook Api abstraction for async rust
-
italo-api
Rust binding for Italo API
-
tactix
Actor Model based on Tokio
-
pi_async
Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
-
Agentic-rs
agents
package provides a set of tools for creating and managing agents capable of processing text and performing specified tasks based on a given role. It leverages asynchronous… -
tag_nominatim
Bindings to the reverse geocoding API powered by openstreetmap
-
async-timers
asynchronous timer primitives
-
ktx-async
Asynchronous reader for KTX texture format
-
simple-process-stats
Get memory usage and CPU time on Linux and Windows
-
crate-test-xxx
test crate
-
hapic
HTTP API Client (hapic): A Rust crate for quickly creating nice-to-use client libraries for HTTP APIs, in particular, there's lots of tooling around HTTP JSON APIs
-
async-signal
Async signal handling
-
termion-input-tokio
An adapter that exposes termion's input and key event iterators as asynchronous streams
-
pingp
ping lib that pings websites easy and fast
-
framed_aio
allows performing async io operations in a framed manner
-
there
planning and executing commands on local and remote hosts
-
eventador
lock-free pub/sub event-bus with sync and async APIs
-
messagebird-async
Wrapper around the message bird SMS API
-
pub-sub-client
Google Cloud Pub/Sub client library
-
progenitor-impl
An OpenAPI client generator - core implementation
-
mezzenger-utils
mezzenger
-
promises
Effective, simple, lightweight Javascript promises in Rust
-
taps
taps (Tokio Asynchronous Pub/Sub) is an in-process async message broker that can be used for messaging between spawned tokio tasks
-
deluge
A highly concurrent stream library driving the underlying futures either concurrently or in parallel to process streaming operations as quickly as possible
-
async-usercalls
An interface for asynchronous usercalls in SGX enclaves. This is an SGX-only crate, you should compile it with the
x86_64-fortanix-unknown-sgx
target -
lunatic-control
TBD
-
async-codec-lite
Adaptors from AsyncRead/AsyncWrite to Stream/Sink using futures
-
fil_actors_runtime_v10
System actors for the Filecoin protocol
-
awaitable-bool
A Tokio-powered awaitable bool (analogous to a flag and highly inspired by Python’s
asyncio.Event
, but can be waited for to become ‘false’ too) -
rust_howto
A documentation summary and a compendium of snippets and recipes for the Rust language and ecosystem. Everything you need for day-to-day Rust coding, all in one place.
-
embedded-executor
Embedded systems-friendly
Futures
executor -
bon
Next-gen compile-time-checked builder generator, named function's arguments, and more!
-
yaanhyy_rust
cargo mod example
-
uller
Generate/Donwload your links
-
sidekiq-rs
Sidekiq compatible server in Rust
-
alligator
getting the output value from a future
-
k8s-controller
lightweight framework for writing kubernetes controllers
-
rexer
Async I/O multiplexing library for rust
-
archlinux-repo
Arch Linux repositories parser
-
bevy_flurx
Allows you to use coroutine in Bevy
-
image_search
designed to search Google Images based on provided arguments
-
timer-rs
timer used to schedule execution of closures at a given timestamp
-
webrocket
A closure focused WebSocket server implementation
-
tourniquet
Async native round-robin manager for remote services
-
safina-threadpool
Safe thread pool - ARCHIVED: Code moved to
safina
crate -
twitchchat
interface to the irc-side of twitch's chat system
-
async-cuda-npp
Async NVIDIA Performance Primitives for Rust
-
back-to-the-future
Conversions between std::future::Future and futures::Future
-
http-lib
High-level, asynchronous API for ureq, a safe HTTP client
-
actix-limitation
Rate limiter using a fixed window counter for arbitrary keys, backed by Redis for Actix Web
-
callbag
spec for reactive/iterable programming
-
count-write
An io::Write wrapper counting the number of bytes written
-
futures-async-stream
Async stream for Rust and the futures crate
-
misanthropic
An async, ergonomic, client for Anthropic's Messages API
-
citadel_types
Types for the citadel protocol
-
gritlab
Gitlab rust API sdk
-
async-handle
A reference-counted async RwLock
-
callback-future
Adapter between callbacks and futures
-
uds
A unix domain socket crate that supports abstract addresses, fd-passing and seqpacket sockets
-
async_msp_lib
Async msp library for iNav and BetaFlight
-
qbit-api-rs
A asynchronous Rust wrapper for qBittorrent Web API
-
tracing-actix
Allow tracing actor futures in actix
-
azur
A no_std Rust crate that implements an executor/reactor and futures using io_uring
-
discv5
p2p discv5 discovery protocol
-
ert
A combinator to control future execution order
-
ardop_interface
Interface to the Amateur Radio Digital Open Protocol (ARDOP)
-
discord_api
Interact with the Discord API from your shell
-
tokio-curl
asynchronous HTTP client using futures backed by libcurl
-
lending-stream
A lending version of Stream
-
starstruck
A game building utility that is made to be simple to use while still providing great performance
-
islabtech-upw-sensor-v1
Rust client library for remote control of the ISLabTech UPW Sensor v1
-
cu
Low level bindings to cuda apis
-
samotop
SMTP server and library built on async-std
-
f1-api
F1 API is a client library for the telemetry API of the F1 video games by Codemasters. It uses asynchronous networking to decode the incoming UDP packets, and turns them into strongly typed Rust structs.
-
future-combinator-params
functions to inject extra arguments between futures combinators Then/AndThen
-
atomic-waker
A synchronization primitive for task wakeup
-
select-next-any
Alternative to futures::StreamExt::select_next_some that returns the None variant
-
settimeout
Creates a std::future::Future implementation to be ready at some point
-
ebus
Basic Event Bus implementation
-
taos
Driver for TDengine - a timeseries database and analysis platform
-
textmode
terminal interaction library backed by a real terminal parser
-
scoped_async_spawn
spawn non-static futures
-
tokio-uds-proto
Unix Domain sockets working with tokio-proto
-
futura
Helpers for working with futures
-
sn_data_types
Safe Network Data Types
-
tokio_telegraf
Minimal async rust wrapper for the telegraf/influxdb protocol, based on Tokio
-
set_timeout
allows efficiently executing futures after some delay has passed
-
otdb
An open trivia database API wrapper
-
test_executors
async executors for testing
-
rmw_ttlmap
Minimal async cache in Rust with support for key expirations
-
async-file-lock
Asynchronous file lock that can auto lock and auto seek
-
heim-common
Common stuff shared across heim project crates
-
future_handles
complete futures via handles
-
mini-telnet
Asynchronous minimal telnet library
-
async-shared-timeout
Async timeout that can be reset and shared
-
mini-c-ares
A minimal Rust wrapper for the c-ares library, for asynchronous DNS requests, based on rust-c-ares
-
async-raft-ext
An async implementation of the Raft distributed consensus protocol.The ability of raft is enhanced while keeping the access interface unchanged for rnacos
-
paxos-rust
A lightweight implementation of the Paxos Consensus Algorithm
-
create-rspc-app
Get started with your next rspc app!
-
archimedes_task_handler
handle tasks for the Archimedes project
-
tokio-uring
io-uring support for the Tokio asynchronous runtime
-
eyeball-im-util
eyeball-im
-
sigio
signal-based async io
-
tokio_util_watchdog
A watchdog utility for tokio runtimes
-
fundamentum-edge-pfwd
The port forwarding tool for edge daemon
-
scd4x-rs
query SCD4x sensors over I²C
-
medina
An asynchronous web crawling engine
-
xtra
A tiny actor framework
-
aggligator-transport-bluer
Aggligator transport: Bluetooth on Linux
-
lifeline
dependency injection library for asynchronous message-based applications
-
reqwest-eventsource
Helper to build an Eventsource using reqwest
-
openraft-memstore
A in-memory implementation of the
openraft::RaftStorage
trait -
async-variadic
async variadic functions in Rust with trait bounds
-
ipc-orchestrator
Orchestion of command line processes for local dev usage with IPC communication
-
blocker
Block rust futures to create a synchronous wrapper around an asynchronous api
-
serenity_ctrlc
Ctrl+C handler for serenity
-
futures-zmq
Futures abstractions for ZeroMQ on any futures executor
-
hl7-mllp-codec
A Tokio codec for HL7 Minimal Lower Layer Message Transport protocol (MLLP)
-
strawpoll
A wrapper to avoid spurious polling
-
twitch-irc
Connect to Twitch chat from a Rust application
-
rs-car-ipfs
rs-car wrapper to read files from IPFS trustless gateways
-
pistones
An wrapper for the Piston code execution engine
-
bongonet-runtime
Multithreaded Tokio runtime with the option of disabling work stealing
-
highlightio
hightlight.io SDK for Rust
-
futures-util-either
futures_util::future::Either Ext
-
slice_ops
A selection of useful slice operations
-
futures-yamux
The yamux protocol implementation, rewritten from the ground up
-
mutex-extra
RefMutex<T>
that is similar toMutex<T>
but isSync
andSend
even ifT
isn’tSend
-
dwn
Decentralized Web Node
-
jittr
A binary heap based jitter buffer implementation for zero latency udp/rtp streams
-
bears
wrapper for the Bureau of Economic Analysis (BEA) REST API
-
tokio-smoltcp
An asynchronous wrapper for smoltcp
-
openrazer
Asynchronous bindings to the OpenRazer daemon
-
waterark
Watermark for implementing optimistic SSI (Serializable Snapshot Isolation) transactions
-
kafka
Rust client for Apache Kafka
-
async-io-map
mapping of async IO operations
-
anotify
Async iNotify Filesystem Watcher
-
izihawa-hyper-multipart
multipart/form-data for Hyper
-
cf-turnstile
client for Cloudflare Turnstile
-
re_byte_size
Calculate the heap-allocated size of values at runtime
-
futures-boring
SSL streams for Futures built on top of the BoringSSL
-
monoio-rustls
Asynchronous TLS streams wrapper for Monoio based on Rustls
-
yacme-test
ACME test helpers for YACME
-
archflow
Create a streamable Zip archive
-
elaine
Async http head reader
-
hash_events
An MPMC event system that allows for custom events. Events are emitted with a payload, and subscribers to that event are stream of payloads. For each event, all subscribers are triggered.
-
async_progress
Create sync points across async tasks
-
stateful_async_worker
Asynchronous stateful worker threads utilizable as futures
-
async-convert
Async TryFrom/TryInto traits
-
ncu-rs
A stupid simple and fast cli for updating your package.json dependencies
-
arti-rpcserver
Backend functionality for Arti's RPC service
-
tokio-named-pipes
Windows named pipe bindings for tokio
-
projections
Macro-free pin projections because why not?
-
puteketeke
An asynchronous runtime built on smol
-
tokio-stomp
Asynchronous streaming STOMP client
-
async-blocking-stdio
std::io::std{in(), out(), err()} but async
-
eventsourcing
Event Sourcing for Rust
-
webweg
An asynchronous API wrapper for UCSD's WebReg course enrollment system
-
dynamodb-mutex
Use Dymanodb mutex library
-
cdp-html-shot
capturing HTML screenshots using CDP
-
madsim-rdkafka
The rdkafka simulator on madsim
-
somen
An asynchronous parser combinator
-
gcp_auth
Google cloud platform (GCP) authentication using default and custom service accounts
-
sched-clock
A timer for task scheduling
-
rs1541
Rust bindings and helper functions for accessing Commodore disk drives
-
tangle
Future implementation for Rust
-
eventific
that gives you the needed building blocks for event sourcing
-
cloudflare_dyndns
DynDNS client for Cloudflare
-
async-rayon
Mix async code with CPU-heavy thread pools using Futures + Rayon
-
async-task-ffi
Task abstraction for building executors
-
git-cinnabar
git remote helper to interact with mercurial repositories
-
switchyard
Real-time compute focused async executor
-
ockam
End-to-end encryption and mutual authentication for distributed applications
-
crypto-auditing
Client library for crypto-auditing project
-
async-fuse
Helpers for fusing asynchronous computations
-
v_exchanges_adapters
Implementations of HTTP/HTTPS/WebSocket API methods for some crypto exchanges, using crypto-botters framework
-
srmw
Asynchronous single-reader, multi-writer
-
blocking_pool
A thread pool for running synchronous I/O in asynchronous applications
-
dnsaur
An asynchronous DNS stub resolver
-
yew-interop
use javascript and css asynchrously in yew
-
mikrotik_api
& minimal client to connect and interact with Mikrotik RouterOS API, usually exposed on port 8728
-
arta-tokio
Async abstractions implementation for Tokio
-
inklings
A unified Rust API for various Large Language Model (LLM) providers
-
sparkle-impostor
A third party crate for Twilight to execute Discord webhooks that clone an existing message
-
viz-utils
Viz utils
-
futures-await-test-preview
Async test support for Rust through a procedural macro. This crate defines the
#[async_test]
attribute to make writing tests that use async/await easier. -
variable-len-reader
reading/writing variable length data. Support AsyncRead/AsyncWrite in tokio.
-
local-runtime
Thread-local async runtime
-
rseip-cip
common industry protocol for rseip
-
hermod
futures-based RSS/Atom library
-
vkteams-bot-cli
VK Teams Bot API CLI
-
par-stream
Asynchronous parallel streams analogous to rayon
-
tigerbeetle-unofficial-core
Safe low level callback-based async bindings to tigerbeetle client library
-
intercomm
Asynchronous inter-component communication library
-
adventure
your great adventure for the various type of requests
-
multiserver
Rust multithread server samples
-
bader-db
Key-value cache RESP server with support for key expirations
-
future-by-example
Examples of common patterns using Future
-
stellwerksim
Rust SDK for StellwerkSim
-
asynk-strim
Lightweight stream generator library
-
futures-net
The futures-net library
-
parabuild
A parallel build utility for template heavy projects
-
tokio_safe_block_on
ability to execute async code from a sync context, without blocking a tokio core thread or busy looping the cpu
-
irc
usable, async IRC for Rust
-
streamtools
Additional stream combinators
-
cortex-sources
Ready-made source implementations for various data inputs in the Cortex ecosystem
-
oc-wasm-futures
Futures that allow async/await to be used in OC-Wasm for a more ergonomic experience
-
fluke-io-uring-async
An abstraction on top of io-uring
-
thread_runner
executing tasks concurrently
-
ant-libp2p-webtransport-websys
WebTransport for libp2p under WASM environment
-
dmm-api
DMM Web API SDK
-
xdg-portal
implement for xdg-desktop-portal
-
axum-sessions
🥠 Cookie-based sessions for Axum via async-session
-
bevy-async-ecs
Asynchronous interface for Bevy ECS
-
mlua-luau-scheduler
Luau-based async scheduler, using mlua and async-executor
-
lapin-tower-worker
Framework for building AMQP workers with lapin and tower
-
aggligator
Aggregates multiple links (TCP or similar) into one connection having their combined bandwidth and provides resiliency against failure of individual links
-
browser-window
optionally async, optionally threadsafe, electron-like browser toolkit for Rust
-
glib-signal
GObject signal bindings
-
toni
Fast and modular web framework for scalable applications
-
kowalski
A Rust-based agent for interacting with Ollama models
-
interthread
Auto implementation of the Actor Model
-
async_repeat
Retry futures mechanism
-
zookeeper-cache-rust
ZooKeeper client cache
-
ruchei
working with many streams
-
genawaiter2-macro
Convenience macros for generators (genawaiter2)
-
hentai
API wrapper for nhentai.net
-
msft-runtime
Windows async helpers
-
hydrolink
Lavalink client made with tokio independent of the Discord library, used in production by Hydrogen
-
swiftide-indexing
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
bacon-ls
Bacon Language Server
-
join
Macros which provide useful shortcut combinators, combine sync/async chains, support single and multi thread (sync/async) step by step execution of branches, transform tuple of results in result of tuple
-
rados_hi
Opinionated high-level wrapper for librados (Ceph)
-
future-bool
A bool one can await the changes
-
akinator-py
Python bindings for akinator-rs
-
surge-ping
Asynchronous ICMP ping library
-
amqp-lapin-helper
rust lapin helper
-
async_tasks_recorder
A struct for recording execution status of async tasks with async methods
-
rustmark
Extensible web application for serving Markdown-based content
-
deploy-common
Common components for the
deploy
andfabric
crates -
lunatic-distributed
Node to node communication
-
itla
ITLA (micro laser) non-blocking control library using embedded-hal
-
tokio-task-tracker
graceful shutdown solution for tokio
-
rxqlite-sqlx-common
A distributed sqlite database built upon
openraft
,sqlx
andsqlite
-
mousse
A set of encoder and decoder for server sent events
-
tokio-fd
Non-blocking Read and Write a Linux File Descriptor
-
dialectic-compiler
Session type macro compiler for the Dialectic crate
-
async_tasks_state_map
A struct for recording execution status of async tasks with async methods
-
broadcaster
Broadcasting futures mpmc channel
-
sender-sink
classes for working with tokio UnboundedSender and the Sink trait
-
async-tun
Asynchronous allocation of TUN/TAP devices using async-std
-
tokio-into-sink
convert a tokio::io::AsyncWrite into a futures::Sink for bytes
-
serial-io
A serial port implementation
-
dbus-async-derive
Handler trait derive macro for dbus-async
-
scuffle-future-ext
working with futures
-
proxycurl-linkedin-rs
client for the Proxycurl LinkedIn API
-
bleasy
High-level BLE communication library
-
readwrite
Combine Read and Write into a single Read+Write object
-
tokio-resource-pool
A generic resource pool for the Tokio ecosystem
-
woven
set of async combinators, usable in a no_std environment
-
futures-promises
Promises and Watched Variables for Futures
-
limited-join
A zero-dependency crate providing a join future with limited concurrency
-
tokio-icmp-echo
Asynchronous ICMP pinging library
-
waker-set
waker set
-
async-lease
Essentially a futures-oriented Arc<Mutex<Option<T>>>
-
num_stream
that provides a Stream that yields incrementing numbers at a specified interval
-
monoio-io-wrapper
A read/write wrapper to bridge sync and async io
-
futures-ticker
An asynchronous recurring time event
-
rusty-gql
Schema first GraphQL Library for Rust
-
serde-jsonlines
Read & write JSON Lines documents
-
ockam_node
Ockam [Ockam][main-ockam-crate-link] Node and is intended for use by crates that provide features and add-ons to the main [Ockam][main-ockam-crate-link] library. The main [Ockam][main-ockam-crate-link]…
-
axum-serveplus
High level server designed to be used with axum framework
-
coachman
rust asynchronous task manager built on top of tokio framework
-
thread_timer
cancelable timer with no external dependencies
-
dtbh_interface
Interface library for the automated scanner
-
livekit-runtime
Async runtime compatibility layer for LiveKit
-
async_io_utilities
An asynchronous IO utilities crate powered by
tokio
-
tokio-transports
used for communication between processes
-
aggligator-wrapper-tls
Aggligator transport wrapper: TLS
-
enjoin
Powerful syntax-level async join macro
-
stream-reconnect
Stream-wrapping traits/structs that automatically recover from potential disconnections/interruptions
-
act-locally
single-threaded async actors with ordinary functions as handlers and plainly typed messages
-
hitbox-actix
Asynchronous caching framework for Actix
-
actix-ogn
OpenGliderNetwork client based on actix
-
fs
A Futures implementation for File System operations
-
multipart-rfc7578
multipart/form-data (RFC7578)
-
async-actor
actor framework for Rust
-
callback-result
Assists in converting the callback function's method of obtaining results into the await method
-
mini_async_http
Mini async http server based on mio
-
tokio-netstring-trait
A trait for tokios AsyncRead to easily read netstrings from streams
-
futures-sink
The asynchronous
Sink
trait for the futures-rs library -
gpiocdev
Access GPIO lines on Linux using the GPIO character device
-
ocaml-sys
Low-level OCaml bindings for Rust
-
carboncopy
A user (programmer) interface for asynchronous logging in Rust
-
context_manager
Python's like context_managers in Rust
-
connection
A TCP connection that can read and write serializable data
-
edge-nal
Hosts a bunch of traits which are not yet available in the embedded-nal-async crate
-
xio
providing common functionality for file system operations and asynchronous file processing
-
delay
A collection of trait and classes to make your thread wait (and timeout)
-
neo-email
The modern way to build emails services with Rust
-
f189ctrl
Communication library for Fluke 189 digital multimeter
-
ruyi
An event-driven framework for non-blocking, asynchronous I/O in Rust
-
graus-db
A high-performance, thread-safe key-value embedded data store
-
interprocess-docfix
Interprocess communication toolkit. Docs fixed.
-
rtix
Actors with generators. Name up for grabs until I do something with it, or rust supports proper coroutines
-
async_closure
utilizes the nightly-only feature async_fn_in_trait to imitate async_closures
-
xactor
actors framework based on async-std
-
drop-awaiter
that allows you to asynchronously wait for something to be dropped
-
secure-reliable-transport
SRT implementation in Rust
-
tokio-async-write-utility
Some helper functions for types impl AsyncWrite
-
baildon-store
B+Tree CLI
-
lease
Object pool that leases values and automatically returns them with async support
-
deadpool-bolt
A bolt-client manager for the deadpool connection pool
-
ns-env-config
An env_logger-inspired one-stop configuration for name resolution based on abstract-ns. Reduces boilerplate and provides standard way to configure DNS for applications via
RUST_NS
environment variable. -
reqchan
channel for requesting and receiving data. Each channel has only one requesting end, but it can have multiple responding ends. It is useful for implementing work sharing. The two ends…
-
tokio_gen_server
Elixir/Erlang-GenServer-like actor on the Tokio runtime
-
async-raft2
An async implementation of the Raft distributed consensus protocol
-
axum-limit
A rate limiting library using token buckets, centered around extractor-based limits for async web applications
-
fluvio-async-tls
Asynchronous TLS/SSL streams using Rustls
-
axum-core
Core types and traits for axum
-
tokio-mockstream
A fake stream for testing network applications backed by buffers
-
retry-strategy
A better asynchronous retry tool based on Tokio
-
async-graphql-tide
async-graphql for tide
-
edge-raw
Async +
no_std
+ no-alloc implementation of IP and UDP packet creation and parsing -
tarpc-bincode-transport
A bincode-based transport for tarpc services
-
whorl
was created to teach you how async executors work in Rust
-
batchloader
A type-safe async request batcher based on facebook's dataloader
-
vertigo
Reactive Real-DOM library with SSR for Rust
-
lua_actor
Lua Actor for Rust(sync/async)
-
dencode
decoding and encoding frames from readers and writers
-
tokio-anon-pipe
Asynchronous anonymous pipe for Windows
-
futures-rate
easy tools to help Rust applications guide critical resources or code paths from being overwhelmed
-
tokio-zmq
Futures abstractions for ZeroMQ on the Tokio event-loop
-
rust-cli-commands
-
tower-test
writing client and server
Service
tests -
wora
A framework for building applications (daemons, etc) that run in different environments (Linux, Kubernetes, etc)
-
peermerge
Manage JSON-like documents with multiple writers, without a central authority, using a P2P protocol
-
safina-net
Safe async network functions - ARCHIVED: Code moved to
safina
crate -
mqi
Idiomatic IBM® MQ Interface (MQI) and MQ Administration Interface (MQAI) APIs
-
speed-rs-core
A core HTTP handling server library in Rust, providing low-level HTTP server implementation
-
futures-cputask
Turn synchronous CPU-bound tasks into futures
-
plctag-async
async wrapper for libplctag
-
peace_webi_components
Web interface components for the peace automation framework
-
napi_async_local
Extends napi-rs with the ability to run local futures
-
intervalier
Interval events with handling notifications
-
spin_future
Convert synchronous functions into valid but inefficient futures
-
tokio-shared-udp-socket
Easily share a UDP socket between different futures in tokio
-
tls-async
TLS support for AsyncRead/AsyncWrite using native-tls
-
osaka
async for rust without the noise
-
await-group
Golang like WaitGroup implementation
-
act-zero
Ergonomic actor system
-
bbb_api_wrapper
A wrapper for BuiltByBit's Ultimate REST API
-
peace_flow_model
Flow data model for the peace automation framework
-
limitr
offering various rate-limiting algorithms such as Token Bucket, Leaky Bucket, and more
-
local-spawn-pool
Spawn
!Send
futures in a pool and await for all of them to finish. Standalone alternative totokio::task::LocalSet
. -
tourniquet-tonic
Async native round-robin manager for remote services. Tonic integration.
-
viz-handlers
The handlers for Viz
-
observables
Reactivity
-
slings
A small async runtime based on io-uring for Rust
-
completeio
Completion based IO drivers and async runtime
-
aws-smithy-http-server
Server runtime for Smithy Rust Server Framework
-
gneiss-mqtt
Asynchronous and threaded MQTT(5) clients
-
tokio-bincodec
A fork of
tokio-bincode
-
eventbuzz_core
The core submodule of eventbuzz project
-
lsp-codec
Tokio-compatible codec implementation for Language Server Protocol
-
background-jobs-core
Core types for implementing an asynchronous jobs processor
-
aral
Async Runtime Aggregation Layer
-
agnostic-lite
agnostic-lite
is an agnostic abstraction layer for any async runtime -
npm-package
client for fetching metadata from the npm package
-
futures-time
async time combinators
-
swimos_sync
SwimOS Synchronization Channels
-
tracing-layer-slack
Send filtered tracing events to Slack
-
ferris_chats_data
data structures for ferris_chat
-
teloxide-core
Core part of the
teloxide
library - telegram bot API client -
rxqlite-common
A distributed sqlite database built upon
openraft
,sqlx
andsqlite
-
relaxed_channel
Wrapper around async-channel, more performant on heavy pipelines
-
blocksr
Drew's Rust library for (clang/objc) blocks
-
tower-async-bridge
Bridges a
tower-async
Service
to be used within atower
(classic) environment, and also the other way around -
fil_actors_runtime_v9
System actors for the Filecoin protocol
-
completion-io
Core traits and types for asynchronous completion-based I/O
-
cucumber-codegen
Code generation for
cucumber
crate -
lagoinha
package that uses public APIs to fetch addresses using the Brazilian Postal Code (CEP). This package cuncurrenlty calls all the supported APIs and returns the first result.
-
retry_async
retrying, with specific support for the Azure SDK for Rust (cf. https://github.com/Azure/azure-sdk-for-rust).
-
event_handlers
A unified library for handling events
-
safina-async-test
Macro for running async tests - ARCHIVED: Code moved to
safina
crate -
surrealdb-async-graphql-axum
async-graphql for axum
-
tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
minehut
easy to use Rust wrapper for the Minehut API
-
futures-task
Tools for working with tasks
-
wakerpool
lightweight object pool for lists of Wakers
-
swimos_runtime
SwimOS Agent & Downlink Runtime
-
reactive-messaging
Reactive client/server communications, focused on high performance
-
oauth-lib
Asynchronous Rust library to deal with OAuth flows
-
eventually-redis
Event Store implementation using Redis, for Eventually crate
-
safina-select
Safe async select function, for awaiting multiple futures - ARCHIVED: Code moved to
safina
crate -
paggo
A small, fast, and safe in-memory database
-
encrypted-dns
A modern encrypted DNS server (DNSCrypt v2, Anonymized DNSCrypt, DoH)
-
tempest
Realtime message handling framework inspired by Apache Storm and built with Actix
-
selectme
A fast and fair select! macro for asynchronous Rust
-
libsync
containing channels and other synchronisation object implementations
-
gdext_coroutines
Run Rust Async functions and Coroutines in Godot 4.2+ (through GDExtension), inspired on Unity's Coroutines design
-
async-read-length-limit
limit the size of an async read
-
futurify
Convert your sync functions into non-blocking thread futures
-
tokio-extra-macros
Extra proc macros for Tokio
-
futures-jsonrpc
Futures implementation for JSON-RPC
-
ksqldb
A thin wrapper around the KSQL DB REST API to make it more ergonomic to work with
-
task-exec-queue
A asynchronous task execution queue
-
pick_action_from_image
Pick an action from an image
-
elfo-test
Test utils for the elfo system
-
wtransport
WebTransport (over HTTP3) protocol
-
repsheet_etl
ETL tools for repsheet
-
asygnal
[WIP] Async-first signal handling, such as ctrl-c
-
async-pipe
Creates an asynchronous piped reader and writer pair using tokio.rs
-
tokio-lock
Access an object from a single Tokio task
-
serf-core
A decentralized solution for service discovery and orchestration that is lightweight, highly available, and fault tolerant
-
tokio_dual_stack
Dual-stack TCP listener based on tokio
-
rust-runc
consuming the runc binary in your Rust applications
-
tokio-rustls-fork-shadow-tls
Asynchronous TLS streams wrapper for Tokio based on Rustls
-
async-drop-guard
offers hash map and cache data structures where individual entries can be locked
-
ekv
Key-value database for embedded systems, for raw NOR flash, using an LSM-Tree
-
platoon
An experimental mini async runtime
-
smoltimeout
A way to poll a future until it or a timer completes
-
decrypt-cookies
A decrypt browser crate
-
app-queue
In-app persistent queue for asynchronous jobs
-
tripwire
makes futures pre-emptible
-
north-config
North config is a multi source configuration crate designed as part of the North Microservice Framework
-
simplex-chat
API for the SimpleX Chat CLI
-
actix-interop
Use async/await syntax with actix actors
-
reactors
Performance-focused cross-platform asynchronous IO implementation
-
async-compat
Compatibility adapter between tokio and futures
-
rspc
A blazing fast and easy to use TRPC server for Rust
-
iou
io_uring bindings
-
rmp-futures
Async Rust MessagePack and MessagePack-RPC
-
telers
An asynchronous framework for Telegram Bot API written in Rust
-
futures-stable-preview
futures which support internal references
-
async-native-tls-2
Native TLS using futures
-
prk_async_dataflow
An asynchronous dataflow processing library for Rust with SIMD-accelerated JSON parsing and AI agent capabilities
-
zino-axum
Integrations with axum for zino
-
hyper-serve
High level server designed to be used with axum framework
-
async-read-util
A collection of utilities for working with AsyncRead
-
verypoll
Very polling library
-
async-hofs
Various extention traits for providing asynchronous higher-order functions
-
bawawa
Opinionated set of tools to manage and compose process executions
-
nrf24radio
Asynchronous embedded driver for NRF24L01(+) devices
-
kayrx
Framework
-
stick
Platform-agnostic asynchronous gamepad, joystick and flighstick library
-
futures-dnsv2
A futures-based dns client implementation
-
async-component-components
async-component components
-
async_ui_web_html
Async UI for the Browser
-
timedmap
A hash map with expiring key-value pairs
-
async-cron-scheduler
Runtime-agnostic async task scheduler with cron expression support
-
async-gcode
An async gcode parser for no_std targets
-
wrtc
Wrapper around webrtc-rs library, focused on developer experience
-
rust-freely
An asynchronous wrapper for the WriteFreely/Write.as API
-
fred
An async client for Redis and Valkey
-
async-subscription-map
Async bookkeeping datastructure for state subscriptions
-
async-compatibility-layer
an abstraction layer for using both async-std and tokio
-
pin-utils
pinning
-
asyncfd
Send and receive file descriptors over Unix domain sockets while maintaining Tokio AsyncRead and AsyncWrite
-
noblklayer
provide a bare-bones, non-blocking, I/O layer
-
unsend
A thread unsafe runtime for thread unsafe people
-
cdrs-tokio
Async Cassandra DB driver written in Rust
-
agnostic-io
agnostic-io
defines I/O traits in agnostic style for any async runtime -
await_macros
Macros that expand to
(expr).await
-
bme280-rs
query BME280 sensors over I²C
-
soketto
A websocket protocol implementation
-
compio-io
IO traits for completion based async IO
-
riker-patterns
A collection of common actor patterns for Riker
-
serviceless
actor model in rust, like actix
-
mqttc
client for the MQTT protocol
-
euklid
CRDT
-
mqtt-channel-client
MQTT client that communicates over Tokio channels
-
tentacle
Minimal implementation for a multiplexed p2p network framework
-
streamcatcher
A thread-safe, shared (asynchronous), almost-lockless stream buffer
-
miku-server-timing
An axum layer to inject the Server-Timing HTTP header into the response
-
compio-quic
QUIC for compio
-
ntex-files
Static files support for ntex web
-
tokio-jsonrpc
JSON RPC 2.0 for tokio
-
tracing-durations-export
Record and visualize parallelism of tracing spans
-
asyncra
Unblocking async runtime
-
relock
Distributed async locking using Redis
-
tbon
TinyChain Binary Object Notation is a compact and versatile stream-friendly binary serialization format
-
worst-executor
A spin-loop like executor for async
-
futures-dagtask
DAG-based Task Queue
-
hds_console-api
test crate, do not use
-
spmc-logger
A single-producer multi-consumer persistent logger
-
kapacitor-udf
creating Kapacitor User Defined Functions (UDFs)
-
activitystreams-types
Base types from the Activity Streams spec
-
libpool
threadpool from The Rust Programming Language
-
posturn
Build turn-based games with
async
Rust -
event-source
Zero cost async immediate event dispatching
-
tor-rpc-connect
Common implementation logic for Arti RPC Connect points
-
heim-disk
Cross-platform disk information
-
fd-queue
support fd passing on Unix sockets
-
agreed-memstore
An in-memory implementation of the
agreed::RaftStorage
trait. Fork of async-raft’s memstore crate. -
icanhazdadjoke-sdk
An SDK to interact with the icanhazdadjoke Dad Jokes API
-
tokio-utun
Utun bindings for Tokio
-
async-openai-wasm
OpenAI on WASM
-
pcap-async
Async/Stream Extensions for libpcap
-
futures-util-io-peek
AsyncPeek trait
-
tourniquet-celery
Async native round-robin manager for remote services. celery integration.
-
serf-types
Types for the
serf
crate -
volo-macros
Volo's proc macros
-
simple-async-local-executor
A single-threaded polling-based executor suitable for use in games, embedded systems or WASM
-
agreed
Fork of async-raft, the Tokio-based Rust implementation of the Raft protocol
-
rocket-session-store
session library that can use a custom store
-
mio-anonymous-pipes
Asynchronous wrapper for windows synchronous pipes
-
kay
Experimental high-performance actor system framework for Rust
-
limitation-actix-middleware
An Actix web middleware for rate limiting requests using a fixed window counter keyed on a header
-
async-fd-lock
Advisory cross-platform file locks using file descriptors with async support by spawning blocking tasks
-
compio-runtime
High-level runtime for compio
-
tower-fallthrough-filter
A Tower middleware that gives controll to a defined service if the filter matches and otherwise falls through to the inner service
-
tokio-tungstenite
Tokio binding for Tungstenite, the Lightweight stream-based WebSocket implementation
-
async-trait
Type erasure for async trait methods
-
oricalchum
A lightweight actor model
-
jarust_plugins
A janus client SDK in Rust
-
mueue
message queues
-
lazy-queue
Futures-driven lazy queue processing
-
mio-timerfd
mio support for linux's timerfd
-
mediatrix
Strongly typed, extensible event mediator
-
greenthread-future
Convert closures to futures based on greenthread on bare-metal (no_std + no_alloc)
-
minicoro-sys
rust binding to minicoro
-
futures-length-delimited-frame
Frame a stream of bytes based on a length prefix
-
local-pool-with-id
A minor variation on a LocalPool executor which exposes unique IDs for tracking future completion
-
a_chat
a asynchronous chat server
-
ntex-compio
compio runtime intergration for ntex framework
-
rexa
GraphQL MongoDB API builder
-
bluer
official Rust interface to the Linux Bluetooth protocol stack (BlueZ)
-
odem-rs-util
Model elements and statistical tooling for the ODEM-rs simulation framework
-
amqp-manager
Lapin wrapper that encapsulates the use of connections/channels and creation of amqp objects
-
crb-superagent
CRB | Composable Runtime Blocks | Agent Extensions
-
monoio-native-tls
Asynchronous TLS streams wrapper for Monoio based on NativeTLS
-
tokio-task-manager
Allow an async Tokio application to gracefully shutdown, waiting for all tasks to finish
-
mio-utun
Utun bindings for mio
-
basteh-redb
basteh based on redb
-
tower-reqwest
Adapter between reqwest and tower-http crates
-
switch-resume
Delimited async continuations
-
reqwest-retry-after
Retry-After header support for reqwest
-
safina-executor
Safe async runtime executor - ARCHIVED: Code moved to
safina
crate -
embassy-time
Instant and Duration for embedded no-std systems, with async timer support
-
rexecutor-sqlx
A robust job processing library
-
ruw
Read-Update-Write
-
flysystem
A filesystem abstraction layer for Rust
-
side-futures
Send future for execution on the runtime that may be in a different thread
-
roux-stream
A streaming API for the roux Reddit client
-
keclc-file
File support for Eternal
-
actix-raft
Raft distributed consensus protocol using the Actix actor framework
-
task_scheduler
easilty schedule an FnOnce to run in the future
-
async-await
Just some macros to emulate the Async and Await :)
-
async-dup
Duplicate an async I/O handle
-
parallel-future
fluent async task experiments
-
tracing-appender
file appenders and making non-blocking writers
-
again
wasm-compatible retry util for std library futures
-
stream-ext
An extension trait for Streams that provides a variety of convenient combinator functions
-
groq-api-rs
Client For Groq Cloud LLM APIs
-
xo-api-client
Unofficial crate for accessing Xen Orchestra through its API
-
async_object
Async Object wrapper
-
eventastic
opinionated fork of Eventually-rs. It enforces the use of transactions and handles idempotency.
-
EasyDist
A non-blocking IO and easy-to-use Rust crate for constructing simple distributed preject. The crate contains several building blocks that can be use to construct a distributed system program.
-
somen-language
somen parser combinator for languages
-
tokio-tls-gmssl
TLS/SSL streams for Tokio using native-tls giving an implementation of TLS for nonblocking I/O streams
-
usb-disk-probe
stream type which can be used to probe for USB storage devices in the system
-
oneshot-broadcast
channel that broadcasts a value once without cloning it
-
yaaral
async runtime abstraction library
-
online
📶 Library to check your Internet connectivity
-
tokio-websockets
High performance, strict, tokio-util based WebSockets implementation
-
bevy_async_system
ability to wait for game status asynchronously
-
leap_client_rs
Rust client library for the Leap Edge socket service
-
misskey-util
High-level API for the misskey-rs library
-
openraft-rocksstore-compat07
A example v07 compatible implementation of the
openraft::RaftStorage
trait -
mcprotocol-rs
Model Context Protocol (MCP)
-
signals
A functional-reactive-like library for Rust that allows asynchronous chaining
-
nonblocking
stdin crate for Rust
-
heph-inbox
Bounded capacity channel designed to be used as inbox for actors. Also supports one shot channels.
-
spawns-core
Async runtime agnostic thread context task spawner for Rust
-
smol-hyper
Integrations between smol and hyper
-
deduplicate
caching, asynchronous, request deduplication
-
finito
Retry behaviour for futures
-
async-dispatcher
async runtime based on a pluggable dispatcher
-
cdns-rs
A native Sync/Async Rust implementation of client DNS resolver
-
tokio-reactor-trait
reactor-trait implementation for tokio
-
peace_cli_model
Command line interface data types for the peace automation framework
-
async_io_crypto
handling AsyncRead with ciphering / deciphering
-
mega_etl
A cloud-native ETL (Extract, Transform, Load) application framework based on the WasmEdge WebAssembly runtime for developers to filter, map, and transform data pipelines going into cloud databases
-
deadpool-amqprs
Dead simple async pool for amqprs
-
tauri-plugin-rspc
Tauri adapter for rspc
-
tk-easyloop
A thread local loop and other loop helpers
-
futuresdr-types
Polymorphic Types for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
c_mcai_worker_sdk
AMQP Worker to listen and provide trait to process message
-
opentls
TLS connections with OpenSSL
-
heim-process
Cross-platform processes information
-
b_stb
that efficiently converts Hyper response bodies and async streams into strings or bytes
-
future-result
An ideomatic way of mapping a Result to a Future of Result
-
jelastic-rs
Rust wrapper for the Jelastic API
-
throttled-reader
An io::Read proxy that limits calls to read()
-
v_exchanges_api_generics
A client for HTTP/HTTPS/WebSocket APIs
-
catty
Send and await a value asynchronously
-
safina-sync
Safe structs for sharing or sending data between async tasks - ARCHIVED: Code moved to
safina
crate -
aiur
Single threaded async executor with structured concurrency
-
rsdns
DNS Client Library
-
pupactor
actor model library built with tokio
-
futures-delay-queue
Async delay queue backed by async-std and futures-timer
-
underway
⏳ Durable step functions via Postgres
-
ockam_command
End-to-end encryption and mutual authentication for distributed applications
-
grpcio
language implementation of gRPC, base on the gRPC c core library
-
zino-orm
ORM for zino
-
uring-fs
Truly asynchronous file operations using io-uring. Supports any async runtime. Linux only.
-
tokio-lxi
LXI protocol abstractions for Tokio
-
ctrlc2
Easy Ctrl-C handler version 2 for Rust projects
-
context-async
context handle async future timeout or cancel
-
async_dag
An async task scheduling utilitiy
-
async-native-tls-alpn
Native TLS using futures
-
crud_hyper
CRUD (Create, Read, Update, Delete) web application built using Rust’s
hyper
library. This project demonstrates how to implement basic CRUD operations with an in-memory database and… -
ferris_chats_server
This binary provides a server for ferris_chat
-
dioxus-query
Fully-typed, async, reusable cached state management for Dioxus 🧬
-
tokio-context
Contexts for cancelling asynchronous tasks using tokio
-
gritea
Gitea API sdk
-
todc-net
Algorithms for message-passing (HTTP) distributed systems
-
overclock
A framework for building data-driven distributed systems
-
diazene
Actor for Rust (with Tokio)
-
puddle
object pool implementation that uses asynchronous synchronization primitives only
-
paladin-core
distributed algorithm toolkit. Write distributed algorithms without the complexities of distributed systems programming.
-
foxhole-api
wrapper for the Foxhole War API
-
trillium-tokio
tokio runtime adapter for trillium.rs
-
tokio-udp-framed
Based on UdpFramed from tokio-util but with some quality of life modifications to support shared ownership of
UdpSocket
and to split Send/Recv into their own types -
async-stdin
Asynchronously read from stdin
-
tokio-dbus
Pure Rust D-Bus implementation for Tokio
-
librdkafka-sys
Native bindings to the librdkafka library
-
tower-pipeline
A Tower Service combinator that "pipelines" two services
-
anthropic
SDK
-
rexie
futures based wrapper around IndexedDB that compiles to webassembly
-
handy_io
A handy pattern and futures based asynchronous I/O library
-
aster-proxy
A light, fast and powerful cache proxy written in Rust
-
async-http1-lite
Asynchronous http1 stream
-
linux-io-uring
The
io_uring
library for Rust -
felixs-tower-lsp
Language Server Protocol implementation based on Tower
-
zellij-client
The client-side library for Zellij
-
nanopore
A minimalist async runtime based on io_uring (Linux) and I/O rings (Windows)
-
async-nats-tokio-rustls-deps
Fork of Asynchronous TLS/SSL streams for Tokio using Rustls
-
ftools
Functional utilities for Rust
-
strife
A lightweight library for the Discord API
-
mias_channel
that supports bi-directional channels by wrapping others
-
async-pidfd
Process file descriptors (pidfd) for Linux
-
ockam_transport_uds
Unix Domain Socket (UDS) Transport for the Ockam Routing Protocol
-
awaur
Asynchronous Web API Utilities for Rust
-
async-slot
An asynchronous (futures-based) channel that only preserves last value sent
-
elk-mq
A Message Queue implementation in rust, using Redis as a communication medium
-
futures-io-preview
The
AsyncRead
andAsyncWrite
traits for the futures-rs library -
email-lib
Cross-platform, asynchronous Rust library to manage emails
-
tower-worker
Tower layers focused on wrapping services with asynchronous worker tasks that may also make requests to the wrapped service
-
erkpht-tower
Tower is a library of modular and reusable components for building robust clients and servers
-
coerce-k8s
Kubernetes discovery provider, automatically discover cluster peers hosted in Kubernetes, based on a configurable pod-selection label
-
tbot
Make cool Telegram bots with Rust easily
-
edge-dhcp
Async +
no_std
+ no-alloc implementation of the DHCP protocol -
tokio-executor-trait
executor-trait implementation for tokio
-
memphis-rust-community
Memphis Messaging Protocol
-
tower-http-client
Extra Tower middlewares and utilities for HTTP clients
-
attempt
do something over and over and over and over and
-
pangotls
TLS Reverse Proxy using Tokio and Rustls
-
thalo_message_store
Thalo's message store built with sled
-
futures-websocket
A futures-based websocket implementation
-
rotor
The mio-based framework for doing I/O in simple and composable way
-
lunatic-control-axum
TBD
-
fibers_inotify
A futures friendly inotify wrapper for fibers crate
-
asyncio-utils
Support limit,skip on AsyncRead traits
-
async-graphql-warp
async-graphql for warp
-
client-handle
A macro to generate client handles when using multithreaded / asynchronous code
-
awesome-operates
A reposity includs many common use code utils
-
metalmq-client
MetalMQ client library (AMQP 0.9)
-
ex-futures
An extension of
futures
-
cloudwatch_logging
logging to AWS CloudWatch Logs
-
windows-async
async executor for windows application using windows crate
-
mofo
Multiple Ongoing Futures Object - an abstraction for easily managing ongoing child tasks with futures
-
wring
uring runtime
-
chokepoint
Generic stream transformer to simulate traffic / network congestion
-
tang-rs
A light weight asynchronous connection pool
-
tubetti
Serve &[u8] data at a localhost url with minimal configuration
-
futures-utils-lite
futures about utils in lite
-
cargo-daku
Daku API cargo plugin
-
futures-quic
quic protocol backed by Quiche
-
actix-broker
Message broker for the Actix actor framework
-
thetvdb
API async client
-
io_tee
Tee Read, BufRead, and Seek instances to a writer
-
associated-async-io
Async IO traits that use futures instead of poll
-
txrx
take on the C++ unified executors proposal
-
chtsh
Rust CLI for interacting with https://cht.sh
-
futures-stream-reader
Convert an [AsyncRead] into a [Stream] of byte chunks
-
mobc-bolt
A bolt-client manager for the mobc connection pool
-
rust-gpt
interaction with the Completion/Chat OpenAI API
-
noosphere-fs
A high-level, FS-like view over Noosphere content
-
crdts
Practical, serializable, thoroughly tested CRDTs
-
real-async-trait
A proc macro that uses experimental features to work around type erasure for async traits
-
prefect
An embeddable task queue based on SQLite (renamed to effectum)
-
async-shell
Asynchronous process child wait
-
reducer
A predictable reactive framework for Rust apps
-
async-compression
Adaptors between compression crates and Rust's modern asynchronous IO types
-
garcon
A collection of trait and classes to make your thread or async function wait
-
tower-sessions-deadpool-sqlite-store
deadpool-sqlite session store for
tower-sessions
-
libp2p-core
Core traits and structs of libp2p
-
async-i3ipc
Bindings for i3 and async-std allowing async applications to communicate with i3 over it's IPC interface. Contains futures implementations and convenience functions for working with i3.
-
tokio-futures-respawn
function to respawn failed long running tasks
-
signalwire
The unofficial SignalWire SDK for Rust
-
swimos_future
SwimOS Future Utilities
-
rustls-acme
TLS certificate management and serving using rustls
-
cute-async
Cute async utilities
-
fil_actors_runtime_v8
System actors for the Filecoin protocol
-
init_system
Framework to wrap application init
-
aredis
Redis client implemented in Rust
-
papaleguas
ACME client
-
cache-compute
implements request/async computation coalescing
-
google-cloud
Asynchronous Rust bindings for Google Cloud Platform gRPC APIs
-
plumb
A functional, async pipeline framework
-
libuio
A io_uring based async framework designed for high performance networking on linux
-
tokio-stream-multiplexor
Stream Multiplexor for tokio with a tcp like interface
-
fil_actors_runtime_v11
System actors for the Filecoin protocol
-
elfo-utils
Some utils for the elfo system
-
tokio-process-stream
that wraps a tokio::process into a tokio::stream
-
rseip-eip
encapsulation protocol for rseip
-
openssh-mux-client
openssh mux client
-
async_job
async cron job crate for Rust
-
feature-extension-for-wasm-bindgen-futures
Feature extension for wasm-bindgen-futures
-
erl_rpc
Erlang RPC Client
-
async-graphql-viz
async-graphql for viz
-
mezzenger-channel
mezzenger transport over futures channels
-
black-box
A minimal actor framework
-
wasm-agnostic
users who want to write async runtime-agnostic crate for wasm target
-
async-tick
tick clock
-
rtx
zero-cost runtime-abstraction intended for use by Rust libraries to enable the Freedom of Choice between asynchronous runtimes
-
tower-sessions-dynamodb-store
AWS DynamoDB session store. Not for direct use; see the
tower-sessions
crate for details. -
tokio-tasker
Lets you stop and join groups of Tokio tasks
-
rexecutor
A robust job processing library
-
fibers_tasque
A
tasque
extension specialized forfibers
-
mini-tokio
basic asynchronous rust executor
-
catalyzer
HTTP server framework
-
agner-init-ack
An actor toolkit inspired by Erlang/OTP (init-ack)
-
rkyv_codec
Some adaptors to stream rkyv Archives over AsyncRead and AsyncWrite
-
actor-interfaces
I only uploaded this to crates.io because I was having some issues cross compiling with local dependencies. If anyone wants to use the name for something actually useful, DM me on github
-
beul
It executes futures
-
patchable-async-sleep
An async sleep function, patchable to the preferred runtime
-
hollywood
actor framework
-
sendgrid-async
An async-std based client for sending emails with SendGrid
-
futuredsp
A signal processing library for SDR and real-time DSP
-
cloudflare-workers-kv-sdk-rs
Unofficial Cloudflare Workers KV SDK for Rust-Lang
-
futwaiter
The container of Future's that has the ability to complete them all at once
-
skipdb-core
The core for
skipdb
andasync-skipdb
crates -
shutdown-async
Asynchronous Shutdown
-
rlg
that implements application-level logging with a simple, readable output format. Features include log rotation, network logging, and support for multiple structured formats like JSON, CEF, and more.
-
rusher
Pusher compatible pubsub service
-
tierkreis-runtime
Runtime implementation for the tierkreis quantum-classical hybrid workflow orchestration tool
-
async-zmq-types
Types and traits to create a generic interface over asynchronous zmq implementations
-
compio-tls
TLS adaptor with compio
-
axum-messages
🛎️ One-time notification messages for Axum
-
compio-buf
Buffer trait for completion based async IO
-
zephyrus-macros
Procedural macros used by Zephyrus
-
streamline
Reversible futures::Stream-based state machines
-
killswitch
used to broadcast a shutdown request
-
tokio-pty-process-stream
wraps tokio-pty-process in order to provide a simpler API as a single stream object
-
tokio-utils
Tools for asynchronous programming in Tokio applications
-
proxied
Asynchronous client connector for proxies
-
syncthing
controlling syncthing file synchronization through its REST interface
-
awaitable-error
Awaitable type with input and output that can be stored in container
-
tower-util
working with
Service
-
task_yield
Executor-independent task yielding
-
stream-broadcast
Runtime independent broadcast, which only polls it's underlying stream if no pending data is available
-
nakago
A lightweight Rust toolkit for sharp dependency injection 😎
-
BiliupApi
一个封装好的自用库
-
fure
Retrying futures using different policies
-
launchpadlib
accessing Launchpad.net
-
must-done
An experimental Future that is guaranteed to be done
-
juliet
A safe stream multiplexing protocol
-
actman
Async Actor Model Library in Rust
-
tower-async-hyper
Bridges a
tower-async
Service
to be used within ahyper
(1.x) environment -
axum-prometheus
A tower middleware to collect and export HTTP metrics for Axum
-
rt-local
Thread local asynchronous runtime working with platform-specific event loops
-
spotify-rs
wrapper for the Spotify API
-
tabs
A collection of asynchronous task abstractions, based on tokio
-
mio-byte-fifo
Concurrent non-blocking byte SPSC FIFO buffer intended for use in Mio poll
-
pipebuf_rustls
PipeBuf wrapper for Rustls
-
async_main
Runtime-agnostic async main proc macro
-
asteroid-mq-model
Basic models for asteroid-mq
-
eventually
using Event Sourcing in Rust applications
-
awaken
Coalescing cross-thread wakers for mio and io_uring
-
async-pidfd-next
Process file descriptors (pidfd) for Linux
-
proxy-scraper
command-line tool for scraping proxy information
-
async-ops
Use std::ops traits with Futures
-
tower-actor
A
tower
middleware that creates aService
by passing messages to an actor -
axum-jrpc
A JSON-RPC extractor for Axum
-
tower-sessions-sqlx-store-chrono
SQLx session stores for
tower-sessions
but usingchrono
instead oftime
-
openai-api
OpenAI API library for rust
-
tes3mp-plugin
Stubs for creating a TES3MP server plugin
-
edge-captive
Async +
no_std
+ no-alloc implementation of a Captive Portal DNS -
vmc
Virtual Motion Capture protocol for virtual avatar tracking
-
async-option
Essentially an asynchronous Async<Mutex<Option<T>>>
-
split-stream-by
Stream extension crate for splitting a Stream into two per a predicate
-
async-entry
extended Tokio's proc macros
-
aws-smithy-async
Async runtime agnostic abstractions for smithy-rs
-
path-tree
lightweight high performance HTTP request router for Rust
-
murray
A minimal actor definition macro using Tokio
-
kyansel
Cancellable future. Provide a future as argument and the current future will cancel if the provided future resolves first
-
tacacs-plus
An asynchronous, runtime-independent RFC8907 TACACS+ client
-
async-throttle
Asynchronous Rate Limiting
-
async-core
A standard for async runtimes
-
async-graphql-relay
Relay support for async-graphql
-
luarmor
API wrapper for luarmor.net
-
axum-htmx
A set of htmx extractors, responders, and request guards for axum
-
derive-tokio-io
Derive AsyncRead and AsyncWrite
-
multipart-rs
zero-allocation, streaming, async multipart reader & writer for Rust
-
futures-finally
that executes a future after the completion of a future or stream regardless of the value or outcome
-
request-channel
Async MPSC request-reponse channel
-
xml-macro
A convenience macro for quick-xml
-
acu
building asynchronous actors
-
stalk
sending serialized data with tokio
-
hyper-futures
Compatibility layer for futures to use AsyncRead and AsyncWrite traits with hyper
-
arta
Async runtime abstractions library
-
openai_responses
Rust SDK for the OpenAI Responses API
-
imgur2018
An Imgur upload client for async Rust
-
connpass-rs
An api client for connpass.com
-
gneiss-mqtt-aws
AWS IoT Core specific builders for asynchronous and threaded MQTT clients
-
diny
An asynchronous, alloc-free serialization framework
-
rustygear
Client library for communicating via the gearman protocol
-
crb-runtime
CRB | Composable Runtime Blocks | Runtime
-
juniper
GraphQL server library
-
async-graphql-extension-apollo-tracing
An async_graphql extension to send traces & metrics to Apollo Studio
-
minimal-executor
A minimal executor for asynchronous tasks based on the futures-rs library
-
o5m-stream
streaming async o5m decoder
-
forceps
async & on-disk database
-
abs_art
ABStraction of Asynchronous RunTime
-
zipit
Create and stream zip archives on the fly
-
scoped_spawn
Full structured concurrency for asynchronous programming
-
bookkeeper-client
Async rust client for Apache BookKeeper
-
navactor
A cli tool for creating and updating actors from piped input
-
logimesh-macro
Proc macros for logimesh
-
reqwest-streams
HTTP body streaming support for reqwest: JSON/CSV/Protobuf and others
-
supplicant
Bindings for wpa_supplicant
-
future-union
Use future::Either with
impl Future
-
futures-stream-ext
Asynchronous stream extensions for the futures(-core) crate
-
rcopy
A fast file and directory transfer tool powered by Tokio, RKYV, and io_uring
-
epicenter
synchronous and asynchronous event dispatcher for Rust
-
mold2d
platformer game library in Rust
-
postgres_rustls
TLS support for tokio-postgres via tokio-rustls
-
rip-starttls
Sans I/O implementation of https://duesee.dev/p/avoid-implementing-starttls/
-
async-rx
functions for async reactive programming
-
fetchy
Async HTTPS fetch API built on pasts
-
nb-executor
Single-future, #![no_std] executor based on event bitmasks
-
jarust_rt
A janus client SDK in Rust
-
gwyh
sweet gossip library
-
task-stream
a global task executor, run in
no_std
-
bb8_surrealdb2
Surrealdb support for the async bb8 connection pool
-
tower-amqp
Framework for building AMQP workers with tower
-
try_future
Convenient short-hand for returning early from
futures
-based functions -
anthropic-sdk
Anthropic Rust SDK
-
tasktrace
Logical 'backtraces' of async tasks
-
lnd_grpc_rust
An async library implementing LND RPC via tonic_openssl and prost
-
egg-mode-extras
Rate-limited streams and other helpers for egg-mode
-
async-ioutil
A collection of Rust asynchronous I/O utilities
-
memstore
An in-memory implementation of the
async-raft::RaftStorage
trait -
unix-udp-sock
async & sync UDP sockets supporting sendmsg/recvmsg and src IP manipulation
-
kvarn-quinn
Temporary Kvarn fork: Versatile QUIC transport protocol implementation
-
tokio-macros
Tokio's proc macros
-
rtbase
async runtime base code
-
batch
Distributed task queue library based on RabbitMQ
-
casus
containing a handful of event-based async primitives
-
futures-shuttle
Futures-aware shuttle synchronization object
-
posixmq
An idiomatic library for using posix message queues, with optional mio integration
-
hyper-http-proxy
A proxy connector for Hyper-based applications
-
arti-bench
benchmarking utility for Arti
-
mirai-ws
mirai-http-api rust interface, based on tungstenite
-
protwrap
Thin protocol wrapper for network applications
-
yaar
asynchronous runtime optimized around configuration and no_std
-
tokio-shared-rt
Allow
#[tokio::test]
to use a shared runtime -
peachy
async task manager, similar to thread pool but cooler and for structs
-
xitca-unsafe-collection
unsafe keyword enabled utilities for xitca
-
tarpc
An RPC framework for Rust with a focus on ease of use
-
heim-virt
Cross-platform virtualization system detection
-
bililive
stream-based bilibili live client library
-
async_counter
Counter that implements a future to await on specific value
-
aggligator-monitor
Aggligator link monitor and speed test
-
in-keys
utilizing streams in a convenient
Terminal
construct -
pin-macros
primarly used to simplify the proccess of working with self-referencial structures
-
toni-macros
Macros for Toni
-
yield-now
Wakes current task and returns Poll::Pending once
-
gj
Event loop and promises
-
fork_stream
Clone any stream
S
where<S as Stream>::Item: Clone
-
sc2
StarCraft II Client API
-
fetch-js
A fetch API implementation in Rust
-
rspc-tauri
Tauri adapter for rspc
-
async-trait-ext
a procedural macro for async traits
-
embedded-hal
A Hardware Abstraction Layer (HAL) for embedded systems
-
remcached
Caching system designed for efficient storage and retrieval of entities from remote repositories (REST APIs, Database, ...etc)
-
axiom
Implements a highly-scalable and ergonomic actor system for Rust based on the best of Erlang / Elixir and Akka
-
wombo
managing event loop threads
-
celery-rs-core
Core utilities for a celery client and worker in rust
-
holidayapi_rust
A HolidayAPI library for Rust
-
futuristic
Extensions to the futures crate
-
async-stream-packed
Asynchronous stream packed
-
sigfinn
Lifecycle manager for spawning tasks
-
mobc-forked
A generic connection pool with async/await support
-
lib3h_zombie_actor
lib3h actor request tracking module
-
buffer-unordered-weighted
Stream::buffer_unordered where each future can have a different weight
-
tokio-rustls-wasi
Asynchronous TLS/SSL streams for Tokio using Rustls
-
remote_config
Flexible crate for asynchronously loading configuration from remote source with caching and automatic revalidation
-
signalr-client
calling SignalR hubs from a Rust cross-platform application, supporting WASM and non WASM targets
-
some_local_executor
local executor
-
mediator
pattern in Rust
-
hyper-proxy
A proxy connector for Hyper-based applications
-
tracing-forest
Preserving contextual coherence among trace data from concurrent tasks
-
actix-codec
Codec utilities for working with framed protocols
-
json-rpc2
robust and pragmatic JSON-RPC 2.0 implementation
-
its_ok_to_be_block_on
A minimal implementation of block_on, to execute futures in a syncronous context
-
async-http-client-lite
Asynchronous http client
-
netapp
A toolkit library for distributed software
-
sockit
A UDP socket that can read and write serializable data
-
async-result
wrapper providing a convenient way to await a result, built on futures-channel's oneshot channel
-
stream-operators
a collection of selected rxjs operators for rust standard Stream
-
actix-server
General purpose TCP server built for the Actix ecosystem
-
clia-ntex-files
Static files support for ntex web
-
form-data
AsyncRead/AsyncWrite/Stream
multipart/form-data
-
tokio-blocking
A thin wrapper to provide a simple interface to insert blocking operations between non-blocking operations in the context of futures
-
mlua_actor
Lua Actor for Rust(sync/async)
-
x-bow
Precise State Management Library
-
async-mq
Zero-cost async-await abstraction of lapin AMQP client crate
-
async_ui_web
Async UI for the Browser
-
cooper
in-process, async Actor library for Rust
-
async-middleware
async monad(ish) middleware in Rust using tuples and async trait transforms
-
bevy_async_task
Ergonomic abstractions to async programming in Bevy
-
deadpool
Dead simple async pool
-
lrcall
procedure call framework that is compatible with local and remote procedure calls
-
pullcaps
An asynchronous client for the PushShift API
-
peace_webi_rt
Web interface runtime data types for the peace automation framework
-
relay
A lightweight oneshot Future channel
-
zino-actix
Integrations with actix-web for zino
-
emitter_runtime
Runtime support for rs-event-emitter
-
termcandy
terminal GUI library
-
progenitor-client
An OpenAPI client generator - client support
-
eternal
Framework
-
peace_rt_model
Runtime data types for the peace automation framework
-
chikatetsu
An(other) actor framework for Tokio
-
absinthe
Are you an Actor & Async junkie? Then your app needs some Absinthe!
-
intersession-layer-messaging
A metastable messenger that allows reliability between peers when peers go offline, are unreliable, and facing intermittent network conditions between sessions
-
swimos_trigger
SwimOS Asynchronous Trigger
-
async-utils
nothing to see here yet :)
-
cancellable
providing a generic cancellable utility
-
tokio-iocp
IOCP support for the Tokio asynchronous runtime
-
salvia
Incremental computing brought to async Rust
-
rasi-default
a reference implementation of RASI syscalls
-
tower-batch
batch-tower
is a Tower middleware that allows you to buffer requests for batch processing until the buffer reaches a maximum size OR a maximum duration elapses -
async-gitlib
Asynchronous library with libgit2 artifacts
-
af-core
A core library and async runtime for Rust applications
-
epoxy_frp
The Reactive Glue for Frontend Applications
-
compio-signal
Signal handling for compio
-
iroh-quinn
Versatile QUIC transport protocol implementation
-
rqlite-ha421
An async implementation of a rqlite client
-
tokio-bitstream-io
Tokio port of bitstream-io: Library for reading/writing un-aligned values from/to streams in big-endian and little-endian formats
-
hala-io
hala asynchronous io programming primitive types
-
netty-rs
allows exposes a simple-to-use API used to create stateful application level network protocols as both a client or server
-
linux-io-uring-sys
The
io_uring
bindings for Rust -
futuresdr-pmt
Polymorphic Types for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
mioqu
queuing and processing background tasks
-
madsim-macros
Madsim's proc-macro
-
thalo_runtime
A high-performance event sourcing runtime utilizing WebAssembly an embedded event store
-
ringbuf-rs
in-memory ringbuf implementation
-
amqprs
AMQP 0-9-1 client implementation for RabbitMQ
-
gain-lep
Support for exposing Gain APIs via Lep
-
swimos_utilities
SwimOS Time Utilities
-
fibers_transport
Transport layer abstraction built on top of [
fibers
] crate -
quinn
Versatile QUIC transport protocol implementation
-
fizyr-rpc
Native Rust implementation of the Fizyr RPC protocol
-
pipebuf_mio
PipeBuf support for
mio
byte-streams -
compio-dispatcher
Multithreading dispatcher for compio
-
feature-extension-for-smol
Feature extension for smol
-
ant-libp2p-mdns
libp2p mDNS discovery method
-
serf
A decentralized solution for service discovery and orchestration that is lightweight, highly available, and fault tolerant
-
axum-macros
Macros for axum
-
async-trait-sync
Fork of async-trait with support to Sync future
-
pingora-cache
HTTP caching APIs for Pingora proxy
-
async-watch
Async watch channel
-
keclc-httpauth
HttpAuth support for Kayrx web
-
async-graphql-derive
Macros for async-graphql
-
iroh-quinn-udp
UDP sockets with ECN information for the QUIC transport protocol
-
redeez
queueing system for Redis
-
async-global-executor-trait
executor-trait implementation for async-global-executor
-
etcd-rs
etcd client for rust
-
mlg
An asynchronous Log for Rust
-
kayrx-ui
Framework
-
async-llm
OpenAI-compatible APIs
-
jackrabbit
Real-time Message Queue
-
async-transport
Asynchronous transports with ECN information
-
basteh
Generic kv storage with replaceable backend
-
twilight-http
Discord REST API client for the Twilight ecosystem
-
anansi-aux
Anansi's auxiliary library
-
tokio-stream_wasi
work with
Stream
andtokio
-
message_worker
Message Worker is a low-ish level library for Rust for the creation of event-listeners using futures and streams. Notably MW supports non-sync and non-send (i.e. non-thread-safe) contexts within listeners.
-
photonio-base
The base of PhotonIO
-
thespis
The interface of the thespis actor model (contains only traits)
-
jsonrpc-rs
Futures base jsonrpc server/client framework
-
multitask
An executor for running async tasks
-
bongonet-boringssl
BoringSSL async APIs for Bongonet
-
comet-eventbus
strong-typed sync and asynchronous eventbus
-
v_rusty_tarantool
Tarantul async client based on tokio framework
-
openai-api-fork
OpenAI API library for rust
-
flo-state
Lightweight actor library
-
uasync
fast, safe, async executor
-
qcow2-rs
read/write qcow2 image in async/await
-
trovo
A trovo.live api & chat client written in and for rust
-
jarust_interface
A janus client SDK in Rust
-
httpbin
reimplementation in rust. Works as a library and as a standalone webserver binary. (not affiliated to the original httpbin)
-
tower-limit
Limit maximum request rate to a
Service
-
elfo-telemeter
Collects and exposes metrics of the elfo system
-
smol-macros
Macros for setting up a smol runtime
-
async-http-body
Agit init HttpBody Support Async Expressions
-
hydro
cooperative green tasks
-
asyncs-sync
Asynchronous runtime agnostic synchronization utilities
-
tracing-actix-web2
Rust tracing adapter for Actix Web
-
gm-quic
An IETF quic transport protocol implemented natively using async Rust
-
noop-waker
A waker that does nothing
-
waitfor
Retry a function until it succeeds, errors out, or a timeout/deadline is reached
-
async-graphql-axum-wasi
async-graphql for axum
-
lutetium
tokio based simple actor library
-
tokio-eventfd
Linux eventfd for tokio
-
actix-signal
Manage the lifecycle of an actix actor with its address
-
libp2p-pnet
Private swarm support for libp2p
-
spaad
Zero boilerplate actor systems with xtra
-
forked-tarpc
An RPC framework for Rust with a focus on ease of use
-
rxqlite-notification
A distributed sqlite database built upon
openraft
,sqlx
andsqlite
-
mio-aio
POSIX AIO bindings for mio
-
async-ucx
Asynchronous Rust bindings to UCX
-
ratchet_rs
Async WebSocket implementation
-
pulz-executor
Abstractions of some async runtimes
-
tokio-dbus-macros
Pure Rust D-Bus implementation for Tokio
-
tower-sesh-core
Core components for
tower-sesh
and related crates -
remem
Thread-safe object reuse
-
vesper-macros
Procedural macros used by Zephyrus
-
volo-thrift
Thrift RPC framework implementation of volo
-
idb-sys
A callback based crate for interacting with IndexedDB on browsers using webassembly
-
async-stream-lite
Proc macro-free async/await Rust streams
-
heim-net
Cross-platform network information
-
webdavc
async webdav client. fork from rustydav https://docs.rs/rustydav
-
odem-rs-sync
Model-time synchronization facilities of the ODEM-rs simulation framework
-
tokio-test-shutdown-timeout
Tokio test attribute with a shutdown timeout
-
mailbox_processor
A small little actor abstraction inspired by the FSharp Mailbox Processor which in turn was inspired by erlang
-
aldrin
Message bus for service-oriented RPC and interprocess communication
-
sendblue
that provides an API client for interacting with the SendBlue REST API, enabling businesses to integrate iMessage and SMS services into their applications
-
kcp-rs
KCP Stream Protocol
-
tractor
Actor system modelled after Pony's actors
-
smartpoll
A 'Task' abstraction that simplifies polling futures
-
tokio-channel
Channels for asynchronous communication using Tokio
-
kvarn-tokio-uring
Temporary Kvarn fork: io-uring support for the Tokio asynchronous runtime
-
causality
Event Driven Architecture Traits
-
futures-enum
#[derive(Future, Stream, Sink, AsyncRead, AsyncWrite, AsyncSeek, AsyncBufRead)] for enums
-
veilid-async-tls
Asynchronous TLS/SSL streams using Rustls
-
tower-buffer
Buffer requests before dispatching to a
Service
-
photonio
A runtime for asynchronous applications
-
suspend
A common mechanism for suspending a thread or a Future until notified
-
abstract-ns
Abstract name service traits for use with futures (and tokio)
-
tower-sessions-surrealdb-store
SurrealDB session store. Not for direct use; see the
tower-sessions
crate for details. -
asteroid-mq-sdk
Rust SDK for asteroid-mq
-
d3
A framework for server development
-
manual_future
A future that must be manually completed, similar to Java's CompletableFuture
-
pingora-boringssl
BoringSSL async APIs for Pingora
-
postel
High level server for hyper and tower
-
pptr
Type-Driven Asynchronous Actor Runtime
-
lspower
A lightweight framework for implementing LSP servers
-
crb-morph
CRB | Composable Runtime Blocks | Morph
-
cold-io
Event driven network io
-
async-attributes
Experimental language-level polyfills for Async Rust
-
requiem-service
Actix service
-
libp2p-upnp
UPnP support for libp2p transports
-
orengine-macros
Procedural macros for use with Orengine
-
leaves
Distributed ID Allocator
-
generic-api-client
A client for HTTP/HTTPS/WebSocket APIs
-
axum-session-manager
Session manager crate for Rust web framework 'Axum'
-
rustis
Redis async driver for Rust
-
tokio-compat-02
Tokio 0.2 compat utilities
-
openssh-sftp-error
Error type used when communicating with openssh sftp server
-
tokio-tls-api
TLS/SSL streams for Tokio giving an implementation of TLS for nonblocking I/O streams
-
tinywake
A minimal, no_std-compatible waker implementation for Cortex-M async executors
-
parity-runtime
Tokio runtime wrapper
-
mysql_async
Tokio based asynchronous MySql client library
-
xtor
Async Actor framework for Rust which is blazing fast and rock solid
-
aio_event
A tokio event like asyncio event in python
-
actors-rs
Easily build fast, highly concurrent and resilient applications. An Actor Framework for Rust.
-
fsdr-blocks
Building blocks for FutureSDR signal processing library for SDR and real-time DSP
-
makiko
Asynchronous SSH client library in pure Rust
-
nostd_async
An asyncronous runtime for a single-threaded no_std environment
-
forky-udpflow
Stream API for tokio-udp
-
requiem
Actor framework for Rust
-
manual-executor
Async executor with manual waking
-
folo
Runtime engine for Rust services
-
futures-test-sink
Test utilities for futures::sink
-
linkd
actor model framework that takes inspiration from OTP in the erlang ecosystem
-
rivulet
Asynchronous contiguous-memory streams
-
compio-process
Processes for compio
-
monolake
High Performance Proxy base on Monoio
-
async-reactor-trait
reactor-trait implementation for async-io
-
indexed-db
Bindings to IndexedDB that default the transactions to aborting and can work multi-threaded
-
rseip-core
core module for rseip
-
tower-async-test
writing client and server
Service
tests. An “Async Trait” spiritual fork from the original tower-test Library -
param
Param-style trait
-
dmds-tokio-fs
Dmds I/O handler interacts with the filesystem using Tokio
-
fut-compat
Offers compatibility between the tokio and async_std runtimes
-
actix-service
Service trait and combinators for representing asynchronous request/response operations
-
wasm_main_executor
Run futures from web workers on the main browser thread
-
zino-http
HTTP requests and responses for zino
-
aspartam
Minimalistic actor framework based on tokio, inspired by actix
-
winit-runtime
Async winit runtime
-
tunein
client to fetch radio stations from TuneIn
-
waitlist
Keep track of an ordered list of Wakers to wake
-
rillrate-system
RillRate agent for system monitoring
-
cs-utils
Common utilities
-
asynchronous
Promises Q style , async and event loops
-
uring
Pure Rust library for io_uring
-
completeq-rs
An alternative to passing messages between asynchronous tasks
-
duplexify
Combine a reader + writer into a duplex of Read + Write
-
socksv5_future
Socks v5 futures for Server and Client
-
riker-cqrs
Command Query Responsibility Separation for Riker applications
-
workflow-async-trait
Type erasure for async trait methods (customized, see README.md notes)
-
async-mesos
An asynchronous client for Mesos HTTP scheduler API
-
async-gen
Async generator in stable rust using async/await
-
async-recorder
Store records without waiting for your persistence backend
-
silx-types
aSynchronous Interactive calcuLation eXecutor: an easy to use executor for asynchronous and interacting processes
-
jenner
Tools for working with generators to work with both iterators and streams
-
waker-waiter
async runtimes interoperate with arbitrary futures
-
async-dashscope
client for DashScope API
-
barrage
An async broadcast channel
-
tokio-rustls-acme
Automatic TLS certificate management using rustls
-
rio_rt
A minimal async runtime with an experimental ambition to be an portable and interoperable async runtime for Rust
-
tokio-scoped
Scoped Runtime for tokio
-
netsim
Run tests in network-isolated threads. Intercept and meddle with their packets.
-
swimos_byte_channel
SwimOS Byte Channel
-
bytes-stream
functions to work with stream of bytes
-
atticus
A mimimal API to create asynchronous actors
-
async_buf_reader_utils
Adds additional functionality to the async-std crate for BufReader
-
liburing
Rust liburing#24bd087 raw bindings with basic tests
-
future_pubsub
A tokio based publish-subscibe channel
-
marzban_api
async client which abstracts/simplifies the interactions with the Marzban panel API (https://github.com/Gozargah/Marzban)
-
motore-macros
Motore's proc macros
-
zino-auth
Authentication and authorization for zino
-
qbase
Core structure of the QUIC protocol, a part of gm-quic
-
hyper-proxy2
A proxy connector for Hyper-based applications
-
signalr_rs
SignalR client based on actix web client and async await
-
rust-stream-ext-concurrent
Concurrent behavior extensions for any futures::stream::Stream objects
-
viz-test
The core traits and types in for Viz
-
process-stream
Thin wrapper around [
tokio::process
] to make it streamable -
heim-runtime
Runtime shims for heim crate
-
asynciter
Asynchronous iterator
-
rasi-syscall
The low level syscall interface for RASI system
-
wasmflow-packet
encapsulating the message packets sent across Wasmflow components
-
elfo-dumper
Dumps messages of the elfo system on disk
-
tower-sessions-moka-store
Moka session store for
tower-sessions
-
rama-http
rama http layers, services and other utilities
-
boomerang_builder
The Reactor assembly API for Boomerang
-
photonio-tokio
A PhotonIO implementation based on Tokio
-
madsim-tonic-build
Codegen module of
madsim-tonic
simulation implementation -
situwaition
Run a closure continuously, until is succeeds or times out
-
ockam_transport_websocket
WebSocket Transport for the Ockam Routing Protocol
-
rustdtp
Cross-platform networking interfaces for Rust
-
tokio01-test
Testing utilities for Tokio and futures-based code
-
tinyio
A tiny Rust concurrency runtime library
-
async_channel_io
AsyncRead
andAsyncWrite
implementations forasync_channel
-
tokio-childstream
Convert a tokio::process::Child into a Stream for stdout, stderr, and exit events
-
peace_webi
Web interface for the peace automation framework
-
nature
development support platform, it separates data definition from code, so it decouple the data from business system
-
simple-async
Very simple async runtime for Rust
-
peace_rt
Runtime logic for the peace automation library
-
cynthia
A high performance asynchronous programming runtime for Rust
-
agilulf_protocol
Agilulf Protocol serializer and deserializer
-
rama-udp
UDP support for rama
-
simple-actor
Helper to write actor-based async code
-
iroh-quinn-proto
State machine for the QUIC transport protocol
-
rdbc-rs
Futures base Rust DataBase Connectivity (RDBC) library
-
backstage
A framework for building data-driven distributed systems
-
async-imap-lite
Asynchronous imap
-
aral-runtime-tokio
Aral Runtime for tokio
-
shuller
Lib to get links to images for your favourite tags on rule34 and any
-
rust_transit
A broker-agnostic asynchronous event library
-
futures-mpsc
A futures aware, bounded, MPSC channel with back pressure support
-
enstream
Conversion from Future to Stream
-
tokio-global
Global tokio runtime
-
bongonet-rustls
RusTLS async APIs for Bongonet
-
async-std-test
Alternate implementation of the #[async_std::test] macro
-
tokio-eld
Histogram-based sampler for recording and analyzing event loop delays
-
asyncore
-
tor-events
A typed event broadcasting framework for Arti
-
volo-grpc
gRPC framework implementation of volo
-
wampire
A asynchronous WAMPv2 client and router implenting the basic WAMP profile
-
ara
Async random access I/O traits
-
tower-balance
Balance load across a set of uniform services
-
qcongestion
Congestion control in QUIC, a part of gm-quic
-
peace_item_tar_x
Manages extracting a tar file for the peace framework
-
elfo-network
Distributed actors for elfo
-
solaredge
API client
-
dstream
DelayedStream - delays items and drops same items coming within given interval
-
pagetop
Un entorno de desarrollo para crear soluciones web modulares, extensibles y configurables
-
stream-kmerge
K-way merge for streams
-
swiftide-core
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
async-timer
Timers for Rust async story
-
simple-tokio-watchdog
Pretty simple but bulletproof watchdog actor
-
vkteams-bot
VK Teams Bot API client
-
twilight-lavalink
Lavalink client for the Twilight ecosystem
-
ockam_executor
Ockam async executor crate
-
sync_stream
Aggregate multiple streams by polling stream items in order, keeping the consumption of multiple streams in sync
-
futures-option
Extension traits for dealing with optional futures and streams
-
edge-mdns
Async +
no_std
+ no-alloc implementation of an mDNS responder -
stream-map-any
Allows merging async Streams of different output type
-
madsim-etcd-client
The etcd simulator on madsim
-
socketioxide
Socket IO server implementation in rust as a Tower Service
-
tower-sessions-file-store
Store sessions for Tower Session store on the file system
-
anansi
full-stack web framework for Rust
-
implicit-await
Implicitly await calls returning Future impls
-
axum-typed-websockets
axum::extract::ws with type safe messages
-
psbus
Generic Publish / Subscribe model for application messaging
-
direct-executor
An executor that directly executes futures, suitable for embedded environments
-
tcp-stream
std::net::TcpStream on steroids
-
async-priority-queue
An async-aware priority queue
-
cqrs-core
Core types and traits for cqrs
-
async-openai-types
OpenAI
-
gen-z
Macro-free stream construction through asynchronous generators via an awaitable sender
-
sinais
signal event library
-
wasmbus-rpc
Runtime library for actors and capability providers
-
lelet
golang like task executor
-
ant-libp2p-swarm
The libp2p swarm
-
async-graphql
A GraphQL server library implemented in Rust
-
crb-routine
CRB | Composable Runtime Blocks | Routine
-
see-you-later
Delay and schedule async task
-
bevy-tokio-tasks
integration of a Tokio runtime into a Bevy app for background processing
-
feature-extension-for-async-std
Feature extension for async-std
-
tokio-udev
Non-blocking/Asynchronous Tokio support for udev device events
-
threaded_logger
An asynchronous logger wrapper
-
peace_fmt
Presentation and formatting support for the peace automation framework
-
streams
A collection of stream-extensions that are missing in the
futures
crate -
viz-core
The core traits and types in for Viz
-
continue
Swift-style continuation API
-
tokio-rev-lines
async stream for reading files or any
BufReader
line by line with buffering in reverse -
tokio-buf
Asynchronous stream of byte buffers
-
msgtrans
Support for a variety of communication protocols such as TCP / QUIC / WebSocket, easy to create server and client network library
-
async-executor-trait
executor-trait implementation for async-std
-
ratchet_fixture
Ratchet fixture
-
async_dataloader
Powerful tool for avoiding N+1 queries using async/await, based on the DataLoader pattern
-
what-the-async
runtime
-
juggle
Async task switching for cooperative multitasking in single thread environments with no_std support
-
catalyzer-utils
development easier
-
st7735-async-low
Low-level async library for 4-wire serial ST7735
-
zino-ntex
Integrations with ntex for zino
-
netbeam
a pure-rust asynchronous network synchronization crate (using tokio) that recreates familiar asynchronous paradigms but in a network context
-
prodash
A dashboard for visualizing progress of asynchronous and possibly blocking tasks
-
zino-channel
Cloud events and subscriptions for zino
-
socks5-impl
Fundamental abstractions and async read / write functions for SOCKS5 protocol and Relatively low-level asynchronized SOCKS5 server implementation based on tokio
-
aral-runtime-noop
Aral Runtime for noop
-
tokio-metrics-collector
collecting Prometheus-compatible metrics from Tokio runtime and tasks
-
openssh-sftp-protocol
Data format used to communicate with openssh mux server
-
scambio
Safe and efficient value exchanges between endpoint pairs
-
tower-timeout
Apply a timeout to requests, ensuring completion within a fixed time duration
-
libp2p-relay
Communications relaying for libp2p
-
memberlist-proto
Proto types and traits for the memberlist crate
-
pollster-macro
Proc-macro crate for pollster
-
backoff-tower
A tower layer to apply a backoff strategy to retried requests
-
async-ready
Async readiness traits
-
voyager
Web crawler and scraper
-
tonic-health
Health Checking module of
tonic
gRPC implementation -
jstream-ext
adds some extra extensions to futures Stream traits
-
geese_executor
Asynchronous executor with Geese event system integration
-
entangled
fork-join task executor
-
runtime-loop
Runtime loop for Rust
-
openssh-sftp-protocol-error
Data format used to communicate with openssh mux server
-
cyper
HTTP client library based on compio and hyper
-
async-graphql-parser
GraphQL query parser for async-graphql
-
tonic-reflection
Server Reflection module of
tonic
gRPC implementation -
tarpc-plugins
Proc macros for tarpc
-
rupnp
An asynchronous library for finding UPnP control points, performing actions on them and reading their service descriptions
-
tower-load
Strategies for measuring the load of a service
-
one-file-raft
Raft consensus in 300 LOC
-
signalfut
A future similar to tokio::signal::unix::Signal, but can be used with all the runtimes
-
htmxtools
A lightweight Rust crate for working with HTMX headers, specifically designed to integrate seamlessly with axum
-
starpu-sys
Low-level bindings to the StarPU runtime
-
peace_item_file_download
Manages downloading a file for the peace framework
-
misskey-core
Core traits and types in misskey-rs
-
actix-ws-ng
WebSockets for Actix Web, without actors
-
openraft-macros
Advanced Raft consensus
-
monoio-rustls-fork-shadow-tls
Asynchronous TLS streams wrapper for Monoio based on Rustls
-
hydra-macros
Macros for the hydra framework
-
ratchet_core
Async WebSocket implementation
-
diath
light-weight library for communication between tokio async tasks
-
tower-retry
Retry failed requests
-
futuresdr-frontend
Web Frontend for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
plctag
wrapper of libplctag, with rust style APIs and useful extensions
-
armature
An event-driven stateful actor framework for Rust
-
gen-stream
Generator-based streams for Rust and futures 0.3
-
ssdp-client
An asynchronous library for discovering, notifying and subscribing to devices and services on a network
-
taskio
Abstractions for non-blocking tasks and IO
-
rama-haproxy
rama HaProxy support
-
stream-future
Implement an async iterator with return value
-
futures-to-stream
Turn heterogeneous Futures of same associated Output type to a stream
-
toy-rpc-ha421
An async RPC that mimics golang net/rpc's usage and supports both async-std and tokio
-
async-macros
Macros for async-std
-
async-spawner
executor independent task spawner
-
extern_executor
Async executor which delegates futures polling to external event-loop
-
tokio-task-queue
Execute futures from a stream of futures in order in a Tokio task
-
async-watch2
Async watch channel
-
async-thread
Futures version of std::thread
-
smol-timeout2
A way to poll a future until it or a timer completes
-
async_event_streams
Asynchronous Events Pub/Sub Library
-
vino-packet
encapsulating the message packets sent across Vino components
-
and-then-concurrent
Concurrent and-then combinator for Rust streams
-
peace_value_traits
Trait bounds for value types for the Peace framework
-
xtra-addons
Add-on functionality (Broker, Registry) for crate xtra
-
openssh-sftp-client
Highlevel API used to communicate with openssh sftp server
-
wasmflow-streams
encapsulating the message packets sent across Wasmflow components
-
edge-mqtt
Implements the embedded-svc MQTT traits on top of the rumqttc crate
-
just-watch
Async watch channel
-
aldrin-gen
Aldrin code generator
-
futures-test-preview
Common utilities for testing components built off futures-rs
-
dialectic-tokio-mpsc
A backend for the Dialectic crate using Tokio's MPSC channels
-
futures-waitmap
future-based concurrent event waiting hashmap
-
mercury
The official Rust client for the Mercury Parser
-
tower-make
Trait aliases for Services that produce specific types of Responses
-
gabelung
Branch an asynchronous stream of cloneable items into two
-
gidle_future
A future executor for the glib main loop idle time
-
ntex-io
encoding and decoding frames
-
pingora-rustls
RusTLS async APIs for Pingora
-
nats-connect
Bidirectional async streams over NATS.io
-
change_stream
A Stream that only emits if the value is different
-
rustun
implementing STUN server and client asynchronously
-
message-io
Fast and easy-to-use event-driven network library
-
hyena
async task pool
-
mews
Minimal and Efficient, Multi-Environment WebSocket implementation for async Rust
-
tower-load-shed
Immediately reject requests if the inner service is not ready. This is also known as load-shedding.
-
nodecraft
Crafting seamless node operations for distributed systems, which provides foundational traits for node identification and address resolution
-
nostr-bot
Nostr bot library
-
pexels-api
client for the Pexels API
-
futures-mockstream
Minimal mockstream which implements futures async traits
-
actix-bililive
stream-based bilibili live client library for the Actix ecosystem
-
light-magic
A lightweight, fast and easy-to-use implementation of a optionally encrypted/persistent in-memory database
-
elfo-pinger
Pings groups of the elfo system
-
stream-utils
Additional stream combinators
-
tokio-non-async
Helpers for dealing with tokio channels in non-async code
-
async-stream-http-tunnel-grader
Asynchronous stream http tunnel grader
-
core-futures-tls
A libcore wrapper allowing async/await to be used from no_std crates
-
tower-discover
Abstracts over service discovery strategies
-
zookeeper-client
ZooKeeper async client
-
fieldset
Struct to enum derivation
-
actix-macros
Macros for Actix system and runtime
-
peace_cmd_rt
Runtime types for commands for the Peace framework
-
specta-jsdoc
Export your Rust types to JSDoc
-
elfo-logger
Logs events of the elfo system
-
koibumi-socks
A minimal SOCKS5 client library
-
async-stream-tls-upgrader
Asynchronous stream tls upgrader
-
mqtt-codec-kit
MQTT v3.1.1/v5.0 protocol async codec
-
idb
A futures based crate for interacting with IndexedDB on browsers using webassembly
-
orkhon
Machine Learning Inference Framework and Server Runtime
-
mfio-rt
mfio based async runtime
-
atomic-actor
An
Actor
withasync fn
handlers -
openraft-sledstore
A sled based implementation of the
openraft::RaftStorage
trait -
shadocal
A blazingly fast, Google calendar (more in future) event formatter webserver tool
-
tokio-bincode
Bincode based
tokio-codec
adapter -
black
in Rust for asynchronous, thread-safe logging
-
pingora-proxy
Pingora HTTP proxy APIs and traits
-
swiftide-macros
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
bottle
Actor model framework for Rust
-
compio-log
Log of compio
-
vru-cancel
Cancel tokio stream
-
kythera-fvm
Core implementation of the Kythera FVM
-
async-socks5
An async/.await SOCKS5 implementation
-
openssh-sftp-client-lowlevel
Lowlevel utilities to communicate with openssh sftp server
-
cyper-axum
axum adaptor based on cyper
-
m3u8_downloader
Application m3u8_downloader allows to download m3u8 HLS streams by master playlist link
-
yaaf
Actor Framework
-
lucia-apis
A set of API collections based on the lucia framework
-
websocket_toolkit
A WebSocket toolkit for Rust, enabling efficient real-time communication with flexible reconnection and message handling capabilities
-
streaming-platform
Data streaming platform and message broker with concurrent data transfer capabilities
-
futures-stream-select-ext
futures::stream::select Ext
-
specta-macros
Macros for specta. Don't use directly!
-
bp3d-net
Network utilities
-
nephele
A high performance asynchronous programming runtime for Rust
-
snapup
Abstractions for handling snapshots with streams of subsequent updates
-
tower-ready-cache
Caches a set of services
-
takyon
single threaded async runtime
-
puppet
actor framework which uses no dynamic dispatch or boxing
-
axum-flash
Web framework that focuses on ergonomics and modularity
-
madsim-tonic
The
tonic
simulator on madsim -
stewart-utils
Small common utilities for stewart
-
axum-tungstenite
WebSocket connections for axum directly using tungstenite
-
ant-libp2p-swarm-test
Test framework for code building on top of libp2p-swarm
-
redis-asio
Asynchronous Redis driver based on tokio
-
hyper_lua_actor
Binding of lua_actor & hyper
-
aldrin-parser
Aldrin schema parser library
-
tokio-uring-rustls
Integrate rustls into tokio-uring
-
rabble
creating location transparent actor based systems
-
rama-socks5
SOCKS5 support for rama
-
areq-tokio
Async HTTP requests for tokio runtime
-
agner-reg
An actor toolkit inspired by Erlang/OTP (reg)
-
stream-flatten-iters
Flattens a stream of iterators into one continuous stream
-
tower-layer
Decorates a
Service
to allow easy composition betweenService
s -
alzheimer
Async implementation of brainfuck interpreter
-
verge
An experimental actor library
-
futures-glib
Spawn futures on the glib event loop
-
zino-amis
UI generator for amis
-
peace_rt_model_native
Runtime data types for the peace automation framework
-
futures-state-stream
A version of the futures crate's Stream which returns state on completion
-
boluo-core
boluo的核心类型和特征
-
actm
Tiny async actors framework for rust
-
tk-bufstream
A buffered stream backed by contiguous buffers (netbuf) for tokio
-
tl-async-runtime
A bad runtime impl for educational purposes only
-
ntex-server
Server for ntex framework
-
futuresdr-remote
Remote interaction library for FutureSDR
-
li-async-h1
Asynchronous HTTP 1.1 parser
-
crb-task
CRB | Composable Runtime Blocks | Task
-
pychan
A collection of channels for sending around items of type
pyo3::Py<T>
-
socks5-server
Fine-grained relatively low-level asynchronized SOCKS5 server library based on tokio
-
libp2p-dcutr
Direct connection upgrade through relay
-
task-executor
A task executor
-
pavex
A framework for building API services and web applications in Rust
-
parfait
Most lightweight and easy to use web framework
-
stream-body
An HttpBody implementation with efficient streaming support for the Rust HTTP library hyper
-
tokio-timerfd
timerfd support for tokio
-
stream_router
A Future aware router to dynamically route between Streams and Sinks
-
bongonet-openssl
OpenSSL async APIs for Bongonet
-
architect-tonic-build
Codegen module of
tonic
gRPC implementation -
heph-rt
speciailised runtime for Heph's actor
-
kompact-actor-derive
A derive macro for Kompact Actors
-
ratchet_ext
WebSocket extensions for Ratchet
-
socketioxide-redis
Redis adapter for the socket.io protocol
-
futures-async-runtime-preview
Runtime for the async/await macros in the
futures
crate -
tower-sessions-mongodb-store
MongoDB session store for
tower-sessions
-
genawaiter-macro
Convenience macros for generators (genawaiter)
-
component-future
implements the inner future protocol documented in the tokio docs
-
futures-loco-protocol
Asynchronous Loco protocol stream for futures
-
streamify
Conversions from values to Stream
-
actix-utils
Various utilities used in the Actix ecosystem
-
openssh-mux-client-error
openssh mux client
-
suspend-channel
Channel and stream implementations
-
smol-executor-trait
executor-trait implementation for smol
-
eventum
Asynchronous I/O Event manager
-
spire
The flexible scraper framework powered by tokio and tower
-
bastor
A wrapper helps implementing actor with Bastion more easier with self-implemented state
-
iterstream
Converts Iterator into real asynchronous Stream
-
async-task-group
Manage groups of
async-std
tasks as a single unit -
peace_item_spec_tar_x
Manages extracting a tar file for the peace framework
-
atm-async-utils
implementing and testing futures::Sink and futures::Stream related code
-
async-rustls-stream
An async tls stream library based on rustls and futures-io. Both for server/client.
-
holiday_event_api
The Official Holiday and Event API for Rust
-
shared_stream
easily cloneable streams
-
crb-actor
CRB | Composable Runtime Blocks | Actor
-
async-backtrace
Efficient, logical 'backtraces' of async tasks
-
seal_rs
Set of classic asynchronous primitives (Actors, Executors, Futures / Promises)
-
tarpc-example-service
An example server built on tarpc
-
june
ergonomic remote actors via actix and canary
-
ws-lite
Naive websocket server implemented using async / await
-
wasmflow-traits
encapsulating the message packets sent across Wasmflow components
-
crdb-cache
Concurrently Replicated DataBase
-
actix-test
Integration testing tools for Actix Web applications
-
rosey-actors
Actor framework
-
mendes
Rust web toolkit for impatient perfectionists
-
poller
File I/O events library for Rust
-
cyfs-async-h1
Asynchronous HTTP 1.1 parser
-
rt-local-core
Thread local asynchronous runtime working with platform-specific event loops
-
dialectic-null
A no-op backend for the Dialectic crate, intended for benchmarking and testing
-
stream-consumer-task
Start asynchronous task in background to consume stream
-
miku-h2
An HTTP/2 client and server
-
ruchei-callback
Callback traits for ruchei
-
ntex-service
ntex service
-
aurora-streams
managing publish-subscribe channels using Tokio message passing channels
-
memberlist-quic
memberlist's transport layer based on QUIC
-
read-progress-stream
Stream reader wrapper that tracks the number of bytes read
-
mai
A higher-level mio interface
-
pea2pea
low-level, and customizable implementation of a TCP P2P node
-
suspend_fn
macro for implicit await
-
tokio-async-std
An async-std that can fit into tokio ecosystem straight ahead
-
memberlist-types
Types used in the memberlist crate
-
async-cuda-core
Async CUDA streams and buffers for Rust
-
winio
Single-threaded async GUI runtime based on compio
-
minactor
Minimal actor framework for Rust with tokio
-
mirai
A Futures layer over Mio
-
acril-rt
A lightweight single-threaded runtime for Acril actors
-
xorstream
xoring a vector of data with an (optionally async) stream of data
-
aldrin-codegen
Aldrin code generator library
-
d3-components
A framework for server development -- the component layer
-
async-timer-rs
Hashed timer wheel implementation compatible with asynchronous tasks, support async_std/tokio and other futures base framework
-
futures-executor-preview
Executors for asynchronous tasks based on the futures-rs library
-
compio-macros
Proc macro of compio
-
task_scope
asynchronous runtime extension for supporting Structured Concurrency with task spawning
-
async-component-winit
winit async-component wrapper
-
tokiactor
tokio based Actor framework
-
areq
Async runtime-independent HTTP requests
-
libp2p-webtransport-websys
WebTransport for libp2p under WASM environment
-
hala-future
hala asynchronous programming primitive types
-
zino-extra
Extra utilities for zino
-
futures2
Enables depending on futures 0.2 and futures 0.1 in the same crate
-
logged-stream
Logging of all read/write operations, errors and drop of underlying IO object
-
quinn-proto
State machine for the QUIC transport protocol
-
ohkami_openapi
OpenAPI types for Ohkami - intuitive and declarative web framework
-
rama-proxy
proxy types and utilities for rama
-
async-component
Zero overhead reactive programming
-
threader
A performant multithreaded future executor and event loop
-
libp2p-swarm
The libp2p swarm
-
peace_resources
Runtime resources for the peace automation framework
-
actix-async-await
Experimental async/await support for Actix
-
futures-macro-await-preview
Definition of the
await!
macro for thefutures
crate -
ockam_node_no_std
Ockam library types that do not need
std
-
yaar-reactor
Non-blocking IO abstractions for building executors
-
memberlist
A highly customable, adaptable, async runtime agnostic gossip protocol which helps manage cluster membership and member failure detection
-
ant-libp2p-websocket-websys
WebSocket for libp2p under WASM environment
-
mpool
A generic connection pool
-
zino-openapi
OpenAPI support for zino
-
poem-grpc-build
Codegen module of poem-grpc
-
specta-util
High-level utilities for working with Specta
-
yield-progress
Combined progress reporting and cooperative task yielding
-
actix-files
Static file serving for Actix Web
-
aral-runtime-async-std
Aral Runtime for async-std
-
rama-dns
DNS support for rama
-
socketioxide-parser-common
Common parser for the socketioxide protocol
-
sampr
A message passing framework using actors
-
crdb-server
Concurrently Replicated DataBase
-
ntex-h2
An HTTP/2 client and server
-
tokio-tungstenite-typed
tokio-tungstenite with type safe messages
-
acton_test
Testing utilities for Acton agents, providing tools to help in the testing and validation of agent behavior
-
sse-stream
Convert a http body into sse stream
-
tower-spawn-ready
Drives service readiness via a spawned task
-
poem-grpc
GRPC support for Poem
-
async-graphql-actix-web
async-graphql for actix-web
-
ws_stream_wasm
A convenience library for using websockets in WASM
-
monoio-macros
Monoio proc macros
-
ohkami_lib
internal library for Ohkami - intuitive and declarative web framework
-
minechat-protocol
The MineChat protocol, enabling you chat with people over on Minecraft
-
task-compat
compat futures 0.1 and futures 0.3 tasks
-
citadel_wire
NAT traversal and wire support for the Citadel Protocol
-
lunatic-distributed-api
control server implementation
-
fs4
No libc, pure Rust cross-platform file locks. Original fs2, now supports async and replace libc by rustix.
-
crdb-test-utils
Concurrently Replicated DataBase
-
peace_item_sh_sync_cmd
Manages a synchronization shell command for the peace framework
-
aktrs
An actor model framework for Rust
-
poem-mcpserver
MCP Server implementation for Poem
-
actix-postgres
PostgreSQL integration for Actix framework
-
core-futures-stateless
Workaround for no_std async-await that doesn't store task contexts
-
build_async
Rust Macros to Unify Synchronous and Asynchronous Codebases
-
exo_task
A lightweight async task executor for bare metal (or any) systems
-
ntex-async-std
async-std intergration for ntex framework
-
libp2p-gossipsub
Gossipsub protocol for libp2p
-
improv
Actor microframework
-
zino-chatbot
Unified access to chatbot services for zino
-
tower-async-layer
Decorates a
Service
to allow easy composition betweenService
s. An “Async Trait” fork from the original Tower Library -
vanilla_tokio_actor
Vanilla Tokio Actor
-
holly
A simplistic actor model library using futures
-
d3-core
A framework for server development -- the core layer
-
tokio-net
Event loop that drives Tokio I/O resources
-
mio-more
Extra components for use with Mio
-
peace_item_spec_file_download
Manages downloading a file for the peace framework
-
ntex-util
ntex framework
-
memberlist-net
memberlist's transport layer based on TCP and UDP
-
async-tungstenite
Async binding for Tungstenite, the Lightweight stream-based WebSocket implementation
-
akt
An actors library for Rust and Tokio designed to work with async / await message handlers out of the box
-
libp2p-request-response
Generic Request/Response Protocols
-
aldrin-test
Aldrin server and client tests
-
crdb
Concurrently Replicated DataBase
-
futures-macro-await
Definition of the
await!
macro for thefutures
crate -
sendfile
wrapper around the sendfile(2) system call
-
genawaiter2-proc-macro
procedural macro for generators (genawaiter2)
-
nb-connect
Non-blocking TCP or Unix connect
-
rama-tls
tls implementations for rama
-
echannel
Async channel for mixed events
-
stream-reduce
Fold a stream without an initial value
-
rama-tcp
TCP support for rama
-
actix-tls
TLS acceptor and connector services for Actix ecosystem
-
marigold-impl
Internal logic for the marigold language
-
socketioxide-parser-msgpack
Msgpack parser for the socketioxide protocol
-
rasi-ext
includes extend features or experimental features that are useful for asynchronous programming
-
ant-libp2p-upnp
UPnP support for libp2p transports
-
actix-web-async-await
preview of Actix with async/await support
-
axum-handle-error-extract
Error handling layer for axum that supports extractors and async functions
-
delimiter-slice
Stream type for splitting a delimited stream
-
async-dns
async DNS resolver
-
thespis_impl
Reference implementation for the thespis actor model
-
libp2p-websocket-websys
WebSocket for libp2p under WASM environment
-
ohkami
Build web app in intuitive and declarative code
-
async-net
Async networking primitives for TCP/UDP/Unix communication
-
json-array-stream
Incrementally reads a JSON array through an async stream
-
retty
— an asynchronous Rust networking framework that makes it easy to build protocols, application clients/servers
-
agnostic_async_executor
Agnostic Rust Async Executor
-
tonic-web
grpc-web protocol translation for tonic services
-
aector
Dynamic implementation of the actor model with a smart built-in testing framework
-
actor
Actors traits
-
agency
A small async actor framework
-
crdb-sqlite
Concurrently Replicated DataBase
-
stream_multiplexer
Combines many streams into a few
-
tower-async-service
Trait representing an asynchronous, request / response based, client or server. An "Async Trait" fork from the original Tower Library
-
async-std
Deprecated in favor of
smol
- Async version of the Rust standard library -
elfo-core
The core of the elfo system
-
libp2p-autonat
NAT and firewall detection for libp2p
-
rama-net
rama network types and utilities
-
citadel_sdk
High-level library to build applications on the Citadel Protocol
-
coerce-rt
Async actor runtime
-
stage
An ergonomic, composable Actor Model, designed for painless concurrency
-
stream_generator
Allows to easily generate streams with async/await
-
connect
message queue abstraction over async network streams
-
cap-async-std
Capability-based version of async-std
-
ant-libp2p-identify
Nodes identification protocol for libp2p
-
ntex-grpc
GRPC Client/Server framework
-
actix-testing
Various helpers for Actix applications to use during testing
-
crdb-indexed-db
Concurrently Replicated DataBase
-
tentacle-secio
Secio encryption protocol for p2p
-
ntex-grpc-codegen
GRPC Client/Server framework (codegen)
-
crdb-postgres
Concurrently Replicated DataBase
-
async-rustls
Asynchronous TLS/SSL streams using Rustls
-
axum
Web framework that focuses on ergonomics and modularity
-
bastion-executor-trait
executor-trait implementation for bastion
-
ntex-codec
encoding and decoding frames
-
swimos_multi_reader
SwimOS Stream Aggregator
-
ruchei-extra
Stream/Sink wrapper with extra data, as used by ruchei
-
libp2p-swarm-test
Test framework for code building on top of libp2p-swarm
-
execution-engine
Toca Execution Engine implemented using Futures and async/await
-
ntex-glommio
glommio intergration for ntex framework
-
async-h1
Asynchronous HTTP 1.1 parser
-
peace_core
Low level data types for the peace automation framework
-
aldrin-core
Shared core components of Aldrin, a message bus for service-oriented RPC and interprocess communication
-
memberlist-core
A highly customable, adaptable, async runtime agnostic Gossip protocol which helps manage cluster membership and member failure detection
-
ant-libp2p-dns
DNS transport implementation for libp2p
-
libp2p-wasm-ext
Allows passing in an external transport in a WASM environment
-
uexec
work-stealing global and local executor
-
libp2p-mdns
libp2p mDNS discovery method
-
zino-salvo
Integrations with salvo for zino
-
peace_rt_model_core
Core runtime traits for the peace automation framework
-
crdb-macros
Concurrently Replicated DataBase
-
peace_item_sh_cmd
Manages running a shell command for the peace framework
-
rama-utils
rama
-
peace_static_check_macros
Compile time validation macros for the peace automation framework
-
ant-libp2p-plaintext
Plaintext encryption dummy protocol for libp2p
-
futures-async-stream-macro
detail of the
futures-async-stream
crate -
peace
zero stress automation
-
peace_code_gen
Code generation macros for the peace automation framework
-
actix-http
HTTP types and services for the Actix ecosystem