-
mio
Lightweight non-blocking I/O
-
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
-
deadpool
Dead simple async pool
-
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
-
rdkafka
Rust wrapper for librdkafka
-
async-broadcast
Async broadcast channels
-
futures
streams featuring zero allocations, composability, and iterator-like interfaces
-
async-executor
Async executor
-
async-std
Async version of the Rust standard library
-
futures-timer
Timeouts for futures
-
pollster
Synchronously block the thread until a future completes
-
bb8
Full-featured async (tokio-based) connection pool (like r2d2)
-
blocking
A thread pool for isolating blocking I/O in async programs
-
event-listener
Notify async tasks or threads
-
futures-concurrency
Structured concurrency operations for async Rust
-
suppaftp
A super FTP/FTPS client library for Rust
-
tokio-serial
A serial port implementation for tokio
-
multer
An async parser for
multipart/form-datacontent-type in Rust -
paho-mqtt
The Official Eclipse Paho MQTT Rust Client Library. This is a wrapper around the Paho C library
-
minus
An asynchronous data feedable terminal paging library for Rust
-
interprocess
communication toolkit
-
async_zip
An asynchronous ZIP archive reading/writing crate
-
ractor
A actor framework for Rust
-
cucumber
testing framework for Rust, with async support. Fully native, no external test runners or dependencies.
-
async-trait
Type erasure for async trait methods
-
amqprs
AMQP 0-9-1 client implementation for RabbitMQ
-
keycloak
Admin REST API
-
want
Detect when another Future wants a result
-
polling
Portable interface to epoll, kqueue, event ports, and IOCP
-
openraft
Advanced Raft consensus
-
tower-sessions
🥠 Sessions as a
towerandaxummiddleware -
redis-async
An asynchronous futures based Redis client for Rust using Tokio
-
async-process
Async interface for working with processes
-
async-scoped
Spawn scoped (non 'static) asynchronous futures for async_std and tokio runtimes
-
failsafe
A circuit breaker implementation
-
tokio-metrics
Runtime and task level metrics for Tokio applications
-
ws_stream_tungstenite
Provide AsyncRead/AsyncWrite over Tungstenite WebSockets
-
futures-locks
Futures-aware lock primitives
-
tor-rtcompat
Compatibility layer for asynchronous runtimes, used by Tor
-
calloop
A callback-based event loop
-
monoio
A thread per core runtime based on iouring
-
futures-signals
Zero cost FRP signals using the futures crate
-
unicycle
A scheduler for driving a large number of futures
-
madsim
Deterministic Simulator for distributed systems
-
stream-cancel
interrupting asynchronous streams
-
apalis
extensible multithreaded background job processing for Rust
-
tokio-graceful
util for graceful shutdown of tokio applications
-
local-channel
A non-threadsafe multi-producer, single-consumer, futures-aware, FIFO queue
-
async-native-tls
Native TLS using futures
-
nb
Minimal non-blocking I/O layer
-
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
-
async-recursion
Recursion for async functions
-
containerd-shim
containerd shim extension
-
async-io
Async I/O and timers
-
futures-buffered
future concurrency primitives with emphasis on performance and low memory usage
-
eyeball
Add observability to your Rust types!
-
esrs
A Prima.it-opinionated library to achieve cqrs/es
-
tokio-native-tls
TLS/SSL streams for Tokio using native-tls giving an implementation of TLS for nonblocking I/O streams
-
hypercore
Secure, distributed, append-only log
-
async-shutdown
one-stop solution for async graceful shutdown
-
motore
modular and reusable components for building robust clients and servers. Motore is greatly inspired by Tower.
-
rxrust
Reactive Extensions
-
io-uring
The low-level
io_uringuserspace interface for Rust -
fang
Background job processing library for Rust
-
rusty_falcon
Rust bindings for CrowdStrike Falcon API
-
actix-web-flash-messages
Flash messages for actix-web applications
-
pharos
Observer pattern which generates a futures 0.3 stream of events
-
tmq
ZeroMQ bindings for 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
-
tokio-retry
Extensible, asynchronous retry behaviours for futures/tokio
-
gix-actor
A way to identify git actors
-
tokio-zookeeper
Asynchronous client library for interacting with Apache ZooKeeper
-
c-ares-resolver
An asynchronous DNS resolver, backed by c-ares
-
fluvio-future
I/O futures for Fluvio project
-
asynchronous-codec
encoding and decoding frames using
async/await -
service-async
A Service like tower in async style
-
tokio-io-utility
Some helper functions for tokio::io
-
async-speed-limit
Asynchronously speed-limiting multiple byte streams
-
wasm-bindgen-futures
Bridging the gap between Rust Futures and JavaScript Promises
-
mml-lib
Emacs MIME message Meta Language (MML)
-
async-walkdir
Asynchronous directory traversal for Rust
-
reactive-mutiny
async Event-Driven Reactive Library with advanced & optimized containers (channels) and Stream executors
-
celery
Rust implementation of Celery
-
fvm_shared
Filecoin Virtual Machine shared types and functions
-
scoped-futures
imposing upper bounds on Future lifetimes
-
kafka
Rust client for Apache Kafka
-
poem-openapi
OpenAPI support for Poem
-
exponential-backoff
An exponential backoff generator with jitter
-
tokio-graceful-shutdown
perform a graceful shutdown on a Tokio based service
-
async-fn-stream
Lightweight implementation of
async-streamwithout macros -
fn_graph
Dynamically managed function graph execution
-
lazy-pool
Experimental lazy object pool
-
hirun
A concurrent framework for asynchronous programming based on event-driven, non-blocking I/O mechanism
-
apis
Reactive, session-oriented, asynchronous process-calculus framework
-
lamellar
asynchronous tasking runtime for HPC systems developed in RUST
-
futures-rustls
Asynchronous TLS/SSL streams for futures using Rustls
-
triggered
Triggers for one time events between tasks and threads
-
kameo
Fault-tolerant Async Actors Built on Tokio
-
swiftide
Blazing fast, streaming pipeline library for AI applications
-
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
-
filebuffer
Fast and simple file reading
-
actix
Actor framework for Rust
-
swiftide-query
Blazing fast, streaming pipeline library for AI applications
-
dataloader
Facebook's DataLoader using async-await
-
tokio_schedule
schedule tasks in tokio runtime
-
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
-
cancel-safe-futures
Alternative futures adapters that are more cancellation-aware
-
stilgar
A lightweight, no-fuss, drop-in replacement for Rudderstack
-
interruptible
Stops a future producer or stream from producing values when interrupted
-
safina
Safe async runtime
-
rs-event-emitter
simulate promise implementation for rust
-
faktory
API bindings for the language-agnostic Faktory work server
-
hydra
A framework for writing fault tolerant, highly scalable applications with the Rust programming language
-
crosstown_bus
Event Bus with RabbitMQ for Rust
-
poll-promise
Poll the result of an async operation in a game or immediate mode GUI
-
wg
Golang like WaitGroup implementation for sync/async Rust
-
dark-std
asynchronous containers build on tokio. It uses a read-write separation design borrowed from Golang
-
stakker
A lightweight low-level single-threaded actor runtime
-
pijul
A distributed version control system
-
async-tempfile
Automatically deleted async I/O temporary files
-
partial-io
Helpers to test partial, interrupted and would-block I/O operations, with support for property-based testing through proptest and quickcheck
-
poster
MQTTv5 client library written in Rust
-
yt-dlp
⚙️ A Rust library (with auto dependencies downloading) for yt-dlp 🎬️
-
async-socks5
An async/.await SOCKS5 implementation
-
krecik
Asynchronous, parallel external service checker (and reporter), using industry standard libraries: Curl, ngHTTP2 and OpenSSL
-
mobc
A generic connection pool with async/await support
-
conogram
An async wrapper for Telegram Bot API
-
glommio
thread-per-core crate that makes writing highly parallel asynchronous applications in a thread-per-core architecture easier for rustaceans
-
futures-lite
Futures, streams, and async I/O combinators
-
genawaiter
Stackless generators on stable Rust
-
trait-variant
working with impl traits in Rust
-
aqueue
fast speed thread safe async execute queue
-
tokio_wasi
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
debounced
building delayed
Futures and debouncedStreams that wait a given duration before yielding the most recent item -
tiny-tokio-actor
tiny actor library on top of tokio
-
rust-parallel
Fast command line app in rust/tokio to run commands in parallel. Similar interface to GNU parallel or xargs.
-
deno_unsync
A collection of adapters to make working with Tokio single-threaded runtimes easier
-
ipc-queue
FIFO queue described in fortanix-sgx-abi used for asynchronous usercalls
-
mio-serial
A serial port implementation for mio
-
executor-trait
A collection of traits to define a common interface across executors
-
countio
Byte counting for std::io::{Read, Write, Seek} and its async variants from futures and tokio
-
syslog-rs
A native Rust implementation of the glibc/libc syslog
-
async-dropper
The least-worst ad-hoc implementation of AsyncDrop as a Derive macro
-
multishot
An async, lock-free, reusable channel for sending single values to asynchronous tasks
-
pi-async-rt
Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
-
lazy_async_promise
Primitives for lazily getting data from futures with tokio for immediate mode guis
-
futures-bounded
bounding futures in size and time
-
round-based
Driver for MPC protocols
-
ferrisgram
An elegent rust client for the Telegram Bot API
-
delay_timer
Time-manager of delayed tasks. Like crontab, but synchronous asynchronous tasks are possible, and dynamic add/cancel/remove is supported.
-
get_chunk
File iterator or stream with auto or manual chunk size selection
-
blockstore
An IPLD blockstore capable of holding arbitrary data indexed by CID
-
async-ringbuf
Async SPSC FIFO ring buffer
-
decrypt-cookies
A decrypt browser crate
-
springtime-di
Dependency injection framework based on automatic component discovery and runtime autowiring
-
rsdns
DNS Client Library
-
another-rxrust
A different implementation than
rxRustfor easier use ofReactiveXinRust -
tros
Your tros from tarantool TX thread to tokio(..and others!)
-
a10
io_uring library
-
ghost_actor
GhostActor makes it simple, ergonomic, and idiomatic to implement async / concurrent code using an Actor model
-
effectum
An embeddable task queue based on SQLite
-
stream_throttle
Stream combinator, to limit the rate at which items are produced
-
ya-gcp
APIs for using Google Cloud Platform services
-
cassette
single-future, non-blocking executor intended for building state machines
-
lcode
An application of terminal write leetcode.一个终端刷力扣的应用
-
kube-coordinate
Kubernetes leader election using the coordination.k8s.io API
-
llm_client
The Easiest Rust Interface for Local LLMs, and an Interface for Deterministic Signals from Probabilistic LLM Vibes
-
lemmy_db_views_actor
A link aggregator for the fediverse
-
tokio-test
Testing utilities for Tokio- and futures-based code
-
twilight-http-ratelimiting
Discord REST API ratelimiter implementations for the Twilight ecosystem
-
hannibal
a small actor library
-
tokio-pipe
Asynchronous pipe(2) library using tokio
-
async-graphql-poem
async-graphql for poem
-
hypercore-protocol
Replication protocol for Hypercore feeds
-
messagebus
allows intercommunicate with messages between modules
-
freedom-api
Freedom API for Rustaceans
-
futuresdr
An Experimental Async SDR Runtime for Heterogeneous Architectures
-
daktronics-allsport-5000
decoders for the Daktronics All Sport 5000's serial output
-
rxr
Reactive extensions for event-driven applications
-
shadocal
A blazingly fast, Google calendar (more in future) event formatter webserver tool
-
kube-lease-manager
Ergonomic and reliable leader election using Kubernetes Lease API
-
postage
An async channel library
-
actix-casbin
An Actix actor for casbin
-
keen-retry
-- yet powerful -- zero-cost-abstractions & zero-copy lib for error handling & recovery
-
mail-message
A program for easy, quick, and fault tolerant sending of emails from the command line
-
ate
Distributed immutable data store with strong encryption and authentication
-
etcdv3client
etcdv3 client
-
mini_exercism
Minimalistic Rust library to interact with the Exercism.org APIs
-
containerd-client
GRPC bindings to containerd APIs
-
pty-process
spawn commands attached to a pty
-
ractor_actors
actors built with Ractor
-
b2_backblaze
basic async library to upload small files to backblaze b2 service
-
async_smux
Asynchronous smux multiplexing library
-
compio
Completion based async runtime
-
keyring-lib
High-level, asynchronous API for keyring-rs, a cross-platform Rust library to manage credentials
-
async_cache
Async refresh cache
-
reactio
Low-Latency Event Driven Nonblocking Reactor Pattern
-
nuclei
Proactive IO & runtime system
-
local-waker
A synchronization primitive for thread-local task wakeup
-
async-object-pool
object pool implementation that uses asynchronous synchronization primitives only
-
tor-rtmock
Testing mock support for tor-rtcomapt
-
c-ares
wrapper for the c-ares library, for asynchronous DNS requests
-
certsd
automated, asynchronous LE certificate issuer
-
async_executors
Implements Spawn, SpawnLocal and SpawnHandle for commonly used executors
-
drop-stream
A stream that wraps another stream with a closure that is called once it is dropped
-
ntex-grpc
GRPC Client/Server framework
-
async-cuda
Async CUDA for Rust
-
xtra
A tiny actor framework
-
my-awesome-rabbitmq-lib
working with RabbitMQ and asynchronous operations
-
quick-protobuf-codec
Asynchronous de-/encoding of Protobuf structs using asynchronous-codec, unsigned-varint and quick-protobuf
-
netidx-protocols
Protocols built on top of netidx
-
duplicate-checker
A duplicate file checker
-
tokio-stream
work with
Streamandtokio -
rocketmq-store
Unofficial Rust implementation of Apache RocketMQ
-
aggligator
Aggregates multiple links (TCP or similar) into one connection having their combined bandwidth and provides resiliency against failure of individual links
-
gloo-worker
Convenience crate for working with Web Workers
-
sn_sdkg
Safe Network Synchronous Distributed Key Generation: enables dealerless section key generation
-
stopper
an async stream and future stopper mechanism
-
delouse
will expose opinionated debugging stubs most useful for tokio based async programs
-
wait
Syntactic sugar for calling async functions outside of an async context
-
tokio-io-timeout
Tokio wrappers which apply timeouts to IO operations
-
async-change-tracker
reactive change notifications using futures
-
monzo-lib
async Monzo client in pure rust
-
futures-util
Common utilities and extension traits for the futures-rs library
-
synchronized-writer
A tiny implement for synchronously writing data
-
tokio-scheduler-rs
JobScheduler written with tokio runtime, automatic retry, hook and custom storage supported
-
miow
A zero overhead I/O library for Windows, focusing on IOCP and async I/O abstractions
-
mio_wasi
Lightweight non-blocking IO
-
unkey
An asynchronous Rust SDK for the Unkey API
-
futures-scopes
Runtime agnostic, nestable, scopes for spawning non-static futures
-
dynosaur
Dynamic dispatch for return position impl traits and async in Rust
-
irelia
wrapper around the native LoL APIs
-
elfo
Your next actor system
-
asteroid-mq
An embeddable message queue system
-
aj
Background Job based on Actix
-
some_executor
A trait for libraries that abstract over any executor
-
next-gen
Safe generators on stable Rust
-
zookeeper-async
An async ZooKeeper client
-
scoped-stream-sink
Easy way to make streams and sinks
-
wgpu-async
Converts some WGPU callback methods to async methods
-
pgp-lib
High-level, asynchronous API for rPGP, a pure Rust implementation of OpenPGP
-
whirlwind
Collection of thread-safe, asynchronous data structures
-
apalis-sql
SQL Storage for apalis. Use sqlite, postgres and mysql for background job processing
-
tower-batch-control
Tower middleware for batch request processing
-
madsim-rdkafka
The rdkafka simulator on madsim
-
hedwig
message bus for Rust
-
tokio-retry2
Extensible, asynchronous retry behaviours for futures/tokio
-
minior
Ergonomic Minio Client
-
redis-work-queue
A work queue, on top of a redis database, with implementations in Python, Rust, Go, Node.js (TypeScript) and Dotnet (C#)
-
async_cell
A Cell<Option<T>> that you can await on
-
async-event-emitter
Lightweight AsyncEventEmitter
-
s3tui
TUI application for multiple s3 account operations
-
mikrotik-rs
Asynchronous Rust library for interfacing with MikroTik routers
-
async-shared-timeout
Async timeout that can be reset and shared
-
rdkafka-sys
Native bindings to the librdkafka library
-
mqi
Idiomatic IBM® MQ Interface (MQI) and MQ Administration Interface (MQAI) APIs
-
distributed-scheduler
A distributed cronjob library
-
vesper
A slash-command framework meant to be used with twilight
-
flatline
ssh-2.0 client library
-
fundamentum-edge-daemon
The supported way to access Fundamentum's ecosystem from linux devices
-
ads_client
An asynchronous, non-blocking ADS client
-
coc-rs
wrapper around the Clash of Clans public API
-
rio
GPL-3.0 nice bindings for io_uring. MIT/Apache-2.0 license is available for spacejam's github sponsors.
-
stressed
Universal CLI stress tester for competitive programming
-
peace_resources
Runtime resources for the peace automation framework
-
async-io-mini
Async I/O fork for embedded systems
-
tcpclient
Asynchronous tcpclient based on aqueue actor
-
kafru
Python Celery-inspired queuing library for Rust, using cron for scheduling and SurrealDB for storing queues, metrics, and schedules
-
apocalypse
actor framework for Rust
-
z_osmf
z/OSMF Client
-
pinky-swear
Futures and async/await-ready Promises
-
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…
-
eventuals
Eventually consistent values
-
embedded-runtime
A tiny async runtime for embedded devices
-
crossmist
Efficient and seamless cross-process communication, both synchronously and asynchronously
-
taskline
distributed task queue for Rust
-
lighthouse-client
Client SDK for Project Lighthouse
-
gprs
A set of filtered and optimized Rust libraries creates a foundation for building modern web frameworks
-
actix-mqtt-client
A MQTT client based on the actix framework
-
pubnub
SDK for Rust
-
pin-utils
pinning
-
dptree
An asynchronous event dispatch mechanism for Rust
-
splaycast
Stream-specific broadcast channel
-
resident-utils
Resident program library
-
rust-utils
Various utility routines used in the rust programs I have written
-
winctx
A minimal window context for Rust on Windows
-
tls-api
TLS API without implementation
-
async-scgi
Async SCGI Client & Server
-
fvm_actor_utils
Utils for authoring native actors for the Filecoin Virtual Machine
-
mapped_futures
A collection of futures based on FuturesUnordered that supports insertion, removal and mutation of futures by key
-
async_io_stream
IntoAsyncRead on steriods
-
async-stomp
Unofficial successor to Asynchronous streaming STOMP client
-
railsgun
Excessive tooling for Result handling - If you want rails you got RAILS!
-
rusturn
TURN server and client
-
vmcircbuffer
Double Mapped Circular Buffer
-
futures-retry
Retry your Futures and Streams!
-
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
-
swiftide-integrations
Blazing fast, streaming pipeline library for AI applications
-
discro
DISCRete Observables for asynchronous Functional Reactive Programming (FRP)
-
gasket
Staged Event-Driven Architecture (SEDA) framework
-
fama
Pipeline Manager
-
nominatim
Bindings to the reverse geocoding API powered by openstreetmap
-
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)…
-
pistones
An wrapper for the Piston code execution engine
-
infect
Intent/effect/task - A variation on the Model View Intent (MVI) and State Action Model (SAM) paradigms
-
rseip
Ethernet/IP (CIP) client in pure Rust
-
mulligan
A flexible retry library for Rust async operations with configurable backoff strategies and jitter
-
bleasy
High-level BLE communication library
-
tokio-hrtime
Hires timers for tokio
-
napi_ext
Extends napi-rs with the ability to run local futures
-
tools_interface
Abstractions of serveral Wikipedia/Wikimedia/Wikidata-related tools
-
cache_loader_async
A thread safe loading cache with async loader functions based on tokio
-
nebkor-maelstrom
synchronous client for creating Maelstrom distributed clients
-
translators
Free Google Translator without API key and limits
-
vkapi2
vk api wrapper for rust
-
tokio-io-rewind
rewind tokio::io::AsyncRead and tokio::io::AsyncWrite streams
-
act_rs
Act.rs is an actor library built to be used with the standard library and Tokio
-
graceful-shutdown
Graceful Shutdown for async code
-
monoio-codec
Codec for Monoio
-
coasys_juniper
GraphQL server library
-
yosemite
Asynchronous SAMv3 library
-
kafka-threadpool
An async rust threadpool for publishing messages to kafka using SSL (mTLS) or PLAINTEXT protocols
-
tipsy
Cross-platform IPC for Tokio
-
process-lib
Cross-platform, asynchronous Rust library to run commands in pipelines
-
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
-
short_future
Future with shorter lifetime for async closures
-
simple-git
git interface for gix suitable for async context (with tokio)
-
retry-if
A tokio-compatible attribute-macro for decorating methods and functions with an exponential backoff
-
pgboss
job queueing service
-
async_zmq
Async version for ZeroMQ bindings
-
borrow_mutex
Async Rust Mutex which does not require wrapping the target structure
-
kapacitor-udf
creating Kapacitor User Defined Functions (UDFs)
-
persway
Sway IPC daemon
-
woddle
An async, synchronized, database-backed Rust job scheduler
-
senders_receivers
Senders/Receivers implementation for Rust
-
async-codec
creating async codecs
-
mal-api
An asynchronous MyAnimeList (MAL) API library for Rust
-
pi_rt_file
async file 的封装，添加了多线程竞争排序。
-
rustix-uring
The low-level
io_uringuserspace interface for Rust -
pasts
Minimal and simpler alternative to the futures crate
-
linemux
providing asynchronous, multiplexed tailing for (namely log) files
-
rustygram
minimal and blazing fast telegram notification framework for Rust
-
async-rate-limiter
Implements a token bucket algorithm that can be used to limit API access frequency. Written in pure Rust.
-
async-lsp
Asynchronous Language Server Protocol (LSP) framework based on tower
-
ipc-rpc
A wrapper over servo/ipc-channel which provides many high level features
-
meltdown
A lightweight service manager to help with graceful shutdown of asynchronous applications
-
tower-memlim
Tower based middleware layer to limit requests based on the host's computer memory usage
-
php-tokio
Use any async Rust library from PHP!
-
kuska-handshake
Secure Scuttlebutt handshake + boxstream library
-
rust-multipart-rfc7578_2
multipart/form-data (RFC7578)
-
tactix
Actor Model based on Tokio
-
moro-local
Experimental structured concurrency support for async Rust (similar to trio's nurseries). Works with non-Send futures on stable Rust.
-
actix-multipart-rfc7578
multipart/form-data (RFC7578) for Actix
-
deferred-future
模仿 jQuery.Deferred()，允许从 Future 实现类实例的外部对正在 pending 的 Future 对象进行 resolve 或 reject 处理。
-
crossword_generator
generating crossword from provided words
-
girlboss
async job manager with progress tracking
-
tokio-rayon
Mix async code with CPU-heavy thread pools using Tokio + Rayon
-
bb8_surrealdb2
Surrealdb support for the async bb8 connection pool
-
async-ffi
FFI-compatible
Futures -
futures-signals-ext
Extension to futures-signals: MutableOption with combinators, spawning, predicate driven selections from SignalVec
-
pierport
Urbit pier import protocol implementation
-
ticks
ergonomic Rust wrapper for the TickTick Open API
-
agnostic
users who want to write async runtime-agnostic crate
-
futures-core
The core traits and types in for the
futureslibrary -
send-future
Ergonomic and performant fix for https://github.com/rust-lang/rust/issues/96865
-
ringlog
A fast and lightweight non-blocking logging framework
-
eventbuzz
A safe, fast, concurrent event publish/subscribe system based on tokio(async), inspired by Spring events
-
xan-actor
Akka actor
-
maily
easy, quick, and fault tolerant sending of emails
-
termusix
A terminal-based music player with a user-friendly terminal UI, built with Rust
-
sacs
Async Cron Scheduler for Tokio
-
cancellation-token
C#'s CancellationToken API
-
batch-channel
async channel that reduces overhead by reading and writing many values at once
-
cassandra-protocol
Cassandra protocol implementation
-
future-queue
Adapters to manage a queue of futures, where each future can have a different weight
-
asynk
Multithread asynchronous runtime and reactor
-
tokactor
A actor model framework wrapped around tokio
-
gem-rs
that serves as a wrapper around the Gemini API, providing support for streaming
-
rasi-mio
a rasi drivers implementation base on mio
-
patharg
Treat "-" (hyphen/dash) arguments as stdin/stdout
-
suppaftp-cli
FTP command line client, based on suppaftp
-
mio-pidfd
mio support for Linux's pidfd
-
boomerang_builder
The Reactor assembly API for Boomerang
-
monoio-rustls
Asynchronous TLS streams wrapper for Monoio based on Rustls
-
bisync
write async-generic code
-
asynk-strim
Lightweight stream generator library
-
async-select
select!multiplex asynchronous futures simultaneously -
tokio-muxt
Timer for a limited set of events that multiplexes over a single tokio Sleep instance
-
containerd-shim-protos
TTRPC bindings for containerd shim interfaces
-
tokio-js-set-interval
Allows you to use
setInterval(callback, ms)andsetTimeout(callback, ms)as in Javascript inside atokioruntime. The library provides the macrosset_interval!(callback, ms)andset_timeout!(callback, ms) -
ultra-batch
Tokio-based library to batch and cache database queries or other data lookups
-
screeps-async
Tick-aware Async runtime for Screeps
-
rocketmq-client-v4
rocket mq rust client for remote protocol. works on rocket mq V4
-
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.
-
interthread
Auto implementation of the Actor Model
-
tower-sessions-rusqlite-store
(tokio-)rusqlite session store for
tower-sessions -
stackfuture
wrapper around futures that stores the wrapped future in space provided by the caller
-
async-defer
Asynchronous Deferred Calls
-
hyperbee
Peer to Peer B-tree
-
scylla-rs
An async ScyllaDB driver built on an actor-model framework
-
async_async_io
AsyncRead,AsyncWritetraits but withasync fnmethods -
async_counter
Counter that implements a future to await on specific value
-
constellation-rs
Constellation is a framework for Rust (nightly) that aides in the writing, debugging and deployment of distributed programs
-
singleflight-async
Singleflight in async style
-
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.
-
async-tls
Asynchronous TLS/SSL streams using Rustls
-
knien
Typed RabbitMQ interfacing for async Rust
-
tokio-send-fd
A wrapper for tokio::net::UnixStream to send file descriptors
-
fundamentum-sdk-mqtt
MQTT client targeting Fundamentum IoT's MQTT broker
-
stream-wave-parser
The
stream-wave-parseris a crate that treats a stream from WAVE file -
waterark
Watermark for implementing optimistic SSI (Serializable Snapshot Isolation) transactions
-
futures-finally
that executes a future after the completion of a future or stream regardless of the value or outcome
-
async-transmit
Trait for transmitting data to peers asynchronously
-
cxx-async
interoperability between C++ coroutines and asynchronous Rust
-
passivized_vault_client
Vault Client - initialize and monitor Hashicorp Vault nodes
-
read_until_slice
AsyncBufRead::read_until extension to take a slice as a delimiter instead of a single u8
-
tokio-tower
Bridging the protocol gap between Tokio and Tower
-
socksv5
SOCKS v4a and v5 basic building blocks to build your own async SOCKS application
-
serial-thread
Asynchronous, multithreaded serial port communication library using mpsc::cjhannels or async-channels for efficient data handling
-
async-cron-scheduler
Runtime-agnostic async task scheduler with cron expression support
-
busstop
A command and query bus
-
proptest_async
proptest macro supporting async tests
-
ctf-pwn
Pwn utilities for Rust
-
hakuban
Data-object sharing library
-
haalka_futures_signals_ext
vendored version of MoonZoon's futures_signals_ext, as it is yet to be released as a crate
-
async-tensorrt
Async TensorRT for Rust
-
smol-potat
Proc macro for smol runtime
-
isotp-rs
ISO-TP trait define
-
pptr
Type-Driven Asynchronous Actor Runtime
-
lookit
Asynchronously connect to devices
-
bus_queue
Lock-free Bounded non-Blocking Pub-Sub Queue
-
mosquitto-rs
An async MQTT client based on libmosquitto
-
supply-chain-trust-example-crate-000054
Lightweight non-blocking I/O
-
shutdown
can be used to gracefully exit (part of) a running program
-
futures-boring
SSL streams for Futures built on top of the BoringSSL
-
async-compatibility-layer
an abstraction layer for using both async-std and tokio
-
lsp-async-stub
An LSP server stub for futures
-
fb_futures_ext
future crate extensions
-
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.
-
hass-rs
An async websocket client for Home Assistant
-
async-unsync
asynchronous, unsynchronized (thread-local) channels and semaphores
-
killswitch
used to broadcast a shutdown request
-
aws-parameters-and-secrets-lambda
Cache AWS Secrets Manager secrets in your AWS Lambda function
-
wasmcloud-interface-factorial
Interface library for the wasmcloud factorial capability, wasmcloud:example:factorial
-
wiremock_logical_matchers
Logical matchers for use with wiremock
-
wired_handler
Wired's handler library
-
rustun
implementing STUN server and client asynchronously
-
tokio-socketcan
Asynchronous Linux SocketCAN sockets with tokio
-
aranya-policy-ifgen
Tools for generating Rust interfaces to Aranya Policies
-
debouncer
A simple debouncer for Rust
-
lutetium
tokio based simple actor library
-
futures-map
Futures-based and hashmap-based alogrithms
-
sodium
FRP (Functional Reactive Programming)
-
async-rdma
async wrapper for RDMA ibvers lib
-
conva_ai
Rust SDK for using CONVA AI Copilots
-
ianaio-worker
Convenience crate for working with Web Workers
-
retrier
A wasm-compatible retry library for futures
-
cbsk_socket_tokio
socket callback tool by tokio
-
jni-utils
Extra Utilities for JNI in Rust
-
libuv-sys-lite
Tiny, raw bindings to libuv without linking to it
-
par-stream
Asynchronous parallel streams analogous to rayon
-
tokio_gen_server
Elixir/Erlang-GenServer-like actor on the Tokio runtime
-
state_machine_future
Easily create type-safe
Futures from state machines — without the boilerplate -
tokio-util
Additional utilities for working with Tokio
-
libublk
building linux block device in userspace
-
async-observable
Async & reactive synchronization model to keep multiple async tasks / threads partially synchronized
-
ractor_cluster
Distributed cluster environment of Ractor actors
-
tokio-stomp-rs
Asynchronous streaming STOMP client fork
-
mpi-sys
Message Passing Interface bindings for Rust
-
tigerbeetle-unofficial
Safe high level async bindings to tigerbeetle client library
-
secret-lib
Cross-platform, asynchronous Rust library to retrieve secrets from different sources
-
nolocal-block-on
futures_lite::future::block_on that can run without using thread-locals
-
rustygear
Client library for communicating via the gearman protocol
-
lending-stream
A lending version of Stream
-
ng-repo
Repository library of NextGraph, a decentralized, secure and local-first web 3.0 ecosystem based on Semantic Web and CRDTs
-
handle
Trait for asynchronous context pipeline
-
bsky-cli
CLI application for Bluesky using ATrium API
-
thread-waker
Waker implementation using current thread token
-
tokio_delayed_queue
Asynchronous delayed queue for Tokio runtime
-
background-jobs-sled
Sled storage backend for background-jobs
-
zeroconf-tokio
Tokio-based wrapper around the zeroconf crate, which provides mDNS service discovery and registration capabilities
-
catalyzer
HTTP server framework
-
sparkle-convenience
A wrapper over Twilight designed to make it more convenient to use
-
moeval
a toy interpreter
-
ticque
Take a queue for a resource
-
aa-sms
Send messages from with Andrews & Arnold’s SMS API
-
tub
Async Pool
-
gcp_access_token
pure rust implimentation to get google cloud access token for servers with service account credentials
-
disintegrate
build event-sourced applications
-
spawns
Async runtime agnostic thread context task spawner for Rust
-
alicemq
Wapper for the amqprs rabbitMQ library
-
okstd
The standard library that's ok
-
streamunordered
An efficient async stream multiplexer
-
discern
implementing the Command Query Responsibility Segregation (CQRS) pattern
-
orengine
Optimized ring engine for Rust. It is a lighter and faster asynchronous library than tokio-rs, async-std, may, and even smol
-
tower-sessions-libsql-store
A small library for using tower-sessions with libsql
-
livekit-runtime
Async runtime compatibility layer for LiveKit
-
mlua-luau-scheduler
Luau-based async scheduler, using mlua and async-executor
-
asynclog
asynchronous log library
-
webex
Interface to Webex Teams REST and WebSocket APIs
-
eyeball-im
Observable collections based on the
imcrate -
dwn
Decentralized Web Node
-
spin_on
inefficient Future executor
-
akinator-rs
wrapper around the undocumented Akinator API
-
minos
Authorization library
-
git-next-server-actor
Server actor for git-next, the trunk-based development manager
-
turmoil
Simulation testing framework for distributed systems
-
stream-reconnect
Stream-wrapping traits/structs that automatically recover from potential disconnections/interruptions
-
piscina
generic pool that supports both sync and async
-
swiftide-indexing
Blazing fast, streaming pipeline library for AI applications
-
pausable_future
Pausable and resumable future, useful in background tasks
-
hexpm
client for the Hex package manager
-
pwner
Process Owner crate that allows ergonomic access to child processes
-
openraft-memstore
A in-memory implementation of the
openraft::RaftStoragetrait -
tokio-nats
Async-await ready NATS library
-
upstox-rust-sdk
SDK to access Upstox's Uplink v2 APIs programmatically
-
swimos_future
SwimOS Future Utilities
-
test_executors
async executors for testing
-
pi_async
Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
-
peace_rt_model
Runtime data types for the peace automation framework
-
tokio_based
BASED Async Single-threaded Execution Dispatcher
-
cargo-depsize
Rust cargo utility that calculates and displays the total size of each dependency in your Rust project
-
hybrid-logical-clock
Hybrid Logical Clocks for distributed systems
-
truba
The minimal tokio runtime based actors for Rust
-
futures-delay-queue
Async delay queue backed by async-std and futures-timer
-
readwrite
Combine Read and Write into a single Read+Write object
-
ksoft
KSoft.SI api wrapper written in pure Rust
-
async-fs
Async filesystem primitives
-
taski
async task DAG execution
-
twilight-standby
filter wait for filtered incoming events for the Twilight ecosystem
-
slings
A small async runtime based on io-uring for Rust
-
islabtech-upw-sensor-v1
Rust client library for remote control of the ISLabTech UPW Sensor v1
-
async-rate-limit
Common traits for rate limiting and implementations in async contexts
-
rspack_futures
rspack futures
-
async-waitgroup
Golang like WaitGroup implementation that supports both sync and async Rust
-
aiven_rs
sdk to interact with aiven-cloud apis
-
futures-ticker
An asynchronous recurring time event
-
tokio-lxi
LXI protocol abstractions for Tokio
-
cyberex
Utilities Library
-
space-traders
Async SpaceTraders API client for Rust
-
ply_jobs
ability to run background jobs on a schedule
-
rendezvous
Easier rendezvous channels for thread synchronization
-
kafka-rs
Native Rust Kafka client, built upon kafka-protocol-rs and Tokio
-
tokio-serde-cbor
Integration of serde_cbor into tokio-io, to allow sending CBOR encoded frames across network (and possibly through other transports)
-
l337
connection pooler
-
zephyrus
A slash-command framework meant to be used with twilight
-
sonor
controlling sonos speakers
-
noosphere-collections
Collection data types that are needed by an efficient implementation of Noosphere's IPLD data structures
-
tbot
Make cool Telegram bots with Rust easily
-
baildon
B+Tree library
-
tokio-file
Asynchronous file I/O for Tokio
-
slim-futures
Asynchronous tools that intends for smaller binary size
-
flurx
Create reactive asynchronous data flow
-
async-injector
Reactive dependency injection for Rust
-
maelstrom-util
by non-WASM Maelstrom libraries and binaries
-
embedded-io-convert
Convert embedded-io-async types back to futures ones (nightly only)
-
tokio-shared
Share tokio Runtime bwtween dylibs
-
felicia
service for accessing and sharing lists of bad actors
-
libevent-sys
Rust FFI bindings to the libevent library
-
awak
A small async runtime for Rust
-
async-blocking-stdio
std::io::std{in(), out(), err()} but async
-
ruchei
working with many streams
-
eventastic_postgres
An example postgres event store for eventastic
-
hollywood
actor framework
-
situwaition
Run a closure continuously, until is succeeds or times out
-
kioto-serial
Provide serial port I/O using tokio
-
async_tasks_recorder
A struct for recording execution status of async tasks with async methods
-
sn_consensus
Safe Network Membership: Enables nodes to dynamically join and leave a section
-
pollable-map
Utilites for storing futures and streams in as a pollable map
-
agnostik
Executor Agnostic Runtime that can run your futures with your favourite Executor
-
async-compat
Compatibility adapter between tokio and futures
-
parquet-format-async-temp
Temporary crate containing thrift library + parquet definitions compiled to support read+write async
-
napmap
Async HashMap that halts requester tasks until the requested data is accessible
-
async-fuse
Helpers for fusing asynchronous computations
-
taskalicious
Common Rust task workers
-
kumoko
asynchronous server/client crate built on tokio for easy two-way streaming
-
proxy-scraper
command-line tool for scraping proxy information
-
lua_actor
Lua Actor for Rust(sync/async)
-
prometheus-utils
built on top of the prometheus crate
-
rspl
A stream processor language
-
multi-readers
Combining multiple readers
-
replay-channel
A broadcast channel where new receivers replay all past messages before receiving new ones
-
lichess-api
client for Lichess API v2.0.0
-
ref_count
Efficient, low-level asynchronous synchronization for real-time and embedded systems
-
iroh-io
async local io
-
fil_builtin_actors_builder
WASM builder for builtin Filecoin actors
-
async-sleep
Async Sleep
-
ianaio-dialogs
Convenience crate for working with dialogs in browser
-
stund
An SSH tunnel maintenance daemon
-
async_zip_futures
An asynchronous ZIP archive reading/writing crate using futures-rs
-
rx_rust_mp
A protoype implementation of the ReactiveX API in Rust using a message passing approach
-
moxie
Incremental runtime for interactive software
-
peace-performance
osu! pp & stars calculation. Peace edition
-
yield-now
Wakes current task and returns Poll::Pending once
-
woven
set of async combinators, usable in a no_std environment
-
async-task
Task abstraction for building executors
-
tower-amqp
Framework for building AMQP workers with tower
-
diazene
Actor for Rust (with Tokio)
-
tor-log-ratelim
Facility for rate-limiting log messages in Arti
-
elegant-departure
simplify graceful shutdown
-
selectme
A fast and fair select! macro for asynchronous Rust
-
stop-token
Experimental cooperative cancellation for async Rust
-
hala-io
hala asynchronous io programming primitive types
-
goods
Async assets system
-
scipio
A set of utilities to allow one to write thread per core applications
-
futures-yamux
The yamux protocol implementation, rewritten from the ground up
-
kioto-uring-executor
multi-threaded wrapper around tokio-uring
-
hypixel_api
Generic wrapper around the hypixel api (automatic rate-limiting on client-side)
-
clia-rcproxy
A lightweight, fast and powerful Redis Cluster Proxy written in Rust
-
rust-concurrent
Fast command line app in rust/tokio to run commands in parallel. Similar interface to GNU parallel or xargs.
-
reactor-trait
A collection of traits to define a common interface across reactors
-
miau
Async aware and extensible layered configuration system
-
async-wormhole
Async calls across non-async functions
-
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) -
zookeeper-cache
ZooKeeper client cache
-
corcovado
Non-blocking IO library
-
async-native-tls-2
Native TLS using futures
-
actix-daemon-utils
Daemon Utilities by actix
-
xjbutil
A xjbly created utility library for my own use
-
adventure
your great adventure for the various type of requests
-
stakker_mio
Mio I/O polling integration for the Stakker crate
-
task-motel
Opinionated (Tokio) task manager with nested task groups and stoppable tasks
-
heph
actor framework based on asynchronous functions
-
futures-ratelimit
Bounded flavors of futures' FuturesUnordered and FuturesOrdered
-
any-mpsc
An mpsc that allows arbitrary types to be passed through
-
async_logger
Asyncronous logger allows writing arbitrary slices to a memory buffer, which then processed by a writer in it's own thread
-
oneshot-handshake
providing a symmetric one time use channel type
-
async-global-executor
A global executor built on top of async-executor and async-io
-
popol
Minimal non-blocking I/O
-
acu
building asynchronous actors
-
textmode
terminal interaction library backed by a real terminal parser
-
overclock
A framework for building data-driven distributed systems
-
foreback
Future adapters for running aditional work in the background
-
roux-stream
A streaming API for the roux Reddit client
-
tiny_kafka
A tiny Kafka client library with producer and consumer functionalities
-
webhttp
-
dialectic
Transport-polymorphic, asynchronous session types for Rust
-
extreme
Extremely boring async function runner. MIT/Apache-2.0 license is available for spacejam's github sponsors.
-
wrtc
Wrapper around webrtc-rs library, focused on developer experience
-
fure
Retrying futures using different policies
-
pingora-timeout
Highly efficient async timer and timeout system for Tokio runtimes
-
curseforge
A straightforward asynchronous wrapper around the CurseForge Core API. Public API is subject to change before 1.0.0.
-
async-gcode
An async gcode parser for no_std targets
-
negahban
🧐 A simple file watcher, based on
notify, designed to be fast, easy-to-use and async friendly -
txn
A generic optimistic transaction manger, which is ACID, concurrent with SSI (Serializable Snapshot Isolation)
-
night
A scalable Task Queue for executing asynchronous tasks in topological order
-
cb_fut
Call function that return value via callback without a callback
-
swimos_downlink
SwimOS Downlink Runtime
-
io-pipe
A fast and thread-safe library for creating multi-writer and single-reader pipelines in Rust
-
futures-async-stream
Async stream for Rust and the futures crate
-
simpl_actor
tokio actors
-
futuresdr-types
Polymorphic Types for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
madsim-real-tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
shutdown-handler
A shutdown handler that allows all parts of an application to trigger a shutdown
-
metatrait
RPITIT Monads
-
futuristic
Extensions to the futures crate
-
luis_sys
FFI bindings for Microsoft LUIS API
-
gw2api-rs
An asynchronous wrapper for the official Guild Wars 2 API
-
ksqldb
A thin wrapper around the KSQL DB REST API to make it more ergonomic to work with
-
event-source
Zero cost async immediate event dispatching
-
didcomm-rs
DIDComm messaging v2 specifications implementation: https://identity.foundation/didcomm-messaging/spec/
-
tokio-zmq
Futures abstractions for ZeroMQ on the Tokio event-loop
-
passivized_docker_engine_client
Docker Engine Client - manage and run containers, images, and volumes
-
mamenoki
Complete implementation of a Beanstalkd client based on the Tokio runtime
-
thin_main_loop
Thin, cross-platform, main event loop. A building block for native GUI applications, among other use cases.
-
pirates
async RPC lib
-
futures_ringbuf
Mock Type implementing AsyncRead/AsyncWrite for testing and examples
-
capp
Common things i use to build Rust CLI tools for web crawlers
-
callbag
spec for reactive/iterable programming
-
future-local-storage
An init-once-per-future cell for thread-local values
-
mini-c-ares-resolver
An asynchronous DNS resolver, backed by mini-c-ares
-
act-zero
Ergonomic actor system
-
backie
Background task processing for Rust applications with Tokio, Diesel, and PostgreSQL
-
nsq-client
Rust client for the NSQ realtime message processing system
-
futures-io
The
AsyncRead,AsyncWrite,AsyncSeek, andAsyncBufReadtraits for the futures-rs library -
tls-api-2
TLS API without implementation
-
rocketmq-rust
Unofficial Rust implementation of Apache RocketMQ
-
rabbit_borough
Create a RabbitMQ consumer project with minimal effort, by bypassing templating, configuration and complicated resiliency logic
-
gcal_rs
A blazingly fast, hand written Google calendar API in Rust
-
reusable-box-future
A reusable
Pin<Box<dyn Future<Output = T> + Send>> -
extern_executor
Async executor which delegates futures polling to external event-loop
-
telegram-bot-ars
creating Telegram bots
-
danube-client
The async client for Danube Pub/Sub messsaging platform
-
verge
An experimental actor library
-
pw-telegram-bot-fork
creating Telegram bots
-
makepad-futures-legacy
Makepad futures legacy
-
terminusdm
Terminus Download Manager. Download files, resume interrupted downloads, and keep a history of your downloads - within terminal UI.
-
compio-fs
Filesystem IO for compio
-
futures-test
Common utilities for testing components built off futures-rs
-
cannyls_rpc
RPC library for operating cannyls's devices from remote nodes
-
tk-listen
A set of helper futures allowing to listen TCP (or unix) socket with resource limits and proper error handling
-
async_shared
signal implementation
-
pcap-async
Async/Stream Extensions for libpcap
-
starbase_events
Async and mutable event system
-
puff-rs
Puff - Deep Stack Python Runtime and GraphQL library
-
tokio-sync2async
Helpers to bridge between sync and async code
-
async-time-mock-smol
Mockable time for use in async runtimes (smol compatibility)
-
stun-client
async_std based asynchronous STUN client library
-
naumi
Lightweight and fast data transfer protocol. Fast de/serialization and tiny size!
-
monoio-compat
A compat wrapper for monoio
-
merge-streams
Merge multiple streams into one
-
deluge
A highly concurrent stream library driving the underlying futures either concurrently or in parallel to process streaming operations as quickly as possible
-
futures-sink
The asynchronous
Sinktrait for the futures-rs library -
dioxus-v04-optional-hooks
Optional futures for Dioxus 0.4.0-0.4.3
-
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.
-
futures-stream-ext
Asynchronous stream extensions for the futures(-core) crate
-
metalmq
server
-
cbsk_socket_rayon
socket callback tool by rayon
-
arangoq
An AQL query builder layer and ArangoDb client for rust
-
timeware
timer used to schedule execution of closures at a given timestamp
-
tokio-uring
io-uring support for the Tokio asynchronous runtime
-
async-gen
Async generator in stable rust using async/await
-
cbsk_run
async pool tool
-
maelstrom-node
Maelstrom Rust node framework
-
pi_async_buffer
Asynchronous Buffer for IO
-
flo-state
Lightweight actor library
-
rumqttlog
kafka inspired rumqtt's mqtt commitlog
-
murray
A minimal actor definition macro using Tokio
-
napi_async_local
Extends napi-rs with the ability to run local futures
-
tourniquet
Async native round-robin manager for remote services
-
atticus
A mimimal API to create asynchronous actors
-
viaduct
A duplex communication channel between a parent and child process, using unnamed pipes
-
abstract-ns
Abstract name service traits for use with futures (and tokio)
-
async_msp_cli
Async msp cli for iNav and BetaFlight
-
libaio-futures
Straightforward Linux AIO using Futures/async/await
-
rabbit_mqr
Extremely Simplified RabbitMQ Client
-
actix-rt
Tokio-based single-threaded async runtime for the Actix ecosystem
-
emitter_runtime
Runtime support for rs-event-emitter
-
async-sse
Async Server Sent Event parser and encoder
-
aral
Async Runtime Aggregation Layer
-
safina-timer
Safe async timers - ARCHIVED: Code moved to
safinacrate -
msq
legacy Master Server Query Protocol
-
lazy_async_pool
An asyncronous object pool that generates objects on the fly
-
libmqm-sys
IBM® MQ Interface (MQI) and MQ Administration Interface (MQAI) bindings
-
stream-broadcast
Runtime independent broadcast, which only polls it's underlying stream if no pending data is available
-
xilinx-dma
Userspace Xilinx AXI DMA Interface
-
monoio-native-tls
Asynchronous TLS streams wrapper for Monoio based on NativeTLS
-
async-lazy
A value which is initialized on the first access, with an async function
-
sigio
signal-based async io
-
actix-interop
Use async/await syntax with actix actors
-
deadqueue
Dead simple async queue
-
circulate
Lightweight PubSub framework that supports both sync and async
-
rants
An async NATS client library
-
saas-zmq
ZeroMQ tools by using Publish-Federation
-
tokio-graceful-shutdown-without-anyhow
perform a graceful shutdown on a Tokio based service
-
kompact
Kompics component model combined with the Actor model
-
async-ctrlc
Async wrapper of
ctrlc -
async-http1-lite
Asynchronous http1 stream
-
plumbing
An async abstraction to pipeline requests through a channel
-
msft-runtime
Windows async helpers
-
fluke-io-uring-async
An abstraction on top of io-uring
-
stream-ext
An extension trait for Streams that provides a variety of convenient combinator functions
-
async-recorder
Store records without waiting for your persistence backend
-
hydra-websockets
A websocket server for the hydra framework
-
simple_spawn_blocking
spawning blocking tasks more ergonomic
-
io_tee
Tee Read, BufRead, and Seek instances to a writer
-
packet-ipc
Share packets between services using servo ipc
-
handoff
An unbuffered, asynchronous, single-producer/single-consumer channel
-
cntrlr
async embedded framework
-
rusty_tarantool
Tarantul async client based on tokio framework
-
tokio-shutdown
Wait for a stop signal across multiple threads
-
smolscale
A high-performance async-task scheduler
-
random-access-storage
Abstract interface to implement random-access instances
-
stream_router
A Future aware router to dynamically route between Streams and Sinks
-
automerge_repo
automerge-repo
-
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
-
tobytcp
A little library for sending messages over a tcp stream
-
tiny_future
Condvarbased future with automatic cancellation on drop -
callback-result
Assists in converting the callback function's method of obtaining results into the await method
-
side-futures
Send future for execution on the runtime that may be in a different thread
-
signalfut
A future similar to tokio::signal::unix::Signal, but can be used with all the runtimes
-
tarpc-trace
foundations for tracing in tarpc
-
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
-
fundamentum-sdk-api
HTTP client targeting Fundamentum IoT devices RestAPI
-
safina-threadpool
Safe thread pool - ARCHIVED: Code moved to
safinacrate -
fork_stream
Clone any stream
Swhere<S as Stream>::Item: Clone -
tokio-easy-timer
A tokio-based task scheduler, with a user-friendly API
-
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
-
puteketeke
An asynchronous runtime built on smol
-
openai-api
OpenAI API library for rust
-
async-nats-tokio-rustls-deps
Fork of Asynchronous TLS/SSL streams for Tokio using Rustls
-
actix-signal
Manage the lifecycle of an actix actor with its address
-
smol
A small and fast async runtime
-
must_future
A wrapper future marked must_use - mainly to wrap BoxFutures
-
queen
message queue
-
async-minecraft-ping
An async Rust client for the Minecraft ServerListPing protocol
-
black-box
A minimal actor framework
-
tokio-async-drop
macro to enable async drop in a tokio multithreaded runtime
-
veilid-async-tungstenite
Async binding for Tungstenite, the Lightweight stream-based WebSocket implementation
-
rt-local
Thread local asynchronous runtime working with platform-specific event loops
-
stream-guard
RAII wrapper around Stream that invokes a custom action on drop
-
visiting_ref
Container types that asynchronously return ownership of a value to another context upon exiting scope
-
radix-router
Rust port of httprouter
-
awaitable
type with input and output that can be stored in container
-
swarm-commander
Manage tons of commands asynchronously
-
gritlab
Gitlab rust API sdk
-
spaad
Zero boilerplate actor systems with xtra
-
mqtt_actor
An mqtt adapters (from port and adapters) to be used with actix actors
-
monoio-thrift
Thrift for Monoio
-
parity-runtime
Tokio runtime wrapper
-
futures_cbor_codec
A codec for framing an AsyncRead/AsyncWrite with cbor for all types that are serializable with serde
-
prevayler-rs
System prevalence in rust
-
async-xml
deserializing XML data asynchronously
-
terminal-wait-exit
wait user exit terminal, like Ctrl+C
-
hls_lfcd_lds_driver
Rust driver for ROBOTIS HLDS HLS-LFCD-LDS (LDS-01)
-
pick_action_from_image
Pick an action from an image
-
nyantrack-common
Common data types and functionality for NyanTrack
-
bb8-bolt
A bolt-client adaptor for the bb8 connection pool
-
lifeline
dependency injection library for asynchronous message-based applications
-
mediator
pattern in Rust
-
nextgraph
client library. Nextgraph is a decentralized, secure and local-first web 3.0 ecosystem based on Semantic Web and CRDTs
-
teloxide-core
Core part of the
teloxidelibrary - telegram bot API client -
read-progress-stream
Stream reader wrapper that tracks the number of bytes read
-
bp3d-threads
threading library intended to simplify concurrency in BP3D
-
selecting
Cross-platform wrapper over select
-
untokio
Automatically create tokio runtimes
-
async_singleflight
Async singleflight
-
streamline
Reversible futures::Stream-based state machines
-
continue
Swift-style continuation API
-
susync
An util crate to complete futures through a handle. Its main purpose is to bridge async Rust and callback-based APIs.
-
eyeball-im-util
eyeball-im -
simple-scheduler
Schedule periodic tasks to run asynchronously
-
blec
cross-platform ble client library based on btleplug
-
dyn-timeout
Dynamic timeout, cancel, add and remove time before a callback execution
-
async-mq
Zero-cost async-await abstraction of lapin AMQP client crate
-
riker
Easily build fast, highly concurrent and resilient applications. An Actor Framework for Rust.
-
pochta
Addressable channel registry
-
zellij-utils
Zellij client and server
-
in-keys
utilizing streams in a convenient
Terminalconstruct -
proxycurl-linkedin-rs
client for the Proxycurl LinkedIn API
-
peace_rt_model_native
Runtime data types for the peace automation framework
-
orsomafo
Event dispatcher crate
-
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
-
ordered-stream
Streams that are ordered relative to external events
-
streamcatcher
A thread-safe, shared (asynchronous), almost-lockless stream buffer
-
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. -
async-send-fd
A wrapper for async UnixStream's to send file descriptors
-
blocker
Block rust futures to create a synchronous wrapper around an asynchronous api
-
stow
Cloud storage abstraction package for Rust
-
linked-futures
Link futures into a block, which stops all of the included futures when any of the futures complete
-
rlua-async
Async support for rlua, via coroutines
-
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-sgxtarget -
mikrotik_api
& minimal client to connect and interact with Mikrotik RouterOS API, usually exposed on port 8728
-
tracing-orchestra
Give me more instruments!
-
sender-sink
classes for working with tokio UnboundedSender and the Sink trait
-
ruchei-route
Sinks with routes
-
tokio-lk
Futures-aware lock-by-id primitives
-
pantry
Temporary storage for reusing values that may decay
-
this-state
way to store state in a thread-safe manner as well as a way to asynchronously wait for state changes
-
wasmflow-packet
encapsulating the message packets sent across Wasmflow components
-
auto-future
For quickly making a struct into a future via an async fn
-
async-mavlink
An async adapter for mavlink conections
-
bean_factory
bean factory,support inject reference bean
-
tokio-socks
Asynchronous SOCKS proxy support for Rust
-
nonblock
Read available data from file descriptors without blocking (e.g. sockets, streams, child stdout, named pipes)
-
parallel-stream
Data parallelism library for async-std
-
qbit-api-rs
A asynchronous Rust wrapper for qBittorrent Web API
-
tokio-libtls
Tokio bindings for LibreSSL's libtls
-
tokio-stream-multiplexor
Stream Multiplexor for tokio with a tcp like interface
-
tauri-specta
Completely typesafe Tauri commands
-
gentian
proc macro that transforms generators to state machines
-
csnmp
Community-based async (Tokio) SNMP client library
-
rexecutor
A robust job processing library
-
task-collection
Types for managing and waiting on groups of tasks
-
peekable
reader and async reader, which enhance your network programming experience
-
tracing-actix
Allow tracing actor futures in actix
-
streammap-ext
StreamMap of Tokio with altered
nextthat returns when stream is dropped -
test-with-tokio
attribute macro for tests using tokio with cases and async guards
-
coachman
rust asynchronous task manager built on top of tokio framework
-
smartsheet-rs
Async Smartsheet API implementation in Rust
-
tenorite
A concurrency abstraction library. Provides a client-server model for asynchronous workers
-
async-copy-progress
Asynchronous copying with progress callbacks
-
mias_channel
that supports bi-directional channels by wrapping others
-
streams
A collection of stream-extensions that are missing in the
futurescrate -
snarc
Sendable Non-Atomically Reference Counted
-
rasio-mio
a RASIO drivers implementation base on mio
-
zookeeper-cache-rust
ZooKeeper client cache
-
dabus
Dynamic Aplication Controll Bus - an asynchronous, event based module system for thoes who want to move fast and *not* break things
-
rumpsteak
Session types for asynchronous communication between multiple parties
-
fb_futures_01_ext
Extensions for future 0.1 crate
-
async-notify
A general version async Notify, like
tokioNotify but can work with any async runtime -
activitystreams-types
Base types from the Activity Streams spec
-
swimos_messages
SwimOS Runtime Internal Messaging Protocol
-
async-dispatcher
async runtime based on a pluggable dispatcher
-
tidy-browser
Tidy up browser information
-
async_progress
Create sync points across async tasks
-
loading-bytes
Load bytes from paths on native and WASM
-
background-jobs-tokio
in-process jobs processor based on Tokio
-
pymedusa-zip
A PyOxidizer interface to high-performance parallelized implementations of common zip file operations
-
zusammen
Download files in parallel
-
limitation
A rate limiter using a fixed window counter for arbitrary keys, backed by Redis
-
speedracer
racing futures and ranking the results
-
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.
-
waitgroup
Async waitgroup for a collection of task to finish
-
evdev-shortcut
Global shortcuts using evdev
-
backoff-tower
A tower layer to apply a backoff strategy to retried requests
-
dialectic-compiler
Session type macro compiler for the Dialectic crate
-
patchable-async-sleep
An async sleep function, patchable to the preferred runtime
-
taps
taps (Tokio Asynchronous Pub/Sub) is an in-process async message broker that can be used for messaging between spawned tokio tasks
-
apalis-cron
extensible library for cron-like job scheduling for rust
-
netty-rs
allows exposes a simple-to-use API used to create stateful application level network protocols as both a client or server
-
simple-middleware
General purpose middleware crate
-
tokio-process-stream
that wraps a tokio::process into a tokio::stream
-
mpc-bench
Multi-party computation experimentation library
-
wasmer-wit-bindgen-rust
wit-bindgen-gen-c
-
piston_rs
An async wrapper for the Piston code execution engine
-
bipe
asynchronous I/O pipe
-
rust-rsm
RSM:A Realtime Software Middleware framework. Asynchronous, event driven framework
-
futures-executor
Executors for asynchronous tasks based on the futures-rs library
-
co_managed
Create managed sub coroutines. Managed sub coroutines will be cancelled when the parent exit
-
raftlog
distributed replicated log based on the Raft algorithm
-
tokio-stdin-stdout
Thread- and future::sync::mpsc-based AsyncRead/AsyncWrite stdin/stdout with little buffering
-
js-sys-futures
working with the futures and js-sys crates
-
async_monad
Asynchronous monad for rust
-
heph-inbox
Bounded capacity channel designed to be used as inbox for actors. Also supports one shot channels.
-
dstream
DelayedStream - delays items and drops same items coming within given interval
-
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…
-
specta
Easily export your Rust types to other languages
-
zeebe
client for defining, orchestrating, and monitoring business processes across microservices using Zeebe
-
tokio-switching-sleep
A tokio Sleep with a switchable state
-
blocking-permit
Permits and a thread pool for blocking operations
-
async-rayon
Mix async code with CPU-heavy thread pools using Futures + Rayon
-
async-log
Async tracing capabilities for the log crate
-
dagrs
The DAG engine, named dagrs, is designed to execute multiple tasks with graph-like dependencies. It offers high performance and asynchronous execution, providing a convenient programming interface for Rust developers.
-
bufstream
Buffered I/O for streams where each read/write half is separately buffered
-
tokio-stomp-rs-rs
Asynchronous streaming STOMP client fork
-
async_object
Async Object wrapper
-
futures_codec
encoding and decoding frames using
async/await -
paperless-rs
An asynchronous Rust library for the Paperless-ngx document manager
-
multiqueue2
A fast mpmc broadcast queue
-
dyn-future
Convenient and fast dynamic Futures for Rust
-
rust-moysklad
Framework for moy sklad
-
openaction
creating plugins for the OpenAction API
-
libsync
containing channels and other synchronisation object implementations
-
bastor
A wrapper helps implementing actor with Bastion more easier with self-implemented state
-
heim-cpu
Cross-platform CPU information
-
async-time-mock-async-std
Mockable time for use in async runtimes (async-std compatibility)
-
mini-c-ares
A minimal Rust wrapper for the c-ares library, for asynchronous DNS requests, based on rust-c-ares
-
quick_crawler
QuickCrawler is a Rust crate that provides a completely async, declarative web crawler with domain-specific request rate-limiting built-in
-
xtra-addons
Add-on functionality (Broker, Registry) for crate xtra
-
deferred
help perform deferred execution of code logic
-
try-again
Retry synchronous and asynchronous operations
-
pakr-fsm
Template to implement finite-state-machines
-
pangotls
TLS Reverse Proxy using Tokio and Rustls
-
futures-net
The futures-net library
-
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…
-
cs-utils
Common utilities
-
tokio-stomp
Asynchronous streaming STOMP client
-
compio-net
Networking IO for compio
-
epicenter
synchronous and asynchronous event dispatcher for Rust
-
event-listener-strategy
Block or poll on event_listener easily
-
tokio-childstream
Convert a tokio::process::Child into a Stream for stdout, stderr, and exit events
-
fut_rwlock
A read-write lock that is read and written via Futures
-
happyeyeballs
Happy Eyeballs implementation in Tokio (not RFC compliant atm)
-
deadpool-lapin
Dead simple async pool for lapin
-
arti-rpcserver
Backend functionality for Arti's RPC service
-
eventsource-stream
A basic building block for building an Eventsource from a Stream of bytes
-
key-lock
mutual exclusion by keys
-
tezaursapi
api wrapper for tezaurs.lv
-
async-variadic
async variadic functions in Rust with trait bounds
-
peermerge
Manage JSON-like documents with multiple writers, without a central authority, using a P2P protocol
-
switchboard
Enables inter-process communiucation via queues and wakers
-
maybe-future
Future that can be None
-
buffer-unordered-weighted
Stream::buffer_unordered where each future can have a different weight
-
actix-raft
Raft distributed consensus protocol using the Actix actor framework
-
openai-api-fork
OpenAI API library for rust
-
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
-
kay
Experimental high-performance actor system framework for Rust
-
contained-actors
contained is a research project implementing the proposed harmonic runtime for orchestrating cloud-native systems
-
wag
Go like sync.WaitGroup implementation in Rust. (sync/async)
-
reception
creating TCP listeners that spawns clients providing model abstraction layer
-
rio_rt
A minimal async runtime with an experimental ambition to be an portable and interoperable async runtime for Rust
-
async-anyhow-logger
An easy crate for catching anyhow errors from an asynchronous function, and passing them to your logger
-
enstream
Conversion from Future to Stream
-
io-tubes
functionality like pwntools tube for async io in rust
-
amqp-lapin-helper
rust lapin helper
-
viz-utils
Viz utils
-
webrocket
A closure focused WebSocket server implementation
-
signalr_rs
SignalR client based on actix web client and async await
-
just-watch
Async watch channel
-
pipestream
Async support for pipe or something has file descriptor
-
async_dataloader
Powerful tool for avoiding N+1 queries using async/await, based on the DataLoader pattern
-
pingora-rustls
RusTLS async APIs for Pingora
-
tokio-rusqlite
Asynchronous handle for rusqlite library
-
swait
Blocking on Futures
-
acril-rt
A lightweight single-threaded runtime for Acril actors
-
csv-async
CSV parsing for async
-
io_uring_buf_ring
Help user create and manage io-uring buffer-ring
-
stream-kmerge
K-way merge for streams
-
laizy
stable and thread-safe implementation of a lazy value
-
agner-sup
An actor toolkit inspired by Erlang/OTP (supervisors)
-
named-retry
retrying fallible asynchronous operations
-
io-tether
Traits for defining I/O objects which automatically reconnect upon failure
-
stellwerksim
Rust SDK for StellwerkSim
-
gossip-relay-picker
A relay picker for nostr, used by gossip
-
futwaiter
The container of Future's that has the ability to complete them all at once
-
async-select-all
A futures library adapter for selecting over a list of futures
-
luarmor
API wrapper for luarmor.net
-
pseudoterminal
A cross-platform pseudoterminal implementation with async support
-
tokio-nsq
NSQ client built on Tokio. Tokio NSQ aims to be a feature complete NSQ client implementation.
-
agreed
Fork of async-raft, the Tokio-based Rust implementation of the Raft protocol
-
qp
Quick Pool: High Performance Async Generic Pool
-
git-event
Customizable event handler for updates in remote git repositories
-
salvia
Incremental computing brought to async Rust
-
async-result
wrapper providing a convenient way to await a result, built on futures-channel's oneshot channel
-
srmw
Asynchronous single-reader, multi-writer
-
mak
but mak it faster
-
stream_generator
Allows to easily generate streams with async/await
-
bme280-rs
query BME280 sensors over I²C
-
awesome-operates
A reposity includs many common use code utils
-
simple_futures
futures for use in async operations
-
rexecutor-sqlx
A robust job processing library
-
russh-agent
Asynchronous ssh-agent client
-
rad
A type-safe, high-level interface to librados using the low-level C bindings from ceph-rust
-
alopecosa
Pure rust async Tarantool 1.6+ connector built on tokio
-
madsim-tokio
The
tokiosimulator on madsim -
enfync
Environment-friendly async utilities
-
tinkoffpay
tinkoff integration (the seller receives a link to the payment form and redirect the buyer to it); NB: with callback method
-
newsblur_api
NewsBlur-API
-
Agentic-rs
agentspackage 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… -
clap-and-async-test
Is a example to use clap with tokio and futures, how run concurrently some functions with a loop inside
-
f289ctrl
Communication library for Fluke 289 digital multimeter
-
tokio-rustls-wasi
Asynchronous TLS/SSL streams for Tokio using Rustls
-
rtx
zero-cost runtime-abstraction intended for use by Rust libraries to enable the Freedom of Choice between asynchronous runtimes
-
toy-async-runtime
Toy library to start to work with async rust, build for reckless person!
-
pi_async_file
A async file tools library
-
cancellable
providing a generic cancellable utility
-
intercomm
Asynchronous inter-component communication library
-
future-utils
Extensions to Rust's Future and Stream traits
-
gabelung
Branch an asynchronous stream of cloneable items into two
-
quickwit-actors
Actor framework used in quickwit
-
fs-mel
Mélodium core filesystem interaction library
-
peace_rt
Runtime logic for the peace automation library
-
sparkle-impostor
A third party crate for Twilight to execute Discord webhooks that clone an existing message
-
fluvio-async-tls
Asynchronous TLS/SSL streams using Rustls
-
blockz-futures
working with futures for the tokio stack
-
async-file-lock
Asynchronous file lock that can auto lock and auto seek
-
tower-actor
A
towermiddleware that creates aServiceby passing messages to an actor -
delimiter-slice
Stream type for splitting a delimited stream
-
async-jobs
Asynchronous job orchestration for Rust
-
async-refresh
Create values that refresh automatically and asynchronously after a given duration
-
lelet
golang like task executor
-
winmsg-executor
Per-thread async rust executor for windows
-
future-clicker
Reimplementation of manual_future without using
futuresunstable -
releez
run application release-checklist safely
-
tokio-duplex
Combine seperate
AsyncReadandAsyncWritetypes into a singleAsyncRead + AsyncWritetype -
tokio-scoped
Scoped Runtime for tokio
-
arta-tokio
Async abstractions implementation for Tokio
-
xactor
actors framework based on async-std
-
openraft-rocksstore
A rocksdb based implementation of the
openraft::RaftStoragetrait -
tokio_interval
基于Tokio实现了 setInterval(callback, ms) 和 setTimeout(callback, ms) 类似于Javascript的API
-
select-next-any
Alternative to futures::StreamExt::select_next_some that returns the None variant
-
page-turner
A generic abstraction of APIs with pagination
-
amqp
AMQP/RabbitMQ protocol client
-
ndless-async
Ndless-specific integration with async/await for the TI-Nspire
-
crate-test-xxx
test crate
-
abs_art
ABStraction of Asynchronous RunTime
-
mrwei
that implements the common promise primitive for rust based on std future
-
async-ops
Use std::ops traits with Futures
-
joyent-tokio-zookeeper
Asynchronous client library for interacting with Apache ZooKeeper
-
tower-util
working with
Service -
elfo-test
Test utils for the elfo system
-
async-ssh2-lite
Asynchronous ssh2
-
croissant
A scheduling library
-
rs-copier
Copy and move files asynchronously
-
mio-uds
Unix domain socket bindings for mio
-
tokio-executor-trait
executor-trait implementation for tokio
-
serial-io
A serial port implementation
-
sched-clock
A timer for task scheduling
-
tokio-socketcan-bcm
Asynchronous Linux SocketCAN - Broadcast Manager support (BCM) with tokio
-
unblock
A thread pool for isolating blocking in async programs
-
async_timing_util
tokio async functions for waiting until even intervals (on 1 min, 5 min, 30 min, etc), or waiting until a specified timestamp
-
mlua_actor
Lua Actor for Rust(sync/async)
-
plctag-async
async wrapper for libplctag
-
containerd-snapshots
Remote snapshotter extension for containerd
-
lnd_grpc_rust
An async library implementing LND RPC via tonic_openssl and prost
-
foxhole-api
wrapper for the Foxhole War API
-
histlog
hdrhistogram crate, provides off-thread serialization of HdrHistogram interval logs to file
-
thread-async
Execute a task in a new thread and await the result asynchronously
-
broker-tokio
tokio for broker
-
multiqueue
A fast mpmc broadcast queue
-
koibumi-socks
A minimal SOCKS5 client library
-
dwbhk
dwbhk-rs is a library for working with Discord Webhooks
-
pixelflut
An async/sync Pixelflut server/client library
-
interval_future
Wraps a synchronous, waker-less polling function in an interval-based future
-
async-timers
asynchronous timer primitives
-
fb-api
Facebook Api abstraction for async rust
-
pi_weight_task
任务池
-
swimos_byte_channel
SwimOS Byte Channel
-
sntpc
making SNTP requests
-
actix-storage-sled
actix-storage based on sled
-
manual_future
A future that must be manually completed, similar to Java's CompletableFuture
-
catty
Send and await a value asynchronously
-
lib3h_zombie_actor
lib3h actor request tracking module
-
medea-reactive
Reactive mutable data containers
-
eventually-postgres
Event Store implementation using PostgreSQL for the Eventually crate
-
makepad-futures
Makepad futures
-
andiskaz
A convenience library for writing games and other apps in TUI
-
deploy
The
deploylibrary to aide writing and debugging of distributed programs, as well as tooling to run them across a cluster -
eventador
lock-free pub/sub event-bus with sync and async APIs
-
gcs-rsync
rsync support for gcs with higher perf than gsutil rsync
-
gcp_auth
Google cloud platform (GCP) authentication using default and custom service accounts
-
mobc-forked
A generic connection pool with async/await support
-
deadpool-bolt
A bolt-client manager for the deadpool connection pool
-
tokio_kcp
A kcp implementation for tokio
-
gql_client
Minimal GraphQL client for Rust
-
tag_nominatim
Bindings to the reverse geocoding API powered by openstreetmap
-
sidekiq-rs
Sidekiq compatible server in Rust
-
async-http-body
Agit init HttpBody Support Async Expressions
-
tokio-agent
Agents are a simple abstraction around state, inspired by Elixir's Agent
-
futures-zmq
Futures abstractions for ZeroMQ on any futures executor
-
wgp
waitgroup implementation
-
shared_cell
Interior mutability between concurrent tasks on the same thread
-
italo-api
Rust binding for Italo API
-
broadcaster
Broadcasting futures mpmc channel
-
prost-codec
Asynchronous de-/encoding of Protobuf structs using asynchronous-codec, unsigned-varint and prost
-
promise
future/promise library for rust
-
futures-test-preview
Common utilities for testing components built off futures-rs
-
async-openai-wasm
OpenAI on WASM
-
axum-jrpc
A JSON-RPC extractor for Axum
-
async-hid
A async library for interacting with HID devices
-
future-combinator-params
functions to inject extra arguments between futures combinators Then/AndThen
-
ruva
Event Driven Message Handling
-
awaitgroup
Wait for a collection of async tasks to finish
-
async-signal
Async signal handling
-
stackful
Bridge between sync and async
-
haiyuu
experimental actor-like library
-
browser-window
optionally async, optionally threadsafe, electron-like browser toolkit for Rust
-
async-raft
An async implementation of the Raft distributed consensus protocol
-
tokio-reactor-trait
reactor-trait implementation for tokio
-
change_stream
A Stream that only emits if the value is different
-
nanopore
A minimalist async runtime based on io_uring (Linux) and I/O rings (Windows)
-
retry_future
Retry futures mechanism
-
oc-wasm-futures
Futures that allow async/await to be used in OC-Wasm for a more ergonomic experience
-
strawpoll
A wrapper to avoid spurious polling
-
qcow2-rs
read/write qcow2 image in async/await
-
gandi-v5-livedns-api
Gandi LiveDNS Api
-
samotop
SMTP server and library built on async-std
-
hala-future
hala asynchronous programming primitive types
-
simple-tokio-watchdog
Pretty simple but bulletproof watchdog actor
-
rust-paper
Rust Wallpaper manager from ( https://wallhaven.cc/ ) for Linux/UNIX only
-
xo-api-client
Unofficial crate for accessing Xen Orchestra through its API
-
completion
writing completion-based asynchronous code
-
settimeout
Creates a std::future::Future implementation to be ready at some point
-
elfo-configurer
Loads and distributes configs across the elfo system
-
scoped_async_spawn
spawn non-static futures
-
cdrs-tokio
Async Cassandra DB driver written in Rust
-
makiko
Asynchronous SSH client library in pure Rust
-
split-stream-by
Stream extension crate for splitting a Stream into two per a predicate
-
rqlite-rs
Async rqlite client for Rust
-
messagebird-async
Wrapper around the message bird SMS API
-
async-utf8-decoder
Convert AsyncRead to incremental UTF8 string stream
-
pupactor
actor model library built with tokio
-
sync_stream
Aggregate multiple streams by polling stream items in order, keeping the consumption of multiple streams in sync
-
future_handles
complete futures via handles
-
futures-util-either
futures_util::future::Either Ext
-
crown
jewel of rust libraries
-
cocoro
A more type-safe take on Rust stackless coroutines
-
rustpub
Activitypub types
-
tasc
A minimnal, asynchronous threadpool
-
jenner
Tools for working with generators to work with both iterators and streams
-
kythera-fvm
Core implementation of the Kythera FVM
-
rxqlite-common
A distributed sqlite database built upon
openraft,sqlxandsqlite -
alligator
getting the output value from a future
-
relm
Asynchronous, GTK+-based, GUI library, inspired by Elm, written in Rust
-
tokio-stream_wasi
work with
Streamandtokio -
photonio
A runtime for asynchronous applications
-
heim-common
Common stuff shared across heim project crates
-
yaanhyy_rust
cargo mod example
-
set_timeout
allows efficiently executing futures after some delay has passed
-
anotify
Async iNotify Filesystem Watcher
-
nakadion
Types for interacting with the Nakadi Event Broker
-
async_closure
utilizes the nightly-only feature async_fn_in_trait to imitate async_closures
-
agent_rt
agent scheduling
-
tokio-uds-proto
Unix Domain sockets working with tokio-proto
-
log-tracing-layer
Build your own custom tracing layer
-
medina
An asynchronous web crawling engine
-
north-config
North config is a multi source configuration crate designed as part of the North Microservice Framework
-
remote_config
Flexible crate for asynchronously loading configuration from remote source with caching and automatic revalidation
-
futures-time
async time combinators
-
rust-gpt
interaction with the Completion/Chat OpenAI API
-
mutex-extra
RefMutex<T>that is similar toMutex<T>but isSyncandSendeven ifTisn’tSend -
tower-sessions-sqlx-store
SQLx session stores for
tower-sessions -
fsdr-blocks
Building blocks for FutureSDR signal processing library for SDR and real-time DSP
-
ebus
Basic Event Bus implementation
-
enjoin
Powerful syntax-level async join macro
-
discord_api
Interact with the Discord API from your shell
-
rocketmq-runtime
Unofficial Rust implementation of Apache RocketMQ
-
tokio-stomp-2
Unofficial successor to Asynchronous streaming STOMP client
-
c_mcai_worker_sdk
AMQP Worker to listen and provide trait to process message
-
libuio
A io_uring based async framework designed for high performance networking on linux
-
simple-async-pipe
Aims to provide a simple pipe-like functionality for async code
-
rfm69-async
async driver for the rfm69 radio transceiver
-
axum-limit
A rate limiting library using token buckets, centered around extractor-based limits for async web applications
-
fut-compat
Offers compatibility between the tokio and async_std runtimes
-
hypixel
Rust wrapper for the Hypixel public API
-
augrim
consensus algorithms implemented in Rust
-
promises
Effective, simple, lightweight Javascript promises in Rust
-
async_tasks_state_map
A struct for recording execution status of async tasks with async methods
-
async-cuda-npp
Async NVIDIA Performance Primitives for Rust
-
ringbuf-rs
in-memory ringbuf implementation
-
batchloader
A type-safe async request batcher based on facebook's dataloader
-
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
-
future-by-example
Examples of common patterns using Future
-
typout
Command-line typewriter output stream
-
async_msp_lib
Async msp library for iNav and BetaFlight
-
ardop_interface
Interface to the Amateur Radio Digital Open Protocol (ARDOP)
-
appliance
A lightweight framework to build async-friendly components with message-based intercommunications
-
rivulet
Asynchronous contiguous-memory streams
-
stream-operators
a collection of selected rxjs operators for rust standard Stream
-
async-lease
Essentially a futures-oriented Arc<Mutex<Option<T>>>
-
ruw
Read-Update-Write
-
ianaio-file
Convenience crate for working with JavaScript files and blobs
-
connection-utils
Connection related utilities
-
unsync
Unsynchronized synchronization primitives for async Rust
-
starstruck
A game building utility that is made to be simple to use while still providing great performance
-
encrypted-dns
A modern encrypted DNS server (DNSCrypt v2, Anonymized DNSCrypt, DoH)
-
embedded-executor
Embedded systems-friendly
Futuresexecutor -
termion-input-tokio
An adapter that exposes termion's input and key event iterators as asynchronous streams
-
restartables
Future that restarts an inner future if it doesn't meet a condition
-
hermod
futures-based RSS/Atom library
-
scoped_tasks_prototype
A quick-and-dirty attempt to get scoped tasks in Rust
-
stream-download
streaming content to a local file-backed cache
-
swimos_trigger
SwimOS Asynchronous Trigger
-
async-read-progress
Extension traits for inspecting
AsyncReadprogress -
streamtools
Additional stream combinators
-
futures-io-preview
The
AsyncReadandAsyncWritetraits for the futures-rs library -
tiny-jsonrpc
Json rpc lib based on reqwest
-
dynamodb-mutex
Use Dymanodb mutex library
-
kompact-actor-derive
A derive macro for Kompact Actors
-
cdp-html-shot
capturing HTML screenshots using CDP
-
heim-sensors
Cross-platform sensors information
-
smelling_salts
Abstraction over OS APIs to handle asynchronous device waking
-
allochronic-util
Private utility crate for allochronic and khonsulabs
-
smol-timeout2
A way to poll a future until it or a timer completes
-
cooper
in-process, async Actor library for Rust
-
async-ringbuffer
A nonblocking spsc ring buffer with fixed capacity
-
tigermq
Message Queue and Batch processing for Rust
-
dbus-async
Asynchronous DBus library
-
gen-stream
Generator-based streams for Rust and futures 0.3
-
futures-cache
Futures-aware cache backed by sled
-
callback-future
Adapter between callbacks and futures
-
safe-vk
create your own vk bot for conversations
-
async-graphql
A GraphQL server library implemented in Rust
-
go-zoom-kinesis
A robust AWS Kinesis stream processor with checkpointing and retry capabilities
-
asyncore
-
register-count
Counting
Registers created by aCounter -
salvo-oapi
OpenApi support for Salvo web framework
-
tokio-uring-rustls
Integrate rustls into tokio-uring
-
trillium-tokio
tokio runtime adapter for trillium.rs
-
hitbox-actix
Asynchronous caching framework for Actix
-
lunatic-distributed
Node to node communication
-
eventsourcing
Event Sourcing for Rust
-
genserver
Elixir inspired async actor library
-
agner-actors
An actor toolkit inspired by Erlang/OTP (actors)
-
asygnal
[WIP] Async-first signal handling, such as ctrl-c
-
async-dropper-simple
struct-wrapper (i.e. AsyncDropper<T>) based implementation of AsyncDrop
-
futura
Helpers for working with futures
-
folo
Runtime engine for Rust services
-
futures-websocket
A futures-based websocket implementation
-
service-io
Build your service-server fast, easy (and without hosting!)
-
requiem
Actor framework for Rust
-
gnostr-core
Replication protocol for Hypercore feeds
-
tokio_telegraf
Minimal async rust wrapper for the telegraf/influxdb protocol, based on Tokio
-
cf-turnstile
client for Cloudflare Turnstile
-
futures-timeout
that provides timeouts for futures and streams
-
atomic-actor
An
Actorwithasync fnhandlers -
raft-lite
understandable implementation of Raft consensus algorithm
-
axiom
Implements a highly-scalable and ergonomic actor system for Rust based on the best of Erlang / Elixir and Akka
-
eventific
that gives you the needed building blocks for event sourcing
-
mqttc
client for the MQTT protocol
-
try_future
Convenient short-hand for returning early from
futures-based functions -
tokio-anon-pipe
Asynchronous anonymous pipe for Windows
-
tokio-task-queue
Execute futures from a stream of futures in order in a Tokio task
-
actix-web-async-await
preview of Actix with async/await support
-
linkd
actor model framework that takes inspiration from OTP in the erlang ecosystem
-
sctp-proto
A pure Rust implementation of SCTP in Sans-IO style
-
rmp-futures
Async Rust MessagePack and MessagePack-RPC
-
geph4-aioutils
geph4
-
uid-mux
Async multiplexing library with user provided stream ids
-
rexer
Async I/O multiplexing library for rust
-
jarust
A janus client SDK in Rust
-
pingora-runtime
Multithreaded Tokio runtime with the option of disabling work stealing
-
hydrolink
Lavalink client made with tokio independent of the Discord library, used in production by Hydrogen
-
scuttlebutt
interface for kubernetes events
-
kompact-component-derive
A derive macro for Kompact component definitions
-
wasmflow-streams
encapsulating the message packets sent across Wasmflow components
-
syndicate
Syndicated Actor model for Rust, including network communication and Dataspaces
-
mio-signals
handling signals with Mio
-
cloudflare_dyndns
DynDNS client for Cloudflare
-
atcoder
A template for Rust project
-
repsheet_etl
ETL tools for repsheet
-
fbinit-tokio
detail of fbinit crate
-
rusty-gql
Schema first GraphQL Library for Rust
-
tl-async-runtime
A bad runtime impl for educational purposes only
-
asyncio-utils
Support limit,skip on AsyncRead traits
-
uds
A unix domain socket crate that supports abstract addresses, fd-passing and seqpacket sockets
-
viz-handlers
The handlers for Viz
-
syncthing
controlling syncthing file synchronization through its REST interface
-
crypto-auditing
Client library for crypto-auditing project
-
unsend
A thread unsafe runtime for thread unsafe people
-
django-query
Tools for mocking Django-style endpoints
-
tokio-rustls-fork-shadow-tls
Asynchronous TLS streams wrapper for Tokio based on Rustls
-
async-graphql-relay
Relay support for async-graphql
-
icanhazdadjoke-sdk
An SDK to interact with the icanhazdadjoke Dad Jokes API
-
serenity_ctrlc
Ctrl+C handler for serenity
-
rustmark
Extensible web application for serving Markdown-based content
-
scd4x-rs
query SCD4x sensors over I²C
-
tk-cantal
A client for cantal monitoring service. This is not for submitting metrics to the cantal. This library is for accessing metrics that cantal tracks.
-
projections
Macro-free pin projections because why not?
-
wookie
Async test/bench toolkit including single stepping executors. No-std compatible.
-
aktors
Driver for derive-aktor
-
stateful_async_worker
Asynchronous stateful worker threads utilizable as futures
-
jittr
A binary heap based jitter buffer implementation for zero latency udp/rtp streams
-
image_search
designed to search Google Images based on provided arguments
-
dtbh_interface
Interface library for the automated scanner
-
async-handle
A reference-counted async RwLock
-
iou
io_uring bindings
-
thread_runner
executing tasks concurrently
-
futures-state-stream
A version of the futures crate's Stream which returns state on completion
-
baildon-store
B+Tree CLI
-
decoyssh
A compact and portable SSH tarpit server
-
reactive-messaging
Reactive client/server communications, focused on high performance
-
tokio-pty-process-stream
wraps tokio-pty-process in order to provide a simpler API as a single stream object
-
amqp-manager
Lapin wrapper that encapsulates the use of connections/channels and creation of amqp objects
-
tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
par_io
Parallel, async file I/O library with control over memory usage with no dependencies
-
noosphere-core
Core data types of the Rust Noosphere implementation
-
mailbox_processor
A small little actor abstraction inspired by the FSharp Mailbox Processor which in turn was inspired by erlang
-
graus-db
A high-performance, thread-safe key-value embedded data store
-
vkteams-bot-cli
VK Teams Bot API CLI
-
batch-renamer
Framework and command line utilities for interactive renaming of a potentially large number of files
-
hooch
A small async runtime that's been bootlegged for my projects
-
underway
⏳ Durable step functions via Postgres
-
epoxy_streams
Base streams implementation for the
epoxy_frplibrary. Please use epoxy_frp instead. -
tower-pipeline
A Tower Service combinator that "pipelines" two services
-
async_chanx
Implement
Sinkfor some channel implementations -
futures-task
Tools for working with tasks
-
openraft-rocksstore-compat07
A example v07 compatible implementation of the
openraft::RaftStoragetrait -
citadel_io
Underlying runtime for interfacing with I/O for std/wasm targets
-
async-zeroconf
Async library for wrapping Zeroconf implemenations for use with Tokio
-
neo-email
The modern way to build emails services with Rust
-
wait-for-me
Async CountDownLatch
-
asynciter
Asynchronous iterator
-
crb-core
CRB | Composable Runtime Blocks | Core
-
safina-executor
Safe async runtime executor - ARCHIVED: Code moved to
safinacrate -
back-to-the-future
Conversions between std::future::Future and futures::Future
-
lib-wc
Will's Programming Toolbox
-
yew-interop
use javascript and css asynchrously in yew
-
rseip-cip
common industry protocol for rseip
-
sfio-tokio-ffi
An oo-bindgen model for using Tokio in an FFI environment
-
archlinux-repo
Arch Linux repositories parser
-
poolparty
Added functionality for the
futures::executor::ThreadPoolfutures executor -
coerce-redis
Redis actor persistence provider for Coerce. Supports event sourcing and snapshots
-
epoxy_frp
The Reactive Glue for Frontend Applications
-
bluest
A cross-platform Bluetooth Low Energy (BLE) library
-
tokio-netstring-trait
A trait for tokios AsyncRead to easily read netstrings from streams
-
asyncs-sync
Asynchronous runtime agnostic synchronization utilities
-
af-core
A core library and async runtime for Rust applications
-
tokio-xmpp
Asynchronous XMPP for Rust with tokio
-
idb
A futures based crate for interacting with IndexedDB on browsers using webassembly
-
iterstream
Converts Iterator into real asynchronous Stream
-
suspend
A common mechanism for suspending a thread or a Future until notified
-
runtime-loop
Runtime loop for Rust
-
twitch_comment_stream
stream comments from Twitch
-
message-sink
Message framing for AsyncRead + AsyncWrite
-
tokio-pty-process
Interact with a child process through a pseudo-TTY, asynchronously using Tokio
-
otdb
An open trivia database API wrapper
-
agnostic-lite
agnostic-liteis WASM friendly and light version ofagnostic, for users who want to write async runtime-agnostic crate -
mailfred
Process emails as an HTTP server
-
deduplicate
caching, asynchronous, request deduplication
-
tauri-plugin-polodb
A Tauri plugin to expose the PoloDB embedded database to applications
-
bawawa
Opinionated set of tools to manage and compose process executions
-
socks5-proxy
socks5 library based on tokio offering both server and client functions
-
pegy
A derive based parser generator
-
lemmy_apub_lib
A link aggregator for the fediverse
-
async_io_utilities
An asynchronous IO utilities crate powered by
tokio -
tokio-lock
Access an object from a single Tokio task
-
hentai
API wrapper for nhentai.net
-
bililive
stream-based bilibili live client library
-
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.
-
tower-sessions-surrealdb-store
SurrealDB session store. Not for direct use; see the
tower-sessionscrate for details. -
dbus-async-derive
Handler trait derive macro for dbus-async
-
openrazer
Asynchronous bindings to the OpenRazer daemon
-
transform-stream
Lightweight async stream wrapper
-
tokio-context
Contexts for cancelling asynchronous tasks using tokio
-
retry_fn
retry function with versions for blocking or non-blocking, tokio or async-std
-
redis-asio
Asynchronous Redis driver based on tokio
-
leaves
Distributed ID Allocator
-
wd_event
event system
-
async-native-tls-alpn
Native TLS using futures
-
async-acme
async ACME client for tls-alpn-01 challenge
-
oneshot-broadcast
channel that broadcasts a value once without cloning it
-
mini-tokio
basic asynchronous rust executor
-
async-rx
functions for async reactive programming
-
paranoid-hash
A Hashing Library For Those Paranoid With Their Security
-
execution-engine
Toca Execution Engine implemented using Futures and async/await
-
serviceless
actor model in rust, like actix