-
tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
mio
Lightweight non-blocking I/O
-
tokio-rustls
Asynchronous TLS/SSL streams for Tokio using Rustls
-
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
-
polling
Portable interface to epoll, kqueue, event ports, and IOCP
-
rdkafka
Rust wrapper for librdkafka
-
futures
streams featuring zero allocations, composability, and iterator-like interfaces
-
async-std
Async version of the Rust standard library
-
neon
A safe abstraction layer for Node.js
-
async-task
Task abstraction for building executors
-
bb8
Full-featured async (tokio-based) connection pool (like r2d2)
-
async-process
Async interface for working with processes
-
cucumber
testing framework for Rust, with async support. Fully native, no external test runners or dependencies.
-
multer
An async parser for
multipart/form-data
content-type in Rust -
futures-concurrency
Structured concurrency operations for async Rust
-
tokio-serial
A serial port implementation for tokio
-
minus
An asynchronous data feedable terminal paging library for Rust
-
blocking
A thread pool for isolating blocking I/O in async programs
-
pollster
Synchronously block the thread until a future completes
-
async_zip
An asynchronous ZIP archive reading/writing crate
-
ractor
A actor framework for Rust
-
monoio
A thread per core runtime based on iouring
-
want
Detect when another Future wants a result
-
paho-mqtt
The Official Eclipse Paho MQTT Rust Client Library. This is a wrapper around the Paho C library
-
futures-timer
Timeouts for futures
-
futures-lite
Futures, streams, and async I/O combinators
-
keycloak
Admin REST API
-
event-listener
Notify async tasks or threads
-
async-native-tls
Native TLS using futures
-
embassy-executor
async/await executor designed for embedded usage
-
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
-
redis-async
An asynchronous futures based Redis client for Rust using Tokio
-
apalis
extensible multithreaded background job processing for Rust
-
stream-cancel
interrupting asynchronous streams
-
tower-sessions
🥠 Sessions as a
tower
andaxum
middleware -
remoc
🦑 Remote multiplexed objects, channels, observable collections and RPC making remote interactions seamless. Provides multiple remote channels and RPC over TCP, TLS or any other transport.
-
failsafe
A circuit breaker implementation
-
async-scoped
Spawn scoped (non 'static) asynchronous futures for async_std and tokio runtimes
-
calloop
A callback-based event loop
-
futures-signals
Zero cost FRP signals using the futures crate
-
openraft
Advanced Raft consensus
-
futures-rustls
Asynchronous TLS/SSL streams for futures using Rustls
-
juniper
GraphQL server library
-
futures-locks
Futures-aware lock primitives
-
eyeball
Add observability to your Rust types!
-
madsim
Deterministic Simulator for distributed systems
-
mio-serial
A serial port implementation for mio
-
tokio-util
Additional utilities for working with Tokio
-
io-uring
The low-level
io_uring
userspace interface for Rust -
triple_buffer
triple buffering, useful for sharing frequently updated data between threads
-
unicycle
A scheduler for driving a large number of futures
-
gix-actor
A way to identify git actors
-
local-channel
A non-threadsafe multi-producer, single-consumer, futures-aware, FIFO queue
-
esrs
A Prima.it-opinionated library to achieve cqrs/es
-
tachyonix
A very fast asynchronous, multi-producer, single-consumer bounded channel
-
async-shutdown
one-stop solution for async graceful shutdown
-
tokio-pipe
Asynchronous pipe(2) library using tokio
-
pharos
Observer pattern which generates a futures 0.3 stream of events
-
hypercore
Secure, distributed, append-only log
-
motore
modular and reusable components for building robust clients and servers. Motore is greatly inspired by Tower.
-
tor-rtmock
Testing mock support for tor-rtcomapt
-
rxrust
Reactive Extensions
-
swiftide
Blazing fast, streaming document and code indexation
-
zookeeper-client
ZooKeeper async client
-
containerd-shim
containerd shim extension
-
fang
Background job processing library for Rust
-
tor-rpcbase
Low level functionality for Arti's RPC service
-
celery
Rust implementation of Celery
-
asynchronous-codec
encoding and decoding frames using
async/await
-
futures-buffered
future concurrency primitives with emphasis on performance and low memory usage
-
cassette
single-future, non-blocking executor intended for building state machines
-
async-walkdir
Asynchronous directory traversal for Rust
-
kafka
Rust client for Apache Kafka
-
tokio-retry
Extensible, asynchronous retry behaviours for futures/tokio
-
fluvio-future
I/O futures for Fluvio project
-
pi-async-rt
Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
-
tokio_wasi
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
lcode
An application of terminal write leetcode.一个终端刷力扣的应用
-
kdbplus
Dual q/kdb+ interface for API to build a shared library and an IPC client
-
c-ares-resolver
An asynchronous DNS resolver, backed by c-ares
-
nb
Minimal non-blocking I/O layer
-
mpart-async
Asynchronous (Futures-Base) Multipart Requests for Rust
-
async-graphql-value
GraphQL value for async-graphql
-
tokio_schedule
schedule tasks in tokio runtime
-
twilight-standby
filter wait for filtered incoming events for the Twilight ecosystem
-
tokio-graceful
util for graceful shutdown of tokio applications
-
tor-rtcompat
Compatibility layer for asynchronous runtimes, used by Tor
-
runtimelib
Jupyter runtime library
-
partial-io
Helpers to test partial, interrupted and would-block I/O operations, with support for property-based testing through proptest and quickcheck
-
triggered
Triggers for one time events between tasks and threads
-
stream_throttle
Stream combinator, to limit the rate at which items are produced
-
delay_timer
Time-manager of delayed tasks. Like crontab, but synchronous asynchronous tasks are possible, and dynamic add/cancel/remove is supported.
-
wg
Golang like WaitGroup implementation for sync/async Rust
-
automerge
A JSON-like data structure (a CRDT) that can be modified concurrently by different users, and merged again automatically
-
nuclei
Proactive IO & runtime system
-
tokio-test
Testing utilities for Tokio- and futures-based code
-
lazy-pool
Experimental lazy object pool
-
crosstown_bus
Event Bus with RabbitMQ for Rust
-
pinky-swear
Futures and async/await-ready Promises
-
tokio-graceful-shutdown
perform a graceful shutdown on a Tokio based service
-
rust-parallel
Fast command line app in rust/tokio to run commands in parallel. Similar interface to GNU parallel or xargs.
-
aqueue
fast speed thread safe async execute queue
-
poll-promise
Poll the result of an async operation in a game or immediate mode GUI
-
cancel-safe-futures
Alternative futures adapters that are more cancellation-aware
-
ipc-queue
FIFO queue described in fortanix-sgx-abi used for asynchronous usercalls
-
krecik
Asynchronous, parallel external service checker (and reporter), using industry standard libraries: Curl, ngHTTP2 and OpenSSL
-
reactive-mutiny
async Event-Driven Reactive Library with advanced & optimized containers (channels) and Stream executors
-
fn_graph
Dynamically managed function graph execution
-
page-turner
A generic abstraction of APIs with pagination
-
async-speed-limit
Asynchronously speed-limiting multiple byte streams
-
async-io
Async I/O and timers
-
ws_stream_tungstenite
Provide AsyncRead/AsyncWrite over Tungstenite WebSockets
-
async-event
An efficient async condition variable for lock-free algorithms
-
a10
io_uring library
-
async-socks5
An async/.await SOCKS5 implementation
-
lamellar
asynchronous tasking runtime for HPC systems developed in RUST
-
mangadex-desktop-api2
A Actix server for downloading manga, chapters, covers from Mangadex
-
another-rxrust
A different implementation than
rxRust
for easier use ofReactiveX
inRust
-
async-ssh2-lite
Asynchronous ssh2
-
filebuffer
Fast and simple file reading
-
pijul
A distributed version control system
-
poster
MQTTv5 client library written in Rust
-
actix-casbin
An Actix actor for casbin
-
service-async
A Service like tower in async style
-
dark-std
asynchronous containers build on tokio. It uses a read-write separation design borrowed from Golang
-
pptr
Type-Driven Asynchronous Actor Runtime
-
actix
Actor framework for Rust
-
tokio-io-utility
Some helper functions for tokio::io
-
ghost_actor
GhostActor makes it simple, ergonomic, and idiomatic to implement async / concurrent code using an Actor model
-
async-global-executor
A global executor built on top of async-executor and async-io
-
get_chunk
File iterator or stream with auto or manual chunk size selection
-
tokio-rusqlite
Asynchronous handle for rusqlite library
-
async-tempfile
Automatically deleted async I/O temporary files
-
miow
A zero overhead I/O library for Windows, focusing on IOCP and async I/O abstractions
-
rio
GPL-3.0 nice bindings for io_uring. MIT/Apache-2.0 license is available for spacejam's github sponsors.
-
async-dropper
The least-worst ad-hoc implementation of AsyncDrop as a Derive macro
-
interruptible
Stops a future producer or stream from producing values when interrupted
-
stakker
A lightweight low-level single-threaded actor runtime
-
effectum
An embeddable task queue based on SQLite
-
hypercore-protocol
Replication protocol for Hypercore feeds
-
mio-aio
POSIX AIO bindings for mio
-
tiny-tokio-actor
tiny actor library on top of tokio
-
mail-message
A program for easy, quick, and fault tolerant sending of emails from the command line
-
trait-variant
working with impl traits in Rust
-
xtra
A tiny actor framework
-
kcpserver
fast kcp server frame
-
hannibal
a small actor library
-
fvm_shared
Filecoin Virtual Machine shared types and functions
-
messagebus
allows intercommunicate with messages between modules
-
kube-coordinate
Kubernetes leader election using the coordination.k8s.io API
-
async_io_stream
IntoAsyncRead on steriods
-
mapped_futures
A collection of futures based on FuturesUnordered that supports insertion, removal and mutation of futures by key
-
daktronics-allsport-5000
decoders for the Daktronics All Sport 5000's serial output
-
decoyssh
A compact and portable SSH tarpit server
-
ferrisgram
An elegent rust client for the Telegram Bot API
-
mio_wasi
Lightweight non-blocking IO
-
ya-gcp
APIs for using Google Cloud Platform services
-
etcdv3client
etcdv3 client
-
suppaftp-cli
FTP command line client, based on suppaftp
-
scoped-stream-sink
Easy way to make streams and sinks
-
rocketmq-store
Unofficial Rust implementation of Apache RocketMQ
-
musicbrainz_rs_nova
MusicBrainz Rust is a utility crate for the MusicBrainz API
-
async_cache
Async refresh cache
-
mobc
A generic connection pool with async/await support
-
countio
Byte counting for std::io::{Read, Write, Seek} and its async variants from futures and tokio
-
scoped-futures
imposing upper bounds on Future lifetimes
-
kube-lease-manager
Ergonomic and reliable leader election using Kubernetes Lease API
-
hedwig
message bus for Rust
-
conogram
An async wrapper for Telegram Bot API
-
b2_backblaze
basic async library to upload small files to backblaze b2 service
-
quick-protobuf-codec
Asynchronous de-/encoding of Protobuf structs using asynchronous-codec, unsigned-varint and quick-protobuf
-
synchronized-writer
A tiny implement for synchronously writing data
-
futuresdr
An Experimental Async SDR Runtime for Heterogeneous Architectures
-
vesper
A slash-command framework meant to be used with twilight
-
pingora-timeout
Highly efficient async timer and timeout system for Tokio runtimes
-
tokio-uring
io-uring support for the Tokio asynchronous runtime
-
orsomafo
Event dispatcher crate
-
lemmy_db_views_actor
A link aggregator for the fediverse
-
springtime-di
Dependency injection framework based on automatic component discovery and runtime autowiring
-
rabbit-auto
Wrappers for lapin publishers and consumers
-
deduplicate
caching, asynchronous, request deduplication
-
vkapi2
vk api wrapper for rust
-
z_osmf
z/OSMF Client
-
xan-actor
Akka actor
-
futures-util
Common utilities and extension traits for the futures-rs library
-
irelia
wrapper around the native LoL APIs
-
speare
actor-like thin abstraction over tokio::task and flume channels
-
async_smux
Asynchronous smux multiplexing library
-
coerce-redis
Redis actor persistence provider for Coerce. Supports event sourcing and snapshots
-
tokio-scheduler-rs
JobScheduler written with tokio runtime, automatic retry, hook and custom storage supported
-
rxr
Reactive extensions for event-driven applications
-
tmq
ZeroMQ bindings for Tokio
-
syslog-rs
A native Rust implementation of the glibc/libc syslog
-
pty-process
spawn commands attached to a pty
-
winctx
A minimal window context for Rust on Windows
-
pubnub
SDK for Rust
-
containerd-shim-protos
TTRPC bindings for containerd shim interfaces
-
zookeeper-async
An async ZooKeeper client
-
blockstore
An IPLD blockstore capable of holding arbitrary data indexed by CID
-
signal-hook-tokio
Tokio support for signal-hook
-
woddle
An async, synchronized, database-backed Rust job scheduler
-
pasts
Minimal and simpler alternative to the futures crate
-
compio
Completion based async runtime
-
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)…
-
certsd
automated, asynchronous LE certificate issuer
-
coc-rs
wrapper around the Clash of Clans public API
-
fvm_actor_utils
Utils for authoring native actors for the Filecoin Virtual Machine
-
rdkafka-sys
Native bindings to the librdkafka library
-
netidx-protocols
Protocols built on top of netidx
-
enfync
Environment-friendly async utilities
-
async-event-emitter
Lightweight AsyncEventEmitter
-
s3tui
TUI application for multiple s3 account operations
-
c-ares
wrapper for the c-ares library, for asynchronous DNS requests
-
apalis-sql
SQL Storage for apalis. Use sqlite, postgres and mysql for background job processing
-
tokactor
A actor model framework wrapped around tokio
-
ntex-grpc
GRPC Client/Server framework
-
twilight-http-ratelimiting
Discord REST API ratelimiter implementations for the Twilight ecosystem
-
dataloader
Facebook's DataLoader using async-await
-
async-transmit
Trait for transmitting data to peers asynchronously
-
tokio-io-timeout
Tokio wrappers which apply timeouts to IO operations
-
hirun
A concurrent framework for asynchronous programming based on event-driven, non-blocking I/O mechanism
-
hass-rs
An async websocket client for Home Assistant
-
mini_exercism
Minimalistic Rust library to interact with the Exercism.org APIs
-
futures-bounded
bounding futures in size and time
-
stopper
an async stream and future stopper mechanism
-
monoio-codec
Codec for Monoio
-
nominatim
Bindings to the reverse geocoding API powered by openstreetmap
-
sn_sdkg
Safe Network Synchronous Distributed Key Generation: enables dealerless section key generation
-
hydra-websockets
A websocket server for the hydra framework
-
tower-batch-control
Tower middleware for batch request processing
-
graceful-shutdown
Graceful Shutdown for async code
-
async-cron-scheduler
Runtime-agnostic async task scheduler with cron expression support
-
elfo
Your next actor system
-
async-change-tracker
reactive change notifications using futures
-
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
-
coasys_juniper
GraphQL server library
-
eventuals
Eventually consistent values
-
deferred-future
模仿 jQuery.Deferred(),允许从 Future 实现类实例的外部对正在 pending 的 Future 对象进行 resolve 或 reject 处理。
-
dptree
An asynchronous event dispatch mechanism for Rust
-
spawns
Async runtime agnostic thread context task spawner for Rust
-
ultra-batch
Tokio-based library to batch and cache database queries or other data lookups
-
genawaiter
Stackless generators on stable Rust
-
bsky-cli
CLI application for Bluesky using ATrium API
-
round-based
Driver for MPC protocols
-
persway
Sway IPC daemon
-
crossbus
A Platform-Less Runtime-Less Actor Computing Model
-
local-waker
A synchronization primitive for thread-local task wakeup
-
unkey
An asynchronous Rust SDK for the Unkey API
-
drop-stream
A stream that wraps another stream with a closure that is called once it is dropped
-
embedded-runtime
A tiny async runtime for embedded devices
-
danube-client
The async client for Danube Pub/Sub messsaging platform
-
highroller
high-level rolling index that is thread-safe and guarantees cheap runtime-unique IDs
-
rexecutor
A robust job processing library
-
actix-web-flash-messages
Flash messages for actix-web applications
-
postage
An async channel library
-
stressed
Universal CLI stress tester for competitive programming
-
sacs
Async Cron Scheduler for Tokio
-
kompact
Kompics component model combined with the Actor model
-
retry-if
A tokio-compatible attribute-macro for decorating methods and functions with an exponential backoff
-
rseip
Ethernet/IP (CIP) client in pure Rust
-
lighthouse-client
Client SDK for Project Lighthouse
-
taskline
distributed task queue for Rust
-
io-tether
Traits for defining I/O objects which automatically reconnect upon failure
-
tor-log-ratelim
Facility for rate-limiting log messages in Arti
-
eventbuzz
A safe, fast, concurrent event publish/subscribe system based on tokio(async), inspired by Spring events
-
ads_client
An asynchronous, non-blocking ADS client
-
tower-sessions-redis-store
Redis session store for
tower-sessions
-
actix-mqtt-client
A MQTT client based on the actix framework
-
async-graphql-warp
async-graphql for warp
-
rustygram
minimal and blazing fast telegram notification framework for Rust
-
tokio-stream
work with
Stream
andtokio
-
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.
-
kafka-threadpool
An async rust threadpool for publishing messages to kafka using SSL (mTLS) or PLAINTEXT protocols
-
popol
Minimal non-blocking I/O
-
monoio-rustls
Asynchronous TLS streams wrapper for Monoio based on Rustls
-
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
-
fundamentum-sdk-mqtt
MQTT client targeting Fundamentum IoT's MQTT broker
-
async_zmq
Async version for ZeroMQ bindings
-
async-lsp
Asynchronous Language Server Protocol (LSP) framework based on tower
-
tools_interface
Abstractions of serveral Wikipedia/Wikimedia/Wikidata-related tools
-
disintegrate
build event-sourced applications
-
async-defer
Asynchronous Deferred Calls
-
tokio-js-set-interval
Allows you to use
setInterval(callback, ms)
andsetTimeout(callback, ms)
as in Javascript inside atokio
runtime. The library provides the macrosset_interval!(callback, ms)
andset_timeout!(callback, ms)
-
hyperbee
Peer to Peer B-tree
-
futures-finally
that executes a future after the completion of a future or stream regardless of the value or outcome
-
libmqm-sys
Native bindings to the IBM® MQ Interface (MQI) and MQ Administration Interface (MQAI)
-
rust-utils
Various utility routines used in the rust programs I have written
-
madsim-real-tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
retainer
Minimal async cache in Rust with support for key expirations
-
rustix-uring
The low-level
io_uring
userspace interface for Rust -
futures-retry
Retry your Futures and Streams!
-
async-unsync
asynchronous, unsynchronized (thread-local) channels and semaphores
-
simpl_actor
tokio actors
-
async-fuse
Helpers for fusing asynchronous computations
-
slings
A small async runtime based on io-uring for Rust
-
apocalypse
actor framework for Rust
-
stop-token
Experimental cooperative cancellation for async Rust
-
peace_resources
Runtime resources for the peace automation framework
-
async-ffi
FFI-compatible
Future
s -
fil_actors_runtime
System actors for the Filecoin protocol
-
process-lib
Cross-platform, asynchronous Rust library to run commands in pipelines
-
upstox-rust-sdk
SDK to access Upstox's Uplink v2 APIs programmatically
-
async-dispatcher
async runtime based on a pluggable dispatcher
-
resident-utils
Resident program library
-
retrier
A wasm-compatible retry library for futures
-
mobc-lapin
RabbitMQ support for the async mobc connection pool
-
aws-parameters-and-secrets-lambda
Cache AWS Secrets Manager secrets in your AWS Lambda function
-
keen-retry
-- yet powerful -- zero-cost-abstractions & zero-copy lib for error handling & recovery
-
tokio-io-rewind
rewind tokio::io::AsyncRead and tokio::io::AsyncWrite streams
-
passivized_vault_client
Vault Client - initialize and monitor Hashicorp Vault nodes
-
crossmist
Efficient and seamless cross-process communication, both synchronously and asynchronously
-
datacake
A batteries included framework for building fault-tolerance distributed data systems
-
deadqueue
Dead simple async queue
-
patharg
Treat "-" (hyphen/dash) arguments as stdin/stdout
-
lookit
Asynchronously connect to devices
-
futures-core
The core traits and types in for the
futures
library -
vmcircbuffer
Double Mapped Circular Buffer
-
llm_client
LLMs: structured text, decision making, classification, and benchmarks. A user friendly interface to write once and run on any local or API model.
-
futures-async-stream
Async stream for Rust and the futures crate
-
async_executors
Implements Spawn, SpawnLocal and SpawnHandle for commonly used executors
-
async-shared-timeout
Async timeout that can be reset and shared
-
tokio_gen_server
Elixir/Erlang-GenServer-like actor on the Tokio runtime
-
ref_count
Efficient, low-level asynchronous synchronization for real-time and embedded systems
-
wiremock_logical_matchers
Logical matchers for use with wiremock
-
taskalicious
Common Rust task workers
-
overclock
A framework for building data-driven distributed systems
-
wasmcloud-interface-factorial
Interface library for the wasmcloud factorial capability, wasmcloud:example:factorial
-
mal-api
An asynchronous MyAnimeList (MAL) API library for Rust
-
napi_async_local
Extends napi-rs with the ability to run local futures
-
git-next-repo-actor
Repository support for git-next, the trunk-based development manager
-
wgpu-async
Converts some WGPU callback methods to async methods
-
actix-multipart-rfc7578
multipart/form-data (RFC7578) for Actix
-
flo_binding
Declarative binding library for Rust
-
tcpclient
Asynchronous tcpclient based on aqueue actor
-
iroh-io
async local io
-
cbsk_socket
socket callback tool
-
async-tensorrt
Async TensorRT for Rust
-
selium-protocol
dependent crate of Selium. Do not use directly.
-
ticks
ergonomic Rust wrapper for the TickTick Open API
-
kuska-handshake
Secure Scuttlebutt handshake + boxstream library
-
anchor-chain
A statically typed async framework for building LLM-based applications
-
async-select
select!
multiplex asynchronous futures simultaneously -
tros
Your tros from tarantool TX thread to tokio(..and others!)
-
mikrotik-rs
Asynchronous Rust library for interfacing with MikroTik routers
-
fb_futures_ext
future crate extensions
-
stackfuture
wrapper around futures that stores the wrapped future in space provided by the caller
-
linemux
providing asynchronous, multiplexed tailing for (namely log) files
-
borrow_mutex
Async Rust Mutex which does not require wrapping the target structure
-
futures-batch
An adaptor that chunks up elements and flushes them after a timeout or when the buffer is full. (Formerly known as tokio-batch.)
-
async-atomic
Atomics which can be subscribed to and asynchronously notify when updated
-
delouse
will expose opinionated debugging stubs most useful for tokio based async programs
-
conva_ai
Rust SDK for using CONVA AI Copilots
-
infect
Intent/effect/task - A variation on the Model View Intent (MVI) and State Action Model (SAM) paradigms
-
kafka-rs
Native Rust Kafka client, built upon kafka-protocol-rs and Tokio
-
async-broadcast
Async broadcast channels
-
discro
DISCRete Observables for asynchronous Functional Reactive Programming (FRP)
-
cancellation-token
C#'s CancellationToken API
-
probe
Static instrumentation probes
-
irondash_run_loop
Consistent, platform-independent interface to system run loop
-
fundamentum-edge-daemon
The supported way to access Fundamentum's ecosystem from linux devices
-
tokio_based
BASED Async Single-threaded Execution Dispatcher
-
selectme
A fast and fair select! macro for asynchronous Rust
-
webex
Interface to Webex Teams REST and WebSocket APIs
-
stakker_mio
Mio I/O polling integration for the Stakker crate
-
tipsy
Cross-platform IPC for Tokio
-
simple-git
git interface for gix suitable for async context (with tokio)
-
act_rs
Act.rs is an actor library built to be used with the standard library and Tokio
-
batch-processing
A batch library for processing a list of items in parallel
-
truba
The minimal tokio runtime based actors for Rust
-
uid-mux
Async multiplexing library with user provided stream ids
-
ts3
A TeamSpeak3 Query library
-
splaycast
Stream-specific broadcast channel
-
crossword_generator
generating crossword from provided words
-
pegy
A derive based parser generator
-
fluke-io-uring-async
An abstraction on top of io-uring
-
wait-for-me
Async CountDownLatch
-
futures-scopes
Runtime agnostic, nestable, scopes for spawning non-static futures
-
remote_config
Flexible crate for asynchronously loading configuration from remote source with caching and automatic revalidation
-
async-utf8-decoder
Convert AsyncRead to incremental UTF8 string stream
-
serial-thread
Asynchronous, multithreaded serial port communication library using mpsc::cjhannels or async-channels for efficient data handling
-
streamcatcher
A thread-safe, shared (asynchronous), almost-lockless stream buffer
-
nodecraft
Crafting seamless node operations for distributed systems, which provides foundational traits for node identification and address resolution
-
tokio-muxt
Timer for a limited set of events that multiplexes over a single tokio Sleep instance
-
swimos_future
SwimOS Future Utilities
-
acts
a fast, tiny, extensiable workflow engine
-
interthread
Auto implementation of the Actor Model
-
jni-utils
Extra Utilities for JNI in Rust
-
peekable
reader and async reader, which enhance your network programming experience
-
async-executor
Async executor
-
madsim-rdkafka
The rdkafka simulator on madsim
-
async-codec
creating async codecs
-
rust-concurrent
Fast command line app in rust/tokio to run commands in parallel. Similar interface to GNU parallel or xargs.
-
read_until_slice
AsyncBufRead::read_until extension to take a slice as a delimiter instead of a single u8
-
tokio-send-fd
A wrapper for tokio::net::UnixStream to send file descriptors
-
fama
Pipeline Manager
-
future-queue
Adapters to manage a queue of futures, where each future can have a different weight
-
async-injector
Reactive dependency injection for Rust
-
space-traders
Async SpaceTraders API client for Rust
-
wayrs-utils
A collection of utils and abstractions for wayrs-client
-
constellation-internal
Common components for the
constellation
framework -
dwn
Decentralized Web Node
-
streamline
Reversible futures::Stream-based state machines
-
tokio_delayed_queue
Asynchronous delayed queue for Tokio runtime
-
mlua-luau-scheduler
Luau-based async scheduler, using mlua and async-executor
-
mfio
Flexible completion I/O primitives
-
bus_queue
Lock-free Bounded non-Blocking Pub-Sub Queue
-
moeval
a toy interpreter
-
ractor_actors
actors built with Ractor
-
sonor
controlling sonos speakers
-
ipc-rpc
A wrapper over servo/ipc-channel which provides many high level features
-
rasio-mio
a RASIO drivers implementation base on mio
-
proxy-scraper
command-line tool for scraping proxy information
-
ordered-stream
Streams that are ordered relative to external events
-
async-time-mock-smol
Mockable time for use in async runtimes (smol compatibility)
-
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
-
handle
Trait for asynchronous context pipeline
-
par_io
Parallel, async file I/O library with control over memory usage with no dependencies
-
async-native-tls-2
Native TLS using futures
-
agnostik
Executor Agnostic Runtime that can run your futures with your favourite Executor
-
async-fs
Async filesystem primitives
-
peachy
async task manager, similar to thread pool but cooler and for structs
-
parallel-future
fluent async task experiments
-
futures-ticker
An asynchronous recurring time event
-
async-rdma
async wrapper for RDMA ibvers lib
-
awak
A small async runtime for Rust
-
zookeeper-cache
ZooKeeper client cache
-
futures-ratelimit
Bounded flavors of futures' FuturesUnordered and FuturesOrdered
-
axum-limit
A rate limiting library using token buckets, centered around extractor-based limits for async web applications
-
deluge
A highly concurrent stream library driving the underlying futures either concurrently or in parallel to process streaming operations as quickly as possible
-
stream-reconnect
Stream-wrapping traits/structs that automatically recover from potential disconnections/interruptions
-
asyncified
A small library for operating on long lived sync values in an async context
-
rabbit_borough
Create a RabbitMQ consumer project with minimal effort, by bypassing templating, configuration and complicated resiliency logic
-
multishot
An async, lock-free, reusable channel for sending single values to asynchronous tasks
-
swimos_trigger
SwimOS Asynchronous Trigger
-
zephyrus
A slash-command framework meant to be used with twilight
-
wired_handler
Wired's handler library
-
next-gen
Safe generators on stable Rust
-
background-jobs-tokio
in-process jobs processor based on Tokio
-
state_machine_future
Easily create type-safe
Future
s from state machines — without the boilerplate -
replay-channel
A broadcast channel where new receivers replay all past messages before receiving new ones
-
sodium
FRP (Functional Reactive Programming)
-
async-pipes
building concurrent data processing pipelines
-
knien
Typed RabbitMQ interfacing for async Rust
-
streamunordered
An efficient async stream multiplexer
-
sparkle-convenience
A wrapper over Twilight designed to make it more convenient to use
-
tokio-rayon
Mix async code with CPU-heavy thread pools using Tokio + Rayon
-
coerce-k8s
Kubernetes discovery provider, automatically discover cluster peers hosted in Kubernetes, based on a configurable pod-selection label
-
fastcgi-client
Fastcgi client implemented for Rust
-
piscina
generic pool that supports both sync and async
-
io_uring_buf_ring
Help user create and manage io-uring buffer-ring
-
actix-rt
Tokio-based single-threaded async runtime for the Actix ecosystem
-
tokio-tower
Bridging the protocol gap between Tokio and Tower
-
scylla-rs
An async ScyllaDB driver built on an actor-model framework
-
future-local-storage
An init-once-per-future cell for thread-local values
-
kioto-serial
Provide serial port I/O using tokio
-
hollywood
actor framework
-
napmap
Async HashMap that halts requester tasks until the requested data is accessible
-
minos
Authorization library
-
mio-extras
Extra components for use with Mio
-
async_cell
A Cell<Option<T>> that you can await on
-
decrypt-cookies
A decrypt browser crate
-
maelstrom-node
Maelstrom Rust node framework
-
pwner
Process Owner crate that allows ergonomic access to child processes
-
atticus
A mimimal API to create asynchronous actors
-
stream-broadcast
Runtime independent broadcast, which only polls it's underlying stream if no pending data is available
-
fundamentum-sdk-api
HTTP client targeting Fundamentum IoT devices RestAPI
-
baildon
B+Tree library
-
tiny_kafka
A tiny Kafka client library with producer and consumer functionalities
-
tub
Async Pool
-
ng-repo
Repository library of NextGraph, a decentralized, secure and local-first web 3.0 ecosystem based on Semantic Web and CRDTs
-
selecting
Cross-platform wrapper over select
-
libctp-sys
Rust bindings to CTP API
-
tigerbeetle-unofficial
Safe high level async bindings to tigerbeetle client library
-
futures-boring
SSL streams for Futures built on top of the BoringSSL
-
gneiss-mqtt-aws
AWS IoT Core specific builders for asynchronous and threaded MQTT clients
-
terminusdm
Terminus Download Manager. Download files, resume interrupted downloads, and keep a history of your downloads - within terminal UI.
-
serviceless
actor model in rust, like actix
-
pi_async
Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
-
containerd-client
GRPC bindings to containerd APIs
-
async-rate-limit
Common traits for rate limiting and implementations in async contexts
-
smol-potat
Proc macro for smol runtime
-
slimproto
building Slim protocol clients
-
futures-io
The
AsyncRead
,AsyncWrite
,AsyncSeek
, andAsyncBufRead
traits for the futures-rs library -
tokio-shared
Share tokio Runtime bwtween dylibs
-
actix-signal
Manage the lifecycle of an actix actor with its address
-
agner
An actor toolkit inspired by Erlang/OTP
-
gcp_access_token
pure rust implimentation to get google cloud access token for servers with service account credentials
-
pausable_future
Pausable and resumable future, useful in background tasks
-
tokio-stomp
Asynchronous streaming STOMP client
-
ianaio-worker
Convenience crate for working with Web Workers
-
async_progress
Create sync points across async tasks
-
corcovado
Non-blocking IO library
-
yield-progress
Combined progress reporting and cooperative task yielding
-
Agentic-rs
agents
package provides a set of tools for creating and managing agents capable of processing text and performing specified tasks based on a given role. It leverages asynchronous… -
async-notify
A general version async Notify, like
tokio
Notify but can work with any async runtime -
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
-
egui_task_manager
Manage asynchronous easily
-
async-sleep
Async Sleep
-
ticque
Take a queue for a resource
-
nature
development support platform, it separates data definition from code, so it decouple the data from business system
-
future-iter
Iterator utils for futures
-
singleflight-async
Singleflight in async style
-
rocketmq-rust
Unofficial Rust implementation of Apache RocketMQ
-
backie
Background task processing for Rust applications with Tokio, Diesel, and PostgreSQL
-
v-common-v8
common part of the veda platform
-
mini-c-ares-resolver
An asynchronous DNS resolver, backed by mini-c-ares
-
eyeball-im-util
eyeball-im
-
fibers
execute a number of lightweight asynchronous tasks (a.k.a, fibers) based on futures and mio
-
izihawa-common-multipart
multipart/form-data
-
starbase_events
Async and mutable event system
-
circulate
Lightweight PubSub framework that supports both sync and async
-
spaad
Zero boilerplate actor systems with xtra
-
shinyframework_jobs
Shiny Jobs
-
ruchei
working with many streams
-
agnostic
users who want to write async runtime-agnostic crate
-
apalis-cron
extensible library for cron-like job scheduling for rust
-
cbsk_run
async pool tool
-
airlock
no_std async communication
-
swarm-commander
Manage tons of commands asynchronously
-
safina
Safe async runtime
-
puff-rs
Puff - Deep Stack Python Runtime and GraphQL library
-
lightspeed_logger
LightSpeed
-
diazene
Actor for Rust (with Tokio)
-
rx_rust_mp
A protoype implementation of the ReactiveX API in Rust using a message passing approach
-
readwrite
Combine Read and Write into a single Read+Write object
-
islabtech-upw-sensor-v1
Rust client library for remote control of the ISLabTech UPW Sensor v1
-
interprocess-docfix
Interprocess communication toolkit. Docs fixed.
-
async-observable
Async & reactive synchronization model to keep multiple async tasks / threads partially synchronized
-
saas-zmq
ZeroMQ tools by using Publish-Federation
-
async-rayon
Mix async code with CPU-heavy thread pools using Futures + Rayon
-
tokio-lxi
LXI protocol abstractions for Tokio
-
pipebuf_websocket
PipeBuf support for websockets
-
futures_ringbuf
Mock Type implementing AsyncRead/AsyncWrite for testing and examples
-
futures-executor
Executors for asynchronous tasks based on the futures-rs library
-
thin_main_loop
Thin, cross-platform, main event loop. A building block for native GUI applications, among other use cases.
-
sched-callback
async callback scheduling
-
reactor-trait
A collection of traits to define a common interface across reactors
-
rusty_tarantool
Tarantul async client based on tokio framework
-
aral
Async Runtime Aggregation Layer
-
serio
providing traits and utilities for typed IO using format agnostic serialization built on serde
-
tower-sessions-rusqlite-store
(tokio-)rusqlite session store for
tower-sessions
-
felicia
service for accessing and sharing lists of bad actors
-
eyeball-im
Observable collections based on the
im
crate -
signalfut
A future similar to tokio::signal::unix::Signal, but can be used with all the runtimes
-
plumbing
An async abstraction to pipeline requests through a channel
-
smol
A small and fast async runtime
-
tokio-stream_wasi
work with
Stream
andtokio
-
liteapi
Service of litestorm for creating REST APIs
-
situwaition
Run a closure continuously, until is succeeds or times out
-
araft
An async raft implementation based on tokio + tonic
-
queen
message queue
-
peace_rt_model_native
Runtime data types for the peace automation framework
-
raccoon_broker
A message broker implementation
-
lua_actor
Lua Actor for Rust(sync/async)
-
susync
An util crate to complete futures through a handle. Its main purpose is to bridge async Rust and callback-based APIs.
-
charred
char checking
-
rw-deno_core
A modern JavaScript/TypeScript runtime built with V8, Rust, and Tokio
-
taps
taps (Tokio Asynchronous Pub/Sub) is an in-process async message broker that can be used for messaging between spawned tokio tasks
-
event_iterator
Asynchronous lending iterator
-
makepad-futures-legacy
Makepad futures legacy
-
async-cuda
Async CUDA for Rust
-
eventastic_postgres
An example postgres event store for eventastic
-
peace-performance
osu! pp & stars calculation. Peace edition
-
streams
A collection of stream-extensions that are missing in the
futures
crate -
par-stream
Asynchronous parallel streams analogous to rayon
-
glib-signal
GObject signal bindings
-
async_tasks_recorder
A struct for recording execution status of async tasks with async methods
-
pierport
Urbit pier import protocol implementation
-
tokio-socketcan
Asynchronous Linux SocketCAN sockets with tokio
-
actix-daemon-utils
Daemon Utilities by actix
-
slim-futures
Asynchronous tools that intends for smaller binary size
-
acu
building asynchronous actors
-
foxhole-api
wrapper for the Foxhole War API
-
ianaio-dialogs
Convenience crate for working with dialogs in browser
-
bean_factory
bean factory,support inject reference bean
-
oneshot-handshake
providing a symmetric one time use channel type
-
random-access-storage
Abstract interface to implement random-access instances
-
stdout-channel
Write stdout to an async queue
-
busstop
A command and query bus
-
tower-sessions-moka-store
Moka session store for
tower-sessions
-
stackful
Bridge between sync and async
-
async-raft
An async implementation of the Raft distributed consensus protocol
-
pick_action_from_image
Pick an action from an image
-
wrtc
Wrapper around webrtc-rs library, focused on developer experience
-
stund
An SSH tunnel maintenance daemon
-
nyantrack-common
Common data types and functionality for NyanTrack
-
async_counter
Counter that implements a future to await on specific value
-
stream-ext
An extension trait for Streams that provides a variety of convenient combinator functions
-
tokio-file
Asynchronous file I/O for Tokio
-
tbot
Make cool Telegram bots with Rust easily
-
rust-rsm
RSM:A Realtime Software Middleware framework. Asynchronous, event driven framework
-
aiven_rs
sdk to interact with aiven-cloud apis
-
callback-result
Assists in converting the callback function's method of obtaining results into the await method
-
erl_dist
Erlang Distribution Protocol
-
apis
Reactive, session-oriented, asynchronous process-calculus framework
-
taskmanager
Manage groups of background tasks
-
arti-rpcserver
Backend functionality for Arti's RPC service
-
async_async_io
AsyncRead
,AsyncWrite
traits but withasync fn
methods -
merge-streams
Merge multiple streams into one
-
craftio-rs
read & write packets defined in mcproto-rs to I/O sinks/sources
-
passivized_docker_engine_client
Docker Engine Client - manage and run containers, images, and volumes
-
batch-channel
async channel that reduces overhead by reading and writing many values at once
-
curseforge
A straightforward asynchronous wrapper around the CurseForge Core API. Public API is subject to change before 1.0.0.
-
noosphere-collections
Collection data types that are needed by an efficient implementation of Noosphere's IPLD data structures
-
gritlab
Gitlab rust API sdk
-
tourniquet
Async native round-robin manager for remote services
-
async_zip_futures
An asynchronous ZIP archive reading/writing crate using futures-rs
-
didcomm-rs
DIDComm messaging v2 specifications implementation: https://identity.foundation/didcomm-messaging/spec/
-
futwaiter
The container of Future's that has the ability to complete them all at once
-
async-priority-channel
An async channel where pending messages are delivered in order of priority
-
async-rustbus
An asynchronous implementation of the DBus protocol based on rustbus
-
channels-io
Async agnostic/Sync IO & buffer management abstractions
-
scipio
A set of utilities to allow one to write thread per core applications
-
ruw
Read-Update-Write
-
clia-rcproxy
A lightweight, fast and powerful Redis Cluster Proxy written in Rust
-
rendezvous
Easier rendezvous channels for thread synchronization
-
stream-guard
RAII wrapper around Stream that invokes a custom action on drop
-
livekit-runtime
Async runtime compatibility layer for LiveKit
-
miau
Async aware and extensible layered configuration system
-
prometheus-utils
built on top of the prometheus crate
-
sigio
signal-based async io
-
arta-tokio
Async abstractions implementation for Tokio
-
spin_on
inefficient Future executor
-
async-waitgroup
Golang like WaitGroup implementation that supports both sync and async Rust
-
async-nats-tokio-rustls-deps
Fork of Asynchronous TLS/SSL streams for Tokio using Rustls
-
akinator-rs
wrapper around the undocumented Akinator API
-
xjbutil
A xjbly created utility library for my own use
-
monoio-native-tls
Asynchronous TLS streams wrapper for Monoio based on NativeTLS
-
smolscale
A high-performance async-task scheduler
-
bonsaimq
Message/job queue based on bonsaidb, similar to sqlxmq
-
any_spawner
Spawn asynchronous tasks in an executor-independent way
-
libaio-futures
Straightforward Linux AIO using Futures/async/await
-
flurx
Create reactive asynchronous data flow
-
tokio-stomp-2
Unofficial successor to Asynchronous streaming STOMP client
-
future-utils
Extensions to Rust's Future and Stream traits
-
negahban
🧐 A simple file watcher, based on
notify
, designed to be fast, easy-to-use and async friendly -
fbinit-tokio
detail of fbinit crate
-
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) -
waitgroup
Async waitgroup for a collection of task to finish
-
wasmcloud-test-util
Test tools and utilities for wasmcloud
-
extreme
Extremely boring async function runner. MIT/Apache-2.0 license is available for spacejam's github sponsors.
-
screeps-async
Tick-aware Async runtime for Screeps
-
fil_builtin_actors_builder
WASM builder for builtin Filecoin actors
-
csnmp
Community-based async (Tokio) SNMP client library
-
cb_fut
Call function that return value via callback without a callback
-
this-state
way to store state in a thread-safe manner as well as a way to asynchronously wait for state changes
-
prokio
An asynchronous runtime compatible with WebAssembly and non-WebAssembly targets
-
git-next-server-actor
Server actor for git-next, the trunk-based development manager
-
maily
easy, quick, and fault tolerant sending of emails
-
tokio-rustls-wasi
Asynchronous TLS/SSL streams for Tokio using Rustls
-
adventure
your great adventure for the various type of requests
-
openraft-memstore
A in-memory implementation of the
openraft::RaftStorage
trait -
async-graphql-tide
async-graphql for tide
-
sc2
StarCraft II Client API
-
libublk
building linux block device in userspace
-
textmode
terminal interaction library backed by a real terminal parser
-
notify-future
Support asynchronous notification completion future
-
futures-stream-ext
Asynchronous stream extensions for the futures(-core) crate
-
hydra-dashmap
A fork of dashmap for the hydra framework
-
lazy_async_pool
An asyncronous object pool that generates objects on the fly
-
uringy
single-threaded concurrency runtime for Rust based on io_uring
-
elegant-departure
simplify graceful shutdown
-
rt-local
Thread local asynchronous runtime working with platform-specific event loops
-
async-variadic
async variadic functions in Rust with trait bounds
-
tracing-orchestra
Give me more instruments!
-
luis_sys
FFI bindings for Microsoft LUIS API
-
goods
Async assets system
-
xitca-io
async network io types and traits
-
syndicate
Syndicated Actor model for Rust, including network communication and Dataspaces
-
rspl
A stream processor language
-
event-driven-library
Event Driven Message Handling
-
futures-delay-queue
Async delay queue backed by async-std and futures-timer
-
tokio-zmq
Futures abstractions for ZeroMQ on the Tokio event-loop
-
async-compat
Compatibility adapter between tokio and futures
-
mpi-sys
Message Passing Interface bindings for Rust
-
async-recorder
Store records without waiting for your persistence backend
-
kumoko
asynchronous server/client crate built on tokio for easy two-way streaming
-
atrium-cli
CLI application for AT Protocol using ATrium API
-
tokio-serde-cbor
Integration of serde_cbor into tokio-io, to allow sending CBOR encoded frames across network (and possibly through other transports)
-
tk-listen
A set of helper futures allowing to listen TCP (or unix) socket with resource limits and proper error handling
-
delimiter-slice
Stream type for splitting a delimited stream
-
puteketeke
An asynchronous runtime built on smol
-
progenitor-impl
An OpenAPI client generator - core implementation
-
co_managed
Create managed sub coroutines. Managed sub coroutines will be cancelled when the parent exit
-
monoio-compat
A compat wrapper for monoio
-
killswitch
used to broadcast a shutdown request
-
piston_rs
An async wrapper for the Piston code execution engine
-
smelling_salts
Abstraction over OS APIs to handle asynchronous device waking
-
pi_async_buffer
Asynchronous Buffer for IO
-
aa-sms
Send messages from with Andrews & Arnold’s SMS API
-
debounced
building delayed
Future
s and debouncedStream
s that wait a given duration before yielding the most recent item -
minimal-executor
A minimal executor for asynchronous tasks based on the futures-rs library
-
moxie
Incremental runtime for interactive software
-
lifeline
dependency injection library for asynchronous message-based applications
-
linkd
actor model framework that takes inspiration from OTP in the erlang ecosystem
-
dioxus-v04-optional-hooks
Optional futures for Dioxus 0.4.0-0.4.3
-
redis-work-queue
A work queue, on top of a redis database, with implementations in Python, Rust, Go, Node.js (TypeScript) and Dotnet (C#)
-
untokio
Automatically create tokio runtimes
-
async-result
wrapper providing a convenient way to await a result, built on futures-channel's oneshot channel
-
async-send-fd
A wrapper for async UnixStream's to send file descriptors
-
hls_lfcd_lds_driver
Rust driver for ROBOTIS HLDS HLS-LFCD-LDS (LDS-01)
-
bb8-lapin
r2d2-lapin, but for async tokio based connections
-
zeebest
An unofficial zeebe client for the future!
-
msq
legacy Master Server Query Protocol
-
automerge_repo
automerge-repo
-
tiny_future
Condvar
based future with automatic cancellation on drop -
arangoq
An AQL query builder layer and ArangoDb client for rust
-
iroh-test
Internal utilities to support testing of iroh
-
flo-state
Lightweight actor library
-
tokio-graceful-shutdown-without-anyhow
perform a graceful shutdown on a Tokio based service
-
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
-
nsq-client
Rust client for the NSQ realtime message processing system
-
side-futures
Send future for execution on the runtime that may be in a different thread
-
async-minecraft-ping
An async Rust client for the Minecraft ServerListPing protocol
-
hypixel_api
Generic wrapper around the hypixel api (automatic rate-limiting on client-side)
-
ractor_cluster
Distributed cluster environment of Ractor actors
-
gw2api-rs
An asynchronous wrapper for the official Guild Wars 2 API
-
async-ctrlc
Async wrapper of
ctrlc
-
foreback
Future adapters for running aditional work in the background
-
essential-lock
A minimal crate containing Essential's locking method that is safe to use in async code
-
rabbit_mqr
Extremely Simplified RabbitMQ Client
-
task-group
manage groups of tokio tasks
-
paperless-rs
An asynchronous Rust library for the Paperless-ngx document manager
-
qbit-api-rs
A asynchronous Rust wrapper for qBittorrent Web API
-
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.
-
dmds-tokio-fs
Dmds I/O handler interacts with the filesystem using Tokio
-
amqp-lapin-helper
rust lapin helper
-
handoff
An unbuffered, asynchronous, single-producer/single-consumer channel
-
cancellable
providing a generic cancellable utility
-
nextgraph
client library. Nextgraph is a decentralized, secure and local-first web 3.0 ecosystem based on Semantic Web and CRDTs
-
async-http1-lite
Asynchronous http1 stream
-
callbag
spec for reactive/iterable programming
-
async_closure
utilizes the nightly-only feature async_fn_in_trait to imitate async_closures
-
hikvision-rs
High-level asynchronous library for controlling cameras from Hikvision using the PTZ API
-
vents
Events system
-
reception
creating TCP listeners that spawns clients providing model abstraction layer
-
epicenter
synchronous and asynchronous event dispatcher for Rust
-
fluvio-async-tls
Asynchronous TLS/SSL streams using Rustls
-
futuristic
Extensions to the futures crate
-
openai-api
OpenAI API library for rust
-
message-sink
Message framing for AsyncRead + AsyncWrite
-
io_tee
Tee Read, BufRead, and Seek instances to a writer
-
awaitgroup
Wait for a collection of async tasks to finish
-
tokio-stdin-stdout
Thread- and future::sync::mpsc-based AsyncRead/AsyncWrite stdin/stdout with little buffering
-
async_msp_cli
Async msp cli for iNav and BetaFlight
-
pipebuf_mio
PipeBuf support for
mio
byte-streams -
uring-fs
Truly asynchronous file operations using io-uring. Supports any async runtime. Linux only.
-
onetime
(aka. oneshot) async spsc channel
-
radix-router
Rust port of httprouter
-
tokiactor
tokio based Actor framework
-
peace_rt_model
Runtime data types for the peace automation framework
-
futures-sink
The asynchronous
Sink
trait for the futures-rs library -
arti-bench
benchmarking utility for Arti
-
stream_router
A Future aware router to dynamically route between Streams and Sinks
-
mysql_async
Tokio based asynchronous MySql client library
-
async_singleflight
Async singleflight
-
murray
A minimal actor definition macro using Tokio
-
cntrlr
async embedded framework
-
fork_stream
Clone any stream
S
where<S as Stream>::Item: Clone
-
cbsk_s_rayon
socket callback tool
-
linked-futures
Link futures into a block, which stops all of the included futures when any of the futures complete
-
strawpoll
A wrapper to avoid spurious polling
-
dabus
Dynamic Aplication Controll Bus - an asynchronous, event based module system for thoes who want to move fast and *not* break things
-
heph
actor framework based on asynchronous functions
-
async-mavlink
An async adapter for mavlink conections
-
xilinx-dma
Userspace Xilinx AXI DMA Interface
-
any-mpsc
An mpsc that allows arbitrary types to be passed through
-
prevayler-rs
System prevalence in rust
-
dialectic
Transport-polymorphic, asynchronous session types for Rust
-
evdev-shortcut
Global shortcuts using evdev
-
webhttp
-
nu-stream
Nushell stream
-
mias_channel
that supports bi-directional channels by wrapping others
-
async-xml
deserializing XML data asynchronously
-
async-raft2
An async implementation of the Raft distributed consensus protocol
-
awaitable
type with input and output that can be stored in container
-
async-spin-sleep
providing a highly accurate asynchronous timer for multiple async tasks using spin sleep in a single thread
-
peermerge
Manage JSON-like documents with multiple writers, without a central authority, using a P2P protocol
-
must_future
A wrapper future marked must_use - mainly to wrap BoxFutures
-
shutdown-handler
A shutdown handler that allows all parts of an application to trigger a shutdown
-
cxx-async
interoperability between C++ coroutines and asynchronous Rust
-
rlua-async
Async support for rlua, via coroutines
-
aide-de-camp
backend agnostic delayed job queue
-
spawns-executor
Async executors for thread context task spawner
-
bp3d-threads
threading library intended to simplify concurrency in BP3D
-
async_monad
Asynchronous monad for rust
-
abstract-ns
Abstract name service traits for use with futures (and tokio)
-
app-queue
In-app persistent queue for asynchronous jobs
-
async-io-converse
Can conduct a conversation over any AsyncRead or AsyncWrite type with serde compatible types
-
cannyls_rpc
RPC library for operating cannyls's devices from remote nodes
-
rmw_ttlmap
Minimal async cache in Rust with support for key expirations
-
quick_crawler
QuickCrawler is a Rust crate that provides a completely async, declarative web crawler with domain-specific request rate-limiting built-in
-
async-lazy
A value which is initialized on the first access, with an async function
-
csv-async
CSV parsing for async
-
libsync
containing channels and other synchronisation object implementations
-
async-tls
Asynchronous TLS/SSL streams using Rustls
-
cs-utils
Common utilities
-
futures-test
Common utilities for testing components built off futures-rs
-
reactors
Performance-focused cross-platform asynchronous IO implementation
-
coachman
rust asynchronous task manager built on top of tokio framework
-
async-log
Async tracing capabilities for the log crate
-
futures_cbor_codec
A codec for framing an AsyncRead/AsyncWrite with cbor for all types that are serializable with serde
-
tokio-libtls
Tokio bindings for LibreSSL's libtls
-
awesome-operates
A reposity includs many common use code utils
-
app_ctx
An AppCtx implementation in Rust, like ApplicationContext in SpringBoot
-
visiting_ref
Container types that asynchronously return ownership of a value to another context upon exiting scope
-
futures-waitmap
future-based concurrent event waiting hashmap
-
intercomm
Asynchronous inter-component communication library
-
tezaursapi
api wrapper for tezaurs.lv
-
mwmr
A generic optimistic transaction manger, which is ACID, concurrent with SSI (Serializable Snapshot Isolation)
-
libevent
Rust bindings to the libevent async I/O framework
-
ebus
Basic Event Bus implementation
-
auto-future
For quickly making a struct into a future via an async fn
-
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
-
in-keys
utilizing streams in a convenient
Terminal
construct -
mak
but mak it faster
-
basu
Eventbus crate with sync and async features
-
rexecutor-sqlx
A robust job processing library
-
cooper
in-process, async Actor library for Rust
-
msft-runtime
Windows async helpers
-
tokio-async-drop
macro to enable async drop in a tokio multithreaded runtime
-
blec
cross-platform ble client library based on btleplug
-
fb_futures_01_ext
Extensions for future 0.1 crate
-
monoio-thrift
Thrift for Monoio
-
async-rx
functions for async reactive programming
-
axiom
Implements a highly-scalable and ergonomic actor system for Rust based on the best of Erlang / Elixir and Akka
-
dialectic-compiler
Session type macro compiler for the Dialectic crate
-
multiqueue2
A fast mpmc broadcast queue
-
tokio-easy-timer
A tokio-based task scheduler, with a user-friendly API
-
swimos_byte_channel
SwimOS Byte Channel
-
stow
Cloud storage abstraction package for Rust
-
tokio-lk
Futures-aware lock-by-id primitives
-
async-file-lock
Asynchronous file lock that can auto lock and auto seek
-
starpu-sys
Low-level bindings to the StarPU runtime
-
rasi-ext
includes extend features or experimental features that are useful for asynchronous programming
-
handy_async
A handy library for describing asynchronous code declaratively
-
proxycurl-linkedin-rs
client for the Proxycurl LinkedIn API
-
blocker
Block rust futures to create a synchronous wrapper around an asynchronous api
-
jittr
A binary heap based jitter buffer implementation for zero latency udp/rtp streams
-
tokio-process-stream
that wraps a tokio::process into a tokio::stream
-
bufstream
Buffered I/O for streams where each read/write half is separately buffered
-
wasmer-wit-bindgen-rust
wit-bindgen-gen-c
-
loading-bytes
Load bytes from paths on native and WASM
-
compio-driver
Low-level driver for compio
-
read-progress-stream
Stream reader wrapper that tracks the number of bytes read
-
speedracer
racing futures and ranking the results
-
tcp-channel-client
Asynchronous tcpclient based on aqueue actor
-
async-copy-progress
Asynchronous copying with progress callbacks
-
rio_rt
A minimal async runtime with an experimental ambition to be an portable and interoperable async runtime for Rust
-
wasmflow-packet
encapsulating the message packets sent across Wasmflow components
-
futures-rate
easy tools to help Rust applications guide critical resources or code paths from being overwhelmed
-
tokio-udev
Non-blocking/Asynchronous Tokio support for udev device events
-
newsblur_api
NewsBlur-API
-
tokio-executor-trait
executor-trait implementation for tokio
-
mini-c-ares
A minimal Rust wrapper for the c-ares library, for asynchronous DNS requests, based on rust-c-ares
-
nakadion
Types for interacting with the Nakadi Event Broker
-
async-usercalls
An interface for asynchronous usercalls in SGX enclaves. This is an SGX-only crate, you should compile it with the
x86_64-fortanix-unknown-sgx
target -
async_object
Async Object wrapper
-
simple-scheduler
Schedule periodic tasks to run asynchronously
-
tidy-browser
Tidy up browser information
-
switchboard
Enables inter-process communiucation via queues and wakers
-
async-macros
Macros for async-std
-
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
-
event-source
Zero cost async immediate event dispatching
-
ruva
Event Driven Message Handling
-
ianaio-file
Convenience crate for working with JavaScript files and blobs
-
terrars-integrations-github
Pre-generated Terrars Github bindings
-
tokio-context
Contexts for cancelling asynchronous tasks using tokio
-
pakr-fsm
Template to implement finite-state-machines
-
mediator
pattern in Rust
-
aktors
Driver for derive-aktor
-
tobytcp
A little library for sending messages over a tcp stream
-
domain-resolv
An asynchronous DNS stub resolver
-
specta
Easily export your Rust types to other languages
-
futures-timeout
that provides timeouts for futures and streams
-
simple-middleware
General purpose middleware crate
-
tokio-global
Global tokio runtime
-
tokio-extra-macros
Extra proc macros for Tokio
-
async-scgi
Async SCGI Client & Server
-
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…
-
reusable-box-future
A reusable
Pin<Box<dyn Future<Output = T> + Send>>
-
async-sse
Async Server Sent Event parser and encoder
-
bytes-stream
functions to work with stream of bytes
-
rtbase
async runtime base code
-
plctag-async
async wrapper for libplctag
-
gandi-v5-livedns-api
Gandi LiveDNS Api
-
split-stream-by
Stream extension crate for splitting a Stream into two per a predicate
-
asynciter
Asynchronous iterator
-
poolparty
Added functionality for the
futures::executor::ThreadPool
futures executor -
gentian
proc macro that transforms generators to state machines
-
safina-timer
Safe async timers
-
eventific
that gives you the needed building blocks for event sourcing
-
nonblock
Read available data from file descriptors without blocking (e.g. sockets, streams, child stdout, named pipes)
-
slog-scope-futures
slog-scope for
Future
s -
pochta
Addressable channel registry
-
elfo-dumper
Dumps messages of the elfo system on disk
-
spawn_groups
Structured concurrency construct written in Rust, for Rustaceans
-
rumpsteak
Session types for asynchronous communication between multiple parties
-
pirates
async RPC lib
-
deferred
help perform deferred execution of code logic
-
streammap-ext
StreamMap of Tokio with altered
next
that returns when stream is dropped -
dyn-future
Convenient and fast dynamic Futures for Rust
-
ruchei-route
Sinks with routes
-
tokio_interval
基于Tokio实现了 setInterval(callback, ms) 和 setTimeout(callback, ms) 类似于Javascript的API
-
futures_codec
encoding and decoding frames using
async/await
-
tokio-stream-ext
Stream extension with new operators, this will grow over the time
-
parity-runtime
Tokio runtime wrapper
-
rad
A type-safe, high-level interface to librados using the low-level C bindings from ceph-rust
-
js-sys-futures
working with the futures and js-sys crates
-
tokio-shutdown
Wait for a stop signal across multiple threads
-
dyn-timeout
Dynamic timeout, cancel, add and remove time before a callback execution
-
zookeeper-cache-rust
ZooKeeper client cache
-
mio-uds
Unix domain socket bindings for mio
-
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
-
lichess-api
client for Lichess API v2.0.0
-
rust-stream-ext-concurrent
Concurrent behavior extensions for any futures::stream::Stream objects
-
limitation
A rate limiter using a fixed window counter for arbitrary keys, backed by Redis
-
acril-rt
A lightweight single-threaded runtime for Acril actors
-
riker-cqrs
Command Query Responsibility Separation for Riker applications
-
heim-cpu
Cross-platform CPU information
-
openai-api-fork
OpenAI API library for rust
-
ksoft
KSoft.SI api wrapper written in pure Rust
-
trillium-tokio
tokio runtime adapter for trillium.rs
-
async-native-tls-alpn
Native TLS using futures
-
enstream
Conversion from Future to Stream
-
async-object-pool
object pool implementation that uses asynchronous synchronization primitives only
-
tracing-actix
Allow tracing actor futures in actix
-
roux-stream
A streaming API for the roux Reddit client
-
pseudoterminal
A cross-platform pseudoterminal implementation with async support
-
actix-interop
Use async/await syntax with actix actors
-
manual_future
A future that must be manually completed, similar to Java's CompletableFuture
-
rants
An async NATS client library
-
signals
A functional-reactive-like library for Rust that allows asynchronous chaining
-
one_for_one
supervize spawn'ed async tasks
-
dstream
DelayedStream - delays items and drops same items coming within given interval
-
try-again
Retry synchronous and asynchronous operations
-
compio-net
Networking IO for compio
-
heph-inbox
Bounded capacity channel designed to be used as inbox for actors. Also supports one shot channels.
-
stream-kmerge
K-way merge for streams
-
blocking-permit
Permits and a thread pool for blocking operations
-
type-toppings
Opinionated extensions to standard types
-
zellij-utils
Zellij client and server
-
event-listener-strategy
Block or poll on event_listener easily
-
raftlog
distributed replicated log based on the Raft algorithm
-
dwbhk
dwbhk-rs is a library for working with Discord Webhooks
-
tokio-netstring-trait
A trait for tokios AsyncRead to easily read netstrings from streams
-
bastor
A wrapper helps implementing actor with Bastion more easier with self-implemented state
-
io-tubes
functionality like pwntools tube for async io in rust
-
async_message_dispatcher
dispatching messages to asynchronous handlers easier
-
async-handle
A reference-counted async RwLock
-
multiqueue
A fast mpmc broadcast queue
-
quickwit-actors
Actor framework used in quickwit
-
gcs-rsync
rsync support for gcs with higher perf than gsutil rsync
-
xtor
Async Actor framework for Rust which is blazing fast and rock solid
-
lib3h_zombie_actor
lib3h actor request tracking module
-
tokio-socks
Asynchronous SOCKS proxy support for Rust
-
git-next-webhook-actor
webhook actor for git-next, the trunk-based development manager
-
geph4-aioutils
geph4
-
viz-utils
Viz utils
-
futures-signals-ext
Extension to futures-signals: MutableOption with combinators, spawning, predicate driven selections from SignalVec
-
async-refresh
Create values that refresh automatically and asynchronously after a given duration
-
mini-io-queue
Fixed-length, allocation and lock-free, async I/O oriented single-producer single-consumer queues
-
todc-net
Algorithms for message-passing (HTTP) distributed systems
-
maybe-future
Future that can be None
-
async_tasks_state_map
A struct for recording execution status of async tasks with async methods
-
happyeyeballs
Happy Eyeballs implementation in Tokio (not RFC compliant atm)
-
pantry
Temporary storage for reusing values that may decay
-
rotor
The mio-based framework for doing I/O in simple and composable way
-
webrocket
A closure focused WebSocket server implementation
-
tokio-childstream
Convert a tokio::process::Child into a Stream for stdout, stderr, and exit events
-
andiskaz
A convenience library for writing games and other apps in TUI
-
bb8-bolt
A bolt-client adaptor for the bb8 connection pool
-
async-select-all
A futures library adapter for selecting over a list of futures
-
madsim-tokio
The
tokio
simulator on madsim -
async-timers
asynchronous timer primitives
-
joyent-tokio-zookeeper
Asynchronous client library for interacting with Apache ZooKeeper
-
agner-actors
An actor toolkit inspired by Erlang/OTP (actors)
-
simple-async-pipe
Aims to provide a simple pipe-like functionality for async code
-
winmsg-executor
Per-thread async rust executor for windows
-
snarc
Sendable Non-Atomically Reference Counted
-
spekt
std::future::Future and Result-based testing trait for managing the lifecycle of stateful, asynchronous tests
-
dialtone_common
Dialtone Common Code
-
xtra-addons
Add-on functionality (Broker, Registry) for crate xtra
-
prost-codec
Asynchronous de-/encoding of Protobuf structs using asynchronous-codec, unsigned-varint and prost
-
italo-api
Rust binding for Italo API
-
gossip-relay-picker
A relay picker for nostr, used by gossip
-
crown
jewel of rust libraries
-
futures-diagnose
Wraps around a Spawn and provides lots of diagnostics
-
git-event
Customizable event handler for updates in remote git repositories
-
async-read-progress
Extension traits for inspecting
AsyncRead
progress -
tl-async-runtime
A bad runtime impl for educational purposes only
-
rqlite-ha421
An async implementation of a rqlite client
-
merge-io
Merge two separate
AsyncRead
andAsyncWrite
objects into a single I/O stream -
agnostic-lite
agnostic-lite
is WASM friendly and light version ofagnostic
, for users who want to write async runtime-agnostic crate -
reactive-messaging
Reactive client/server communications, focused on high performance
-
asyncs-sync
Asynchronous runtime agnostic synchronization utilities
-
stellwerksim
Rust SDK for StellwerkSim
-
futures-cache
Futures-aware cache backed by sled
-
background-jobs-core
Core types for implementing an asynchronous jobs processor
-
parallel-stream
Data parallelism library for async-std
-
buffer-unordered-weighted
Stream::buffer_unordered where each future can have a different weight
-
retry_future
Retry futures mechanism
-
tag_nominatim
Bindings to the reverse geocoding API powered by openstreetmap
-
idb
A futures based crate for interacting with IndexedDB on browsers using webassembly
-
contained-actors
contained is a research project implementing the proposed harmonic runtime for orchestrating cloud-native systems
-
tokio-uring-rustls
Integrate rustls into tokio-uring
-
named-retry
retrying fallible asynchronous operations
-
zellij-client
The client-side library for Zellij
-
clap-and-async-test
Is a example to use clap with tokio and futures, how run concurrently some functions with a loop inside
-
laizy
stable and thread-safe implementation of a lazy value
-
f189ctrl
Communication library for Fluke 189 digital multimeter
-
amqp
AMQP/RabbitMQ protocol client
-
xo-api-client
Unofficial crate for accessing Xen Orchestra through its API
-
gabelung
Branch an asynchronous stream of cloneable items into two
-
future-clicker
Reimplementation of manual_future without using
futures
unstable -
unblock
A thread pool for isolating blocking in async programs
-
riker-patterns
A collection of common actor patterns for Riker
-
alopecosa
Pure rust async Tarantool 1.6+ connector built on tokio
-
volo-macros
Volo's proc macros
-
waker-waiter
async runtimes interoperate with arbitrary futures
-
salvia
Incremental computing brought to async Rust
-
interval_future
Wraps a synchronous, waker-less polling function in an interval-based future
-
git-next-file-watcher-actor
Config file watcher for git-next, the trunk-based development manager
-
simple_futures
futures for use in async operations
-
zusammen
Download files in parallel
-
ert
A combinator to control future execution order
-
tokio-socketcan-bcm
Asynchronous Linux SocketCAN - Broadcast Manager support (BCM) with tokio
-
async-recursion
Recursion for async functions
-
linera-alloy-rpc-client
Low-level Ethereum JSON-RPC client implementation
-
tokio-nsq
NSQ client built on Tokio. Tokio NSQ aims to be a feature complete NSQ client implementation.
-
sidekiq-rs
Sidekiq compatible server in Rust
-
euklid
CRDT
-
async_io_crypto
handling AsyncRead with ciphering / deciphering
-
indexed_db_futures
Future bindings for IndexedDB via web_sys
-
sender-sink
classes for working with tokio UnboundedSender and the Sink trait
-
oneshot-broadcast
channel that broadcasts a value once without cloning it
-
rexer
Async I/O multiplexing library for rust
-
abcperf-minbft
Integration of MinBFT into ABCperf
-
hash_events
An MPMC event system that allows for custom events. Events are emitted with a payload, and subscribers to that event are stream of payloads. For each event, all subscribers are triggered.
-
russh-agent
Asynchronous ssh-agent client
-
framed_aio
allows performing async io operations in a framed manner
-
async-anyhow-logger
An easy crate for catching anyhow errors from an asynchronous function, and passing them to your logger
-
xactor
actors framework based on async-std
-
stream-future
Implement an async iterator with return value
-
swimos_runtime
SwimOS Agent & Downlink Runtime
-
blockz-futures
working with futures for the tokio stack
-
hala-io
hala asynchronous io programming primitive types
-
telegram-bot-ars
creating Telegram bots
-
ruchei-callback
Callback traits for ruchei
-
async-ringbuffer
A nonblocking spsc ring buffer with fixed capacity
-
eventsourcing
Event Sourcing for Rust
-
qp
Quick Pool: High Performance Async Generic Pool
-
teloxide-core
Core part of the
teloxide
library - telegram bot API client -
mlua_actor
Lua Actor for Rust(sync/async)
-
sparkle-impostor
A third party crate for Twilight to execute Discord webhooks that clone an existing message
-
toy-async-runtime
Toy library to start to work with async rust, build for reckless person!
-
hooks-core
Compile-time, async hooks
-
fut_rwlock
A read-write lock that is read and written via Futures
-
termion-input-tokio
An adapter that exposes termion's input and key event iterators as asynchronous streams
-
select-next-any
Alternative to futures::StreamExt::select_next_some that returns the None variant
-
fred
An async Redis client built on Tokio
-
histlog
hdrhistogram crate, provides off-thread serialization of HdrHistogram interval logs to file
-
process-stream
Thin wrapper around [
tokio::process
] to make it streamable -
crb-core
CRB | Composable Runtime Blocks | Core
-
futures-net
The futures-net library
-
tower-actor
A
tower
middleware that creates aService
by passing messages to an actor -
scd4x-rs
query SCD4x sensors over I²C
-
rs-copier
Copy and move files asynchronously
-
rsdns
DNS Client Library
-
tokio-switching-sleep
A tokio Sleep with a switchable state
-
arta-async-std
Async abstractions implementation for async-std
-
agreed
Fork of async-raft, the Tokio-based Rust implementation of the Raft protocol
-
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…
-
async-lease
Essentially a futures-oriented Arc<Mutex<Option<T>>>
-
tokio-task-manager
Allow an async Tokio application to gracefully shutdown, waiting for all tasks to finish
-
rustpub
Activitypub types
-
fb-api
Facebook Api abstraction for async rust
-
makepad-futures
Makepad futures
-
flv-future-aio
I/O futures for Fluvio project
-
north-config
North config is a multi source configuration crate designed as part of the North Microservice Framework
-
releez
run application release-checklist safely
-
whorl
was created to teach you how async executors work in Rust
-
tokio-scoped
Scoped Runtime for tokio
-
c_mcai_worker_sdk
AMQP Worker to listen and provide trait to process message
-
streamtools
Additional stream combinators
-
pingora-runtime
Multithreaded Tokio runtime with the option of disabling work stealing
-
async_chanx
Implement
Sink
for some channel implementations -
eventually-postgres
Event Store implementation using PostgreSQL for the Eventually crate
-
crate-test-xxx
test crate
-
kvarn-tokio-uring
Temporary Kvarn fork: io-uring support for the Tokio asynchronous runtime
-
eventador
lock-free pub/sub event-bus with sync and async APIs
-
future-combinator-params
functions to inject extra arguments between futures combinators Then/AndThen
-
unsend
A thread unsafe runtime for thread unsafe people
-
o5m-stream
streaming async o5m decoder
-
async-consul
An Tokio-based Consul client for Rust
-
change_stream
A Stream that only emits if the value is different
-
agner-sup
An actor toolkit inspired by Erlang/OTP (supervisors)
-
requiem
Actor framework for Rust
-
peace_rt
Runtime logic for the peace automation library
-
gcp_auth
Google cloud platform (GCP) authentication using default and custom service accounts
-
iou
io_uring bindings
-
sealrs
Set of classic asynchronous primitives (Actors, Executors, Futures / Promises)
-
async-openai
OpenAI
-
completion
writing completion-based asynchronous code
-
actix-storage-sled
actix-storage based on sled
-
mio-pidfd
mio support for Linux's pidfd
-
actix-postgres
PostgreSQL integration for Actix framework
-
sntpc
making SNTP requests
-
troupe
modelling Rust applications with actors
-
worst-executor
A spin-loop like executor for async
-
stateful_async_worker
Asynchronous stateful worker threads utilizable as futures
-
amqprs
AMQP 0-9-1 client implementation for RabbitMQ
-
medea-reactive
Reactive mutable data containers
-
pi_futures
feature select
-
fundamentum-edge-pfwd
The port forwarding tool for edge daemon
-
connection-utils
Connection related utilities
-
future_handles
complete futures via handles
-
anotify
Async iNotify Filesystem Watcher
-
heim-common
Common stuff shared across heim project crates
-
atcoder
A template for Rust project
-
async-jobs
Asynchronous job orchestration for Rust
-
casus
containing a handful of event-based async primitives
-
catalyzer
HTTP server framework
-
set_timeout
allows efficiently executing futures after some delay has passed
-
tokio_telegraf
Minimal async rust wrapper for the telegraf/influxdb protocol, based on Tokio
-
bevy_flurx
Allows you to write sequential description of processes involving delays, user input, and other waits
-
mrwei
that implements the common promise primitive for rust based on std future
-
svix
Svix webhooks API client and webhook verification library
-
alligator
getting the output value from a future
-
zeebe
client for defining, orchestrating, and monitoring business processes across microservices using Zeebe
-
vru-cancel
Cancel tokio stream
-
stilgar
A lightweight, no-fuss, drop-in replacement for Rudderstack
-
rivulet
Asynchronous contiguous-memory streams
-
futures-util-either
futures_util::future::Either Ext
-
medina
An asynchronous web crawling engine
-
gritea
Gitea API sdk
-
messagebird-async
Wrapper around the message bird SMS API
-
tower-util
working with
Service
-
allochronic-util
Private utility crate for allochronic and khonsulabs
-
hermod
futures-based RSS/Atom library
-
rusty_falcon
Rust bindings for CrowdStrike Falcon API
-
wakerpool
lightweight object pool for lists of Wakers
-
async-gen
Async generator in stable rust using async/await
-
gmqtt-client
MQTTv5 client
-
vss
A dead simple library to allow for easily reused shutdown signal handling
-
wookie
Async test/bench toolkit including single stepping executors. No-std compatible.
-
tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
waitlist
Keep track of an ordered list of Wakers to wake
-
service-io
Build your service-server fast, easy (and without hosting!)
-
promise
future/promise library for rust
-
tourniquet-celery
Async native round-robin manager for remote services. celery integration.
-
pw-telegram-bot-fork
creating Telegram bots
-
appliance
A lightweight framework to build async-friendly components with message-based intercommunications
-
broadcaster
Broadcasting futures mpmc channel
-
stream-utils
Additional stream combinators
-
yaanhyy_rust
cargo mod example
-
interprocess
communication toolkit
-
tokio-task-queue
Execute futures from a stream of futures in order in a Tokio task
-
async-cuda-npp
Async NVIDIA Performance Primitives for Rust
-
relaxed_channel
Wrapper around async-channel, more performant on heavy pipelines
-
tokio-io-compat
Compatibility wrapper around std io traits that implements tokio io traits
-
gnostr-core
Replication protocol for Hypercore feeds
-
baildon-store
B+Tree CLI
-
fates
creating reactive declarations
-
tokio-uds-proto
Unix Domain sockets working with tokio-proto
-
mailbox_processor
A small little actor abstraction inspired by the FSharp Mailbox Processor which in turn was inspired by erlang
-
kythera-fvm
Core implementation of the Kythera FVM
-
suppaftp
A super FTP/FTPS client library for Rust
-
gen-stream
Generator-based streams for Rust and futures 0.3
-
tokio-util_wasi
Additional utilities for working with Tokio
-
futures-test-preview
Common utilities for testing components built off futures-rs
-
oc-wasm-futures
Futures that allow async/await to be used in OC-Wasm for a more ergonomic experience
-
sched-clock
A timer for task scheduling
-
and-then-concurrent
Concurrent and-then combinator for Rust streams
-
cloudflare_dyndns
DynDNS client for Cloudflare
-
future-by-example
Examples of common patterns using Future
-
simple-tokio-watchdog
Pretty simple but bulletproof watchdog actor
-
mikrotik_api
& minimal client to connect and interact with Mikrotik RouterOS API, usually exposed on port 8728
-
bluest
A cross-platform Bluetooth Low Energy (BLE) library
-
heim-sensors
Cross-platform sensors information
-
actix-redis
Actor-based Redis client
-
hds_console-api
test crate, do not use
-
tinkoffpay
tinkoff integration (the seller receives a link to the payment form and redirect the buyer to it); NB: with callback method
-
retry-strategy
A better asynchronous retry tool based on Tokio
-
raii-counter-futures
RAII Counter that allows you to wait for a count of zero asynchronously
-
fumio-utils
utils for fumio crates
-
elfo-configurer
Loads and distributes configs across the elfo system
-
async_io_utilities
An asynchronous IO utilities crate powered by
tokio
-
hyper-futures
Compatibility layer for futures to use AsyncRead and AsyncWrite traits with hyper
-
egg-mode-extras
Rate-limited streams and other helpers for egg-mode
-
futura
Helpers for working with futures
-
hydrolink
Lavalink client made with tokio independent of the Discord library, used in production by Hydrogen
-
try_future
Convenient short-hand for returning early from
futures
-based functions -
icanhazdadjoke-sdk
An SDK to interact with the icanhazdadjoke Dad Jokes API
-
tokio-agent
Agents are a simple abstraction around state, inspired by Elixir's Agent
-
tokio-anon-pipe
Asynchronous anonymous pipe for Windows
-
futures-loco-protocol
Asynchronous Loco protocol stream for futures
-
ak
Actor library utilizing std futures
-
ardop_interface
Interface to the Amateur Radio Digital Open Protocol (ARDOP)
-
npm-package
client for fetching metadata from the npm package
-
futures-zmq
Futures abstractions for ZeroMQ on any futures executor
-
mqttc
client for the MQTT protocol
-
bleasy
High-level BLE communication library
-
compio-io
IO traits for completion based async IO
-
async_channel_io
AsyncRead
andAsyncWrite
implementations forasync_channel
-
async_msp_lib
Async msp library for iNav and BetaFlight
-
spmc-logger
A single-producer multi-consumer persistent logger
-
stream-download
streaming content to a local file-backed cache
-
zipit
Create and stream zip archives on the fly
-
tokio-duplex
Combine seperate
AsyncRead
andAsyncWrite
types into a singleAsyncRead + AsyncWrite
type -
openraft-rocksstore
A rocksdb based implementation of the
openraft::RaftStorage
trait -
rexa
GraphQL MongoDB API builder
-
restartables
Future that restarts an inner future if it doesn't meet a condition
-
blocking_pool
A thread pool for running synchronous I/O in asynchronous applications
-
rseip-cip
common industry protocol for rseip
-
starstruck
A game building utility that is made to be simple to use while still providing great performance
-
async_dag
An async task scheduling utilitiy
-
serenity_ctrlc
Ctrl+C handler for serenity
-
fure
Retrying futures using different policies
-
wag
Go like sync.WaitGroup implementation in Rust. (sync/async)
-
component-future
implements the inner future protocol documented in the tokio docs
-
back-to-the-future
Conversions between std::future::Future and futures::Future
-
async-gcode
An async gcode parser for no_std targets
-
containerd-snapshots
Remote snapshotter extension for containerd
-
callback-future
Adapter between callbacks and futures
-
sctp-proto
A pure Rust implementation of SCTP in Sans-IO style
-
rfm69-async
async driver for the rfm69 radio transceiver
-
tinyio
A tiny Rust concurrency runtime library
-
futures-mockstream
Minimal mockstream which implements futures async traits
-
name-it
Give a name to async fn return types
-
async-openai-wasm
OpenAI on WASM
-
repsheet_etl
ETL tools for repsheet
-
dbus-async
Asynchronous DBus library
-
rasi-spec
The Official RASI Specification Test Suite
-
salvo-oapi
OpenApi support for Salvo web framework
-
scuttlebutt
interface for kubernetes events
-
discord_api
Interact with the Discord API from your shell
-
mio-misc
Miscellaneous components for use with Mio
-
lwactors
Lightweight actors for Rust using futures-rs
-
lemmy_apub_lib
A link aggregator for the fediverse
-
puppet
actor framework which uses no dynamic dispatch or boxing
-
lunatic-distributed
Node to node communication
-
tokio-reactor-trait
reactor-trait implementation for tokio
-
rusturn
TURN server and client
-
scoped_async_spawn
spawn non-static futures
-
encrypted-dns
A modern encrypted DNS server (DNSCrypt v2, Anonymized DNSCrypt, DoH)
-
actor-interfaces
I only uploaded this to crates.io because I was having some issues cross compiling with local dependencies. If anyone wants to use the name for something actually useful, DM me on github
-
wasmflow-streams
encapsulating the message packets sent across Wasmflow components
-
peace_item_spec_file_download
Manages downloading a file for the peace framework
-
async-ops
Use std::ops traits with Futures
-
mofo
Multiple Ongoing Futures Object - an abstraction for easily managing ongoing child tasks with futures
-
act-zero
Ergonomic actor system
-
tokio-lock
Access an object from a single Tokio task
-
jsonrpc-rs
Futures base jsonrpc server/client framework
-
unsync
Unsynchronized synchronization primitives for async Rust
-
yew-interop
use javascript and css asynchrously in yew
-
rxqlite-lite-common
A distributed sqlite database built upon
openraft
,sqlx
andsqlite
-
ipc-orchestrator
Orchestion of command line processes for local dev usage with IPC communication
-
enjoin
Powerful syntax-level async join macro
-
deadpool
Dead simple async pool
-
pinarcmutex
PinArcMutex
type, for shared mutable access to pinned data -
embedded-hal-async
An asynchronous Hardware Abstraction Layer (HAL) for embedded systems
-
jarust
A janus client SDK in Rust
-
browser-window
optionally async, optionally threadsafe, electron-like browser toolkit for Rust
-
aral-runtime-tokio
Aral Runtime for tokio
-
manual-executor
Async executor with manual waking
-
batchloader
A type-safe async request batcher based on facebook's dataloader
-
tokio-named-pipes
Windows named pipe bindings for tokio
-
async-signal
Async signal handling
-
blocking-reader
read a file async, will log last read seek and skip to last read when in a loop
-
catty
Send and await a value asynchronously
-
rustmark
Extensible web application for serving Markdown-based content
-
hakuban
Data-object sharing library
-
dynamodb-mutex
Use Dymanodb mutex library
-
asygnal
[WIP] Async-first signal handling, such as ctrl-c
-
projections
Macro-free pin projections because why not?
-
cute-async
Cute async utilities
-
quicksink
Create a Sink from some value and a closure returning a Future
-
taos
Driver for TDengine - a timeseries database and analysis platform
-
tarpc
An RPC framework for Rust with a focus on ease of use
-
futuredsp
A signal processing library for SDR and real-time DSP
-
tower-pipeline
A Tower Service combinator that "pipelines" two services
-
duplexify
Combine a reader + writer into a duplex of Read + Write
-
scoped_tasks_prototype
A quick-and-dirty attempt to get scoped tasks in Rust
-
paranoid-hash
A Hashing Library For Those Paranoid With Their Security
-
mqtt_actor
An mqtt adapters (from port and adapters) to be used with actix actors
-
tk-easyloop
A thread local loop and other loop helpers
-
bottle
Actor model framework for Rust
-
async-throttle
Asynchronous Rate Limiting
-
aiur
Single threaded async executor with structured concurrency
-
rmp-futures
Async Rust MessagePack and MessagePack-RPC
-
futures-time
async time combinators
-
async-ioutil
A collection of Rust asynchronous I/O utilities
-
mai
A higher-level mio interface
-
wgp
waitgroup implementation
-
async-mq
Zero-cost async-await abstraction of lapin AMQP client crate
-
money2
For storing and asynchronously converting between (a subset of) ISO-4217 currencies
-
callysto-avro
Avro serde for Callysto Stream Processing Framework
-
osaka
async for rust without the noise
-
sync_stream
Aggregate multiple streams by polling stream items in order, keeping the consumption of multiple streams in sync
-
subtr-actor
Rocket League replay transformer
-
geese_executor
Asynchronous executor with Geese event system integration
-
bipe
asynchronous I/O pipe
-
tokio-smoltcp
An asynchronous wrapper for smoltcp
-
asyncio-utils
Support limit,skip on AsyncRead traits
-
capp
Common things i use to build Rust CLI tools for web crawlers
-
af-core
A core library and async runtime for Rust applications
-
promises
Effective, simple, lightweight Javascript promises in Rust
-
retry_async
retrying, with specific support for the Azure SDK for Rust (cf. https://github.com/Azure/azure-sdk-for-rust).
-
async-zeroconf
Async library for wrapping Zeroconf implemenations for use with Tokio
-
completeio
Completion based IO drivers and async runtime
-
async-instrumenter
A wrapper over futures which allows to time how long the future takes to execute
-
tower-make
Trait aliases for Services that produce specific types of Responses
-
message_worker
Message Worker is a low-ish level library for Rust for the creation of event-listeners using futures and streams. Notably MW supports non-sync and non-send (i.e. non-thread-safe) contexts within listeners.
-
django-query
Tools for mocking Django-style endpoints
-
gmf
An RPC library using Glommio and Tonic. Note: This package only works on Linux.
-
nasu
Command-line utility which poll on remote addresses in order to perform status checks periodically
-
transform-stream
Lightweight async stream wrapper
-
log-tracing-layer
Build your own custom tracing layer
-
fibers_inotify
A futures friendly inotify wrapper for fibers crate
-
vkteams-bot-cli
VK Teams Bot API CLI
-
otdb
An open trivia database API wrapper
-
image_search
designed to search Google Images based on provided arguments
-
tokio-xmpp
Asynchronous XMPP for Rust with tokio
-
wasmcloud-interface-sleepy
Interface for interacting with the sleepy capability provider
-
lnd_grpc_rust
An async library implementing LND RPC via tonic_openssl and prost
-
ector
open source async, no-alloc actor framework for embedded devices
-
tokio-into-sink
convert a tokio::io::AsyncWrite into a futures::Sink for bytes
-
faktory
API bindings for the language-agnostic Faktory work server
-
cache_loader_async
A thread safe loading cache with async loader functions based on tokio
-
stream-rate-limiter
A rate limiter for Tokio streams
-
serial-io
A serial port implementation
-
broker-tokio
tokio for broker
-
jenner
Tools for working with generators to work with both iterators and streams
-
stream-operators
a collection of selected rxjs operators for rust standard Stream
-
simple-actor
Helper to write actor-based async code
-
tokio-shared-udp-socket
Easily share a UDP socket between different futures in tokio
-
gpiocdev
access GPIO lines on Linux using the GPIO character device
-
async-hid
A async library for interacting with HID devices
-
tokio-iocp
IOCP support for the Tokio asynchronous runtime
-
hash_cons
A type-safe hash-cons library
-
futures-test-sink
Test utilities for futures::sink
-
dbus-async-derive
Handler trait derive macro for dbus-async
-
kabuki
Name reservation
-
tus_async_client
native async client library to interact with *tus* enabled endpoints
-
limited-join
A zero-dependency crate providing a join future with limited concurrency
-
tor-events
A typed event broadcasting framework for Arti
-
async-drop-guard
offers hash map and cache data structures where individual entries can be locked
-
alicemq
Wapper for the amqprs rabbitMQ library
-
rust-gpt
interaction with the Completion/Chat OpenAI API
-
suspend
A common mechanism for suspending a thread or a Future until notified
-
epoxy_frp
The Reactive Glue for Frontend Applications
-
thread_runner
executing tasks concurrently
-
rusty-gql
Schema first GraphQL Library for Rust
-
execution-engine
Toca Execution Engine implemented using Futures and async/await
-
futures-state-stream
A version of the futures crate's Stream which returns state on completion
-
assets
asynchronous asset management
-
async-hofs
Various extention traits for providing asynchronous higher-order functions
-
compio-fs
Filesystem IO for compio
-
tracing-layer-slack
Send filtered tracing events to Slack
-
amqp-manager
Lapin wrapper that encapsulates the use of connections/channels and creation of amqp objects
-
async-circe
IRC crate in Rust
-
noosphere-core
Core data types of the Rust Noosphere implementation
-
intervalier
Interval events with handling notifications
-
safina-threadpool
Safe thread pool
-
tokio-snappy
Wrap rust-snappy as a async stream in tokio
-
makiko
Asynchronous SSH client library in pure Rust
-
deploy-common
Common components for the
deploy
andfabric
crates -
winit-runtime
Async winit runtime
-
lsp-codec
Tokio-compatible codec implementation for Language Server Protocol
-
actix-raft
Raft distributed consensus protocol using the Actix actor framework
-
gearbox
Excessive tooling for Rust, boosting productivity and operations
-
felixs-tower-lsp
Language Server Protocol implementation based on Tower
-
hitbox-actix
Asynchronous caching framework for Actix
-
sync-async-runner
Run async functions synchronously (like coroutines)
-
rs-car-ipfs
rs-car wrapper to read files from IPFS trustless gateways
-
axum-serde
multiple serde-based extractors / responses for the Axum web framework, also offers a macro to easily customize extractors / responses
-
futures-promises
Promises and Watched Variables for Futures
-
futures-cputask
Turn synchronous CPU-bound tasks into futures
-
iterstream
Converts Iterator into real asynchronous Stream
-
tasktrace
Logical 'backtraces' of async tasks
-
hypixel
Rust wrapper for the Hypixel public API
-
vampirc-io
asynchronous, non-blocking, UCI protocol–based communication between chess UIs and chess engines
-
aggligator
Aggregates multiple links (TCP or similar) into one connection having their combined bandwidth and provides resiliency against failure of individual links
-
hala-future
hala asynchronous programming primitive types
-
heph-rt
speciailised runtime for Heph's actor
-
zippyst
Resolve zippyshare.com download links
-
tokio-async-write-utility
Some helper functions for types impl AsyncWrite
-
spin_future
Convert synchronous functions into valid but inefficient futures
-
bevy-tokio-tasks
integration of a Tokio runtime into a Bevy app for background processing
-
kompact-component-derive
A derive macro for Kompact component definitions
-
srmw
Asynchronous single-reader, multi-writer
-
futures-option
Extension traits for dealing with optional futures and streams
-
variable-len-reader
reading/writing variable length data. Support AsyncRead/AsyncWrite in tokio.
-
tokio-transports
used for communication between processes
-
june
ergonomic remote actors via actix and canary
-
monzo-lib
async Monzo client in pure rust
-
tonic_lnd
An async library implementing LND RPC via tonic and prost
-
fg-uds
Asynchronous unix domain socket running on the futures-glib main loop
-
settimeout
Creates a std::future::Future implementation to be ready at some point
-
compio-buf
Buffer trait for completion based async IO
-
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.
-
itla
ITLA (micro laser) non-blocking control library using embedded-hal
-
tokio-rustls-acme
Automatic TLS certificate management using rustls
-
ate
Distributed immutable data store with strong encryption and authentication
-
tripwire
makes futures pre-emptible
-
async-pidfd-next
Process file descriptors (pidfd) for Linux
-
rust-runc
consuming the runc binary in your Rust applications
-
hl7-mllp-codec
A Tokio codec for HL7 Minimal Lower Layer Message Transport protocol (MLLP)
-
streem
creating and consuming streams
-
tower-limit
Limit maximum request rate to a
Service
-
futures-task
Tools for working with tasks
-
tokio-pty-process-stream
wraps tokio-pty-process in order to provide a simpler API as a single stream object
-
safe-vk
create your own vk bot for conversations
-
eventsource-stream
A basic building block for building an Eventsource from a Stream of bytes
-
rust-multipart-rfc7578_2
multipart/form-data (RFC7578)
-
veilid-async-tls
Asynchronous TLS/SSL streams using Rustls
-
yaaf
Actor Framework
-
dtbh_interface
Interface library for the automated scanner
-
openrazer
Asynchronous bindings to the OpenRazer daemon
-
embassy-time
Instant and Duration for embedded no-std systems, with async timer support
-
relm
Asynchronous, GTK+-based, GUI library, inspired by Elm, written in Rust
-
async-http-body
Agit init HttpBody Support Async Expressions
-
async-graphql-relay
Relay support for async-graphql
-
tokio-rustls-fork-shadow-tls
Asynchronous TLS streams wrapper for Tokio based on Rustls
-
stomp
A full STOMP 1.2 client implementation. Allows programs to interact with message queueing services like ActiveMQ and RabbitMQ.
-
mailfred
Process emails as an HTTP server
-
bacon-ls
Bacon Language Server
-
syncthing
controlling syncthing file synchronization through its REST interface
-
lunatic-messaging-api
Lunatic host functions for message sending
-
kay
Experimental high-performance actor system framework for Rust
-
proq
Idiomatic Async Prometheus Query (PromQL) Client for Rust
-
async-stdin
Asynchronously read from stdin
-
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. -
futures-io-preview
The
AsyncRead
andAsyncWrite
traits for the futures-rs library -
futures-util-io-peek
AsyncPeek trait
-
actix-ogn
OpenGliderNetwork client based on actix
-
medusa-zip
A command-line interface to high-performance parallelized implementations of common zip file operations
-
arta
Async runtime abstractions library
-
client-handle
A macro to generate client handles when using multithreaded / asynchronous code
-
async-io-traits
Async versions of io traits
-
ssip-client-async
Client API for Speech Dispatcher
-
rs-firebase-admin-sdk
Firebase Admin SDK for Rust
-
akinator-py
Python bindings for akinator-rs
-
ntex-files
Static files support for ntex web
-
dioxus-query
Fully-typed, async, reusable cached state management for Dioxus 🧬
-
bevy-wasm-tasks
integration of WASM tasks into a Bevy app for background processing
-
mediatrix
Strongly typed, extensible event mediator
-
async-middleware
async monad(ish) middleware in Rust using tuples and async trait transforms
-
rillrate-system
RillRate agent for system monitoring
-
tauri-specta
Completely typesafe Tauri commands
-
bme280-rs
query BME280 sensors over I²C
-
dummy-waker
Get a
core::task::Waker
that does absolutely nothing -
async-read-length-limit
limit the size of an async read
-
gdext_coroutines
Run Rust Async functions and Coroutines in Godot 4.2+ (through GDExtension), inspired on Unity's Coroutines design
-
generic-api-client
A client for HTTP/HTTPS/WebSocket APIs
-
async-read-util
A collection of utilities for working with AsyncRead
-
deadpool-bolt
A bolt-client manager for the deadpool connection pool
-
ero
Erlang-inspired framework for organizing async code in a fault-tolerant way
-
crdts
Practical, serializable, thoroughly tested CRDTs
-
graus-db
A high-performance, thread-safe key-value embedded data store
-
heim-disk
Cross-platform disk information
-
mutex-extra
RefMutex<T>
that is similar toMutex<T>
but isSync
andSend
even ifT
isn’tSend
-
grpcio
language implementation of gRPC, base on the gRPC c core library
-
zksync_consensus_network
ZKsync consensus network actor
-
rustls-acme
TLS certificate management and serving using rustls
-
scoped_spawn
Full structured concurrency for asynchronous programming
-
bridge_updater_lib
A helper library to get Tor bridges with ease
-
cucumber-codegen
Code generation for
cucumber
crate -
rust-cli-commands
-
conquer-struct
macros to perform concurrent future resolution, while populating struct fields
-
mysql_async_uu
Tokio based asynchronous MySql client library
-
minicoro-sys
rust binding to minicoro
-
fluke-maybe-uring
Replicates some tokio-uring types to allow building code without it
-
libpool
threadpool from The Rust Programming Language
-
async-stream-http-tunnel-grader
Asynchronous stream http tunnel grader
-
skrillax-stream
Combines skrillax-network crates to work nicely on top of a tokio tcp stream
-
logged-stream
Logging of all read/write operations, errors and drop of underlying IO object
-
real-async-trait
A proc macro that uses experimental features to work around type erasure for async traits
-
f289ctrl
Communication library for Fluke 289 digital multimeter
-
mycelium_lib
Mycelium DDM
-
tokio-resource-pool
A generic resource pool for the Tokio ecosystem
-
async-openai-wasi
Async bindings for OpenAI REST API based on OpenAPI spec
-
pinned
Synchronisation primitives for !Send tasks
-
archlinux-repo
Arch Linux repositories parser
-
stun-client
async_std based asynchronous STUN client library
-
async-ioutils
A collection of async utilities for I/O
-
async-codec-lite
Adaptors from AsyncRead/AsyncWrite to Stream/Sink using futures
-
zonyitoo/coio
Coroutine scheduler with non-blocking I/O support
-
tokio-prepend-io
Wrapper types that prepends data when reading or writing with AsyncRead or AsyncWrite
-
tokio-takconnect
Asynchronous Playtak client
-
tokio-shield
Prevent futures from being aborted by wrapping them in tasks
-
async-pidfd
Process file descriptors (pidfd) for Linux
-
bililive
stream-based bilibili live client library
-
streamify
Conversions from values to Stream
-
tokio-futures-respawn
function to respawn failed long running tasks
-
backdrop
Drop your large or complex objects in the background with Backdrop! (later, on another thread, or both! Fully customizable! Tokio supported!)
-
rtx
zero-cost runtime-abstraction intended for use by Rust libraries to enable the Freedom of Choice between asynchronous runtimes
-
bawawa
Opinionated set of tools to manage and compose process executions
-
bader-db
Key-value cache RESP server with support for key expirations
-
ex-futures
An extension of
futures
-
mobc-forked
A generic connection pool with async/await support
-
async-stream-tls-upgrader
Asynchronous stream tls upgrader
-
futures-shuttle
Futures-aware shuttle synchronization object
-
join
Macros which provide useful shortcut combinators, combine sync/async chains, support single and multi thread (sync/async) step by step execution of branches, transform tuple of results in result of tuple
-
plumb
A functional, async pipeline framework
-
gjio
Asynchronous input and output
-
fd-queue
support fd passing on Unix sockets
-
stick
Platform-agnostic asynchronous gamepad, joystick and flighstick library
-
incoming
Trait for taking ownership of a stream of incoming connections
-
garcon
A collection of trait and classes to make your thread or async function wait
-
thespis
The interface of the thespis actor model (contains only traits)
-
takyon
single threaded async runtime
-
async-task-ffi
Task abstraction for building executors
-
rama
modular service framework
-
eventastic
opinionated fork of Eventually-rs. It enforces the use of transactions and handles idempotency.
-
melodium-macro
Macro tooling for compiled Mélodium packages
-
monoio-io-wrapper
A read/write wrapper to bridge sync and async io
-
completion-io
Core traits and types for asynchronous completion-based I/O
-
egui_inbox
send messages to egui views from async functions, callbacks, etc. without having to use interior mutability.
-
atomic-waker
A synchronization primitive for task wakeup
-
async-trait
Type erasure for async trait methods
-
packet-ipc
Share packets between services using servo ipc
-
tractor
Actor system modelled after Pony's actors
-
switch-resume
Delimited async continuations
-
dndx-fork-tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
unix-udp-sock
async & sync UDP sockets supporting sendmsg/recvmsg and src IP manipulation
-
activitystreams-types
Base types from the Activity Streams spec
-
tokio-macros
Tokio's proc macros
-
icee-rabbit-rs
Wrapper for async-amqp (lapin)
-
switchyard
Real-time compute focused async executor
-
shared_stream
easily cloneable streams
-
hentai
API wrapper for nhentai.net
-
tokio-tls-gmssl
TLS/SSL streams for Tokio using native-tls giving an implementation of TLS for nonblocking I/O streams
-
async-fd-lock
Advisory cross-platform file locks using file descriptors with async support by spawning blocking tasks
-
async_repeat
Retry futures mechanism
-
memphis-rust-community
Memphis Messaging Protocol
-
async-i3ipc
Bindings for i3 and async-std allowing async applications to communicate with i3 over it's IPC interface. Contains futures implementations and convenience functions for working with i3.
-
epoxy_streams
Base streams implementation for the
epoxy_frp
library. Please use epoxy_frp instead. -
runtime-loop
Runtime loop for Rust
-
mt_logger
A low-dependency, multithreaded logging library with a focus on traceability and ease-of-use via macros
-
bookkeeper-client
Async rust client for Apache BookKeeper
-
actix-broker
Message broker for the Actix actor framework
-
rxqlite-sqlx-common
A distributed sqlite database built upon
openraft
,sqlx
andsqlite
-
holidayapi_rust
A HolidayAPI library for Rust
-
bevy_async_system
ability to wait for game status asynchronously
-
deadline
A one-macro crate to ensure assertions meet their deadlines
-
azur
A no_std Rust crate that implements an executor/reactor and futures using io_uring
-
twilight-lavalink
Lavalink client for the Twilight ecosystem
-
peace_item_sh_cmd
Manages running a shell command for the peace framework
-
again
wasm-compatible retry util for std library futures
-
tempest
Realtime message handling framework inspired by Apache Storm and built with Actix
-
ws-gonzale
Naive websocket server implemented using async / await
-
throttled-reader
An io::Read proxy that limits calls to read()
-
stewart-utils
Small common utilities for stewart
-
aector
Dynamic implementation of the actor model with a smart built-in testing framework
-
eventually-redis
Event Store implementation using Redis, for Eventually crate
-
epics-ca
Client library for EPICS Channel Access protocol
-
weighted-select
futures::stream::Select with weights
-
emitter-rs
📢 Emitter RS is a lightweight EventEmitter implementation for Rust and Wasm
-
vanilla_tokio_actor
Vanilla Tokio Actor
-
tower
modular and reusable components for building robust clients and servers
-
local-spawn-pool
Spawn
!Send
futures in a pool and await for all of them to finish. Standalone alternative totokio::task::LocalSet
. -
verypoll
Very polling library
-
rtix
Actors with generators. Name up for grabs until I do something with it, or rust supports proper coroutines
-
fourche
task queue named after a lion with forked tail (queue fourché), works with Redis
-
tower-async-hyper
Bridges a
tower-async
Service
to be used within ahyper
(1.x) environment -
wasmflow-traits
encapsulating the message packets sent across Wasmflow components
-
async-events-emitter
providing an implementation of an event handling system
-
paggo
A small, fast, and safe in-memory database
-
ruserf
A decentralized solution for service discovery and orchestration that is lightweight, highly available, and fault tolerant
-
rt-local-core
Thread local asynchronous runtime working with platform-specific event loops
-
sampr
A message passing framework using actors
-
restapi
A secure-by-default rest api using hyper, tokio, bb8, kafka-threadpool, postgres, and prometheus for monitoring
-
async-pipe
Creates an asynchronous piped reader and writer pair using tokio.rs
-
fmmap
A flexible and convenient high-level mmap for zero-copy file I/O
-
rosey-actors
Actor framework
-
retry_fn
retry function with versions for blocking or non-blocking, tokio or async-std
-
agner-test-actor
An actor toolkit inspired by Erlang/OTP (test-actor)
-
async-tick
tick clock
-
fil_actors_runtime_v9
System actors for the Filecoin protocol
-
elfo-test
Test utils for the elfo system
-
signald-rust
interface with Signald
-
rusty-penguin
A fast TCP/UDP tunnel, transported over HTTP WebSocket
-
jarust_plugins
A janus client SDK in Rust
-
hyper-http-proxy
A proxy connector for Hyper-based applications
-
desaturate
This package aims to makes it easier to maintain a single code base for both regular and async functions
-
actix-ws-ng
WebSockets for Actix Web, without actors
-
async-shell
Asynchronous process child wait
-
py_mcai_worker_sdk
AMQP Worker to listen and provide trait to process message
-
dbus-tokio
Makes it possible to use Tokio with D-Bus, which is a bus commonly used on Linux for inter-process communication
-
samotop
SMTP server and library built on async-std
-
smol-hyper
Integrations between smol and hyper
-
fibers_tasque
A
tasque
extension specialized forfibers
-
stalk
sending serialized data with tokio
-
volo
high-performance and strong-extensibility Rust RPC framework that helps developers build microservices
-
actix-async-await
Experimental async/await support for Actix
-
chikatetsu
An(other) actor framework for Tokio
-
ttl_cache_with_purging
A time-to-live (TTL) cache implementation with optional background purging for expired entries
-
rexie
futures based wrapper around IndexedDB that compiles to webassembly
-
viaduct
A duplex communication channel between a parent and child process, using unnamed pipes
-
vino-packet
encapsulating the message packets sent across Vino components
-
libp2p-dns
DNS transport implementation for libp2p
-
tokio-beanstalkd
Asynchronous client library for interacting with Beanstalkd work queue
-
pin-utils
pinning
-
evermore
allowing you to run an fixed number of asynchronous task repeatedly until a shutdown signal is sent out
-
hyper_lua_actor
Binding of lua_actor & hyper
-
papaleguas
ACME client
-
async_event_streams
Asynchronous Events Pub/Sub Library
-
simple-process-stats
Get memory usage and CPU time on Linux and Windows
-
hyper-multipart-rfc7578
multipart/form-data (RFC7578) for Hyper
-
async-rustls-stream
An async tls stream library based on rustls and futures-io. Both for server/client.
-
local-pool-with-id
A minor variation on a LocalPool executor which exposes unique IDs for tracking future completion
-
tokio-utun
Utun bindings for Tokio
-
async-graphql-axum-wasi
async-graphql for axum
-
async-weighted-semaphore
An async weighted semaphore
-
ginepro
A client-side gRPC channel implementation for tonic
-
opentls
TLS connections with OpenSSL
-
northstar-rcon-client
Asynchronous RCON client for the Northstar mod
-
futurify
Convert your sync functions into non-blocking thread futures
-
noosphere-fs
A high-level, FS-like view over Noosphere content
-
tower-sessions-dynamodb-store
AWS DynamoDB session store. Not for direct use; see the
tower-sessions
crate for details. -
async-graphql-viz
async-graphql for viz
-
ara
Async random access I/O traits
-
logic-mesh
Control logic engine using event based and reactive blocks written in Rust
-
redis-asio
Asynchronous Redis driver based on tokio
-
meltdown
A lightweight service manager to help with graceful shutdown of asynchronous applications
-
online
📶 Library to check your Internet connectivity
-
noosphere-into
Transformations of Noosphere content into various target formats
-
tracing-layer-core
Send filtered tracing events to a webhook endpoint
-
async-dup
Duplicate an async I/O handle
-
waitfor
Retry a function until it succeeds, errors out, or a timeout/deadline is reached
-
async-dropper-simple
struct-wrapper (i.e. AsyncDropper<T>) based implementation of AsyncDrop
-
ruyi
An event-driven framework for non-blocking, asynchronous I/O in Rust
-
elk-mq
A Message Queue implementation in rust, using Redis as a communication medium
-
async-gitlib
Asynchronous library with libgit2 artifacts
-
skipdb-core
The core for
skipdb
andasync-skipdb
crates -
cache-compute
implements request/async computation coalescing
-
basteh
Generic kv storage with replaceable backend
-
yrs
High performance implementation of the Yjs CRDT
-
ruchei-extra
Stream/Sink wrapper with extra data, as used by ruchei
-
safina-executor
Safe async runtime
-
sigfinn
Lifecycle manager for spawning tasks
-
nrf24radio
Asynchronous embedded driver for NRF24L01(+) devices
-
jelastic-rs
Rust wrapper for the Jelastic API
-
async-resource
Async resource pool
-
wombo
managing event loop threads
-
async-trait-ext
a procedural macro for async traits
-
client-util
Help you to build requests and handle responses by several extension trait!
-
associated-async-io
Async IO traits that use futures instead of poll
-
crypto-auditing
Client library for crypto-auditing project
-
completeq-rs
An alternative to passing messages between asynchronous tasks
-
tonic-middleware
Async middleware and interceptor for Tonic services
-
count-write
An io::Write wrapper counting the number of bytes written
-
actix_derive
Derive macros for
actix
actors -
agilulf_protocol
Agilulf Protocol serializer and deserializer
-
tower-buffer
Buffer requests before dispatching to a
Service
-
async-graphql-extension-apollo-tracing
An async_graphql extension to send traces & metrics to Apollo Studio
-
json-array-stream
Incrementally reads a JSON array through an async stream
-
compio-process
Processes for compio
-
async-core
A standard for async runtimes
-
openraft-rocksstore-compat07
A example v07 compatible implementation of the
openraft::RaftStorage
trait -
awaitable-error
Awaitable type with input and output that can be stored in container
-
futuresdr-remote
Remote interaction library for FutureSDR
-
telers
An asynchronous framework for Telegram Bot API written in Rust
-
async-reactor-trait
reactor-trait implementation for async-io
-
aster-proxy
A light, fast and powerful cache proxy written in Rust
-
rados_hi
Opinionated high-level wrapper for librados (Ceph)
-
cancellable-timer
A timer that can be interrupted
-
f1-api
F1 API is a client library for the telemetry API of the F1 video games by Codemasters. It uses asynchronous networking to decode the incoming UDP packets, and turns them into strongly typed Rust structs.
-
fut-compat
Offers compatibility between the tokio and async_std runtimes
-
name_locker
interface for asynchronous name lockers, that can run an async task with lock on a given name
-
lease
Object pool that leases values and automatically returns them with async support
-
linux-io-uring
The
io_uring
library for Rust -
monoio-rustls-fork-shadow-tls
Asynchronous TLS streams wrapper for Monoio based on Rustls
-
kay_codegen
Code generation for implementing kay actors
-
relock
Distributed async locking using Redis
-
awaken
Coalescing cross-thread wakers for mio and io_uring
-
tk-bufstream
A buffered stream backed by contiguous buffers (netbuf) for tokio
-
file-descriptors
Wrapper around the common kinds of (mostly Linux) file descriptors, including sockets, pipes, FIFOs, terminals, serial ports, character devices, epoll, POSIX message queues, timerfd…
-
indexed-db
Bindings to IndexedDB that default the transactions to aborting and can work multi-threaded
-
tokio-mockstream
A fake stream for testing network applications backed by buffers
-
openssh-mux-client
openssh mux client
-
reqwest-eventsource
Helper to build an Eventsource using reqwest
-
pcap-async
Async/Stream Extensions for libpcap
-
feature-extension-for-async-std
Feature extension for async-std
-
aral-runtime-noop
Aral Runtime for noop
-
async_main
Runtime-agnostic async main proc macro
-
async-diesel
Integrate Diesel into async-std cleanly and efficiently
-
tokio-hglib
Tokio-based async client library for Mercurial command server
-
minehut
easy to use Rust wrapper for the Minehut API
-
tls-async
TLS support for AsyncRead/AsyncWrite using native-tls
-
spawns-compat
Async runtime detections for thread context task spawner
-
kvarn_async
Async utilities used in the Kvarn web server
-
isostatic
minimal url shortner
-
greenthread-future
Convert closures to futures based on greenthread on bare-metal (no_std + no_alloc)
-
async-http-client-lite
Asynchronous http client
-
oso-cloud
Oso Cloud client
-
strife
A lightweight library for the Discord API
-
etcd-rs
etcd client for rust
-
orcinus
async-ready mysql protocol implementation / wrapper libraries
-
mobc-bolt
A bolt-client manager for the mobc connection pool
-
async-entry
extended Tokio's proc macros
-
axum-sessions
🥠 Cookie-based sessions for Axum via async-session
-
futures-utils-lite
futures about utils in lite
-
mio-anonymous-pipes
Asynchronous wrapper for windows synchronous pipes
-
ratchet_rs
Async WebSocket implementation
-
fast_websocket_client
A fast asynchronous websocket client built on top of fastwebsockets library
-
kad
A generic / futures based implementation of the Kademlia Distributed Hash Table (DHT)
-
edge-dhcp
Async +
no_std
+ no-alloc implementation of the DHCP protocol -
tower-redis
A Tower service for asynchronous Redis request/response performed over a managed, multplexed connection
-
opencl-sys
OpenCL C FFI bindings for the Rust programming language
-
jstream-ext
adds some extra extensions to futures Stream traits
-
tes3mp-plugin
Stubs for creating a TES3MP server plugin
-
forceps
async & on-disk database
-
fundamentum-edge-mcu-http-client
An HTTP Client for provisioning EdgeMCU devices
-
eventually
using Event Sourcing in Rust applications
-
its_ok_to_be_block_on
A minimal implementation of block_on, to execute futures in a syncronous context
-
wasm-agnostic
users who want to write async runtime-agnostic crate for wasm target
-
mogwai
The minimal, obvious, graphical, widget application interface
-
must-done
An experimental Future that is guaranteed to be done
-
safina-async-test
Macro for running async tests
-
awaitable-bool
A Tokio-powered awaitable bool (analogous to a flag and highly inspired by Python’s
asyncio.Event
, but can be waited for to become ‘false’ too) -
derive-tokio-io
Derive AsyncRead and AsyncWrite
-
heim-net
Cross-platform network information
-
embassy-futures
no-std, no-alloc utilities for working with futures
-
agner-init-ack
An actor toolkit inspired by Erlang/OTP (init-ack)
-
connection
A TCP connection that can read and write serializable data
-
reducer
A predictable reactive framework for Rust apps
-
bidirectional-channel
A channel where receivers can respond to a message, and senders can wait for a response
-
recursive_scraper
Constant-frequency recursive CLI web scraper with frequency, filtering, file directory, and many other options for scraping HTML, images and other files
-
gneiss-mqtt
Asynchronous and threaded MQTT(5) clients
-
bing_client
Async reverse client for Bing copilot
-
agreed-memstore
An in-memory implementation of the
agreed::RaftStorage
trait. Fork of async-raft’s memstore crate. -
sn_data_types
Safe Network Data Types
-
attempt
do something over and over and over and over and
-
workflow-async-trait
Type erasure for async trait methods (customized, see README.md notes)
-
comet-eventbus
strong-typed sync and asynchronous eventbus
-
signalr_rs
SignalR client based on actix web client and async await
-
futures-jsonrpc
Futures implementation for JSON-RPC
-
taskwait
Runtime agnostic way to wait for a group of async tasks
-
heim-virt
Cross-platform virtualization system detection
-
holly
A simplistic actor model library using futures
-
batched-fn
Middleware for serving deep learning models with batched prediction
-
elfo-utils
Some utils for the elfo system
-
tower-reqwest
Adapter between reqwest and tower-http crates
-
concurrent_tor
An asynchronous implementation of multiple tor clients, with a dispatcher which can pass requests by a user-defined queue
-
executor-trait
A collection of traits to define a common interface across executors
-
pingora-boringssl
BoringSSL async APIs for Pingora
-
ctrlgen
Generate enums for message-passing services
-
akt
An actors library for Rust and Tokio designed to work with async / await message handlers out of the box
-
thalo
A high-performance event sourcing runtime utilizing WebAssembly an embedded event store
-
safina-net
Safe async network functions
-
async-graphql-derive
Macros for async-graphql
-
mysql_async_wasi
Tokio based asynchronous MySql client library
-
mini-tokio
Basic asynchronous rust executor
-
activitystreams-traits
Traits for ActivityStreams 2.0 objects
-
fizyr-rpc
Native Rust implementation of the Fizyr RPC protocol
-
async-subscription-map
Async bookkeeping datastructure for state subscriptions
-
docker_engine_api
way to interact with the Docker Engine API
-
gtk-future-executor
basic building blocks for writing async GUI code with Gtk-rs
-
peace_item_file_download
Manages downloading a file for the peace framework
-
absinthe
Are you an Actor & Async junkie? Then your app needs some Absinthe!
-
atedb
Distributed datachain (database) built on an immutable data store with strong encryption and authentication
-
rdbc-rs
Futures base Rust DataBase Connectivity (RDBC) library
-
carrot-cake
An a-peeling pub/sub framework
-
specta-typescript
Export your Rust types to TypeScript
-
beul
It executes futures
-
futures-stream-select-ext
futures::stream::select Ext
-
aspartam
Minimalistic actor framework based on tokio, inspired by actix
-
agner-reg
An actor toolkit inspired by Erlang/OTP (reg)
-
puddle
object pool implementation that uses asynchronous synchronization primitives only
-
gwyh
sweet gossip library
-
supplicant
Bindings for wpa_supplicant
-
future-result
An ideomatic way of mapping a Result to a Future of Result
-
tabs
A collection of asynchronous task abstractions, based on tokio
-
async-graphql
A GraphQL server library implemented in Rust
-
smartpoll
A 'Task' abstraction that simplifies polling futures
-
stry-evermore
allowing you to run an fixed number of asynchronous task repeatedly until a shutdown signal is sent out
-
tower-sessions-sqlx-store
SQLx session stores for
tower-sessions
-
volo-thrift
Thrift RPC framework implementation of volo
-
aktrs
An actor model framework for Rust
-
ksqldb
A thin wrapper around the KSQL DB REST API to make it more ergonomic to work with
-
quinn
Versatile QUIC transport protocol implementation
-
actix-limitation
Rate limiter using a fixed window counter for arbitrary keys, backed by Redis for Actix Web
-
clia-ntex-files
Static files support for ntex web
-
async-compression
Adaptors between compression crates and Rust's modern asynchronous IO types
-
posixmq
An idiomatic library for using posix message queues, with optional mio integration
-
rseip-eip
encapsulation protocol for rseip
-
waker-set
waker set
-
cdrs-tokio
Async Cassandra DB driver written in Rust
-
tokio-native-tls
TLS/SSL streams for Tokio using native-tls giving an implementation of TLS for nonblocking I/O streams
-
salvo-serde-util
serde util for salvo
-
tokio-utils
Tools for asynchronous programming in Tokio applications
-
fil_actors_runtime_v10
System actors for the Filecoin protocol
-
futures-to-stream
Turn heterogeneous Futures of same associated Output type to a stream
-
lazy-queue
Futures-driven lazy queue processing
-
hyper-async-io
that provides an interface to AsyncRead and AsyncWrite for Hyper's Body
-
bb8-mongodb
bb8 connection pooling impmentation for the MongoDB database
-
compio-runtime
High-level runtime for compio
-
atm-async-utils
implementing and testing futures::Sink and futures::Stream related code
-
agency
A small async actor framework
-
tokio-buf
Asynchronous stream of byte buffers
-
linux-io-uring-sys
The
io_uring
bindings for Rust -
promising-future
Promise/Future pairs
-
nostr-bot
Nostr bot library
-
heim
Cross-platform framework for system information
-
luarmor
API wrapper for luarmor.net
-
tokio-timerfd
timerfd support for tokio
-
async_buf_reader_utils
Adds additional functionality to the async-std crate for BufReader
-
fil_actors_runtime_v8
System actors for the Filecoin protocol
-
stream-flatten-iters
Flattens a stream of iterators into one continuous stream
-
mfio-rt
mfio based async runtime
-
aral-runtime-async-std
Aral Runtime for async-std
-
safina-select
Safe async select function, for awaiting multiple futures
-
mega_etl
A cloud-native ETL (Extract, Transform, Load) application framework based on the WasmEdge WebAssembly runtime for developers to filter, map, and transform data pipelines going into cloud databases
-
futures-length-delimited-frame
Frame a stream of bytes based on a length prefix
-
daku
Interface to the Daku API
-
noosphere-storage
Pluggable backing storage for the Rust Noosphere implementation
-
pyo3-anyio
PyO3 utility bindings for Anyio's event loop
-
async-component-components
async-component components
-
seal_rs
Set of classic asynchronous primitives (Actors, Executors, Futures / Promises)
-
backstage
A framework for building data-driven distributed systems
-
implicit-await
Implicitly await calls returning Future impls
-
handy_io
A handy pattern and futures based asynchronous I/O library
-
tower-async-http
Tower Async middleware and utilities for HTTP clients and servers. An "Async Trait" fork from the original Tower Library
-
kyansel
Cancellable future. Provide a future as argument and the current future will cancel if the provided future resolves first
-
register-count
Counting
Register
s created by aCounter
-
ockam_transport_uds
Unix Domain Socket (UDS) Transport for the Ockam Routing Protocol
-
async-priority-queue
An async-aware priority queue
-
futures-fs
A Futures implementation for File System operations
-
future-bool
A bool one can await the changes
-
marzban_api
async client which abstracts/simplifies the interactions with the Marzban panel API (https://github.com/Gozargah/Marzban)
-
futures-stream-reader
Convert an [AsyncRead] into a [Stream] of byte chunks
-
async-option
Essentially an asynchronous Async<Mutex<Option<T>>>
-
safina-sync
Safe structs for sharing or sending data between async tasks
-
rabble
creating location transparent actor based systems
-
retry-if-macro
A tokio-compatible attribute-macro for decorating methods and functions with an exponential backoff
-
num_stream
that provides a Stream that yields incrementing numbers at a specified interval
-
repeating_future
[RepeatingFuture] is a [Future] that can call an async function of an object over and over again
-
RobotS
Actor framework
-
improv
Actor microframework
-
async-utils
nothing to see here yet :)
-
nonblocking
stdin crate for Rust
-
async-stdio
Adapter for using async read/write streams in std::io contexts
-
tokio-tasker
Lets you stop and join groups of Tokio tasks
-
sendgrid-async
An async-std based client for sending emails with SendGrid
-
async-cuda-core
Async CUDA streams and buffers for Rust
-
task_yield
Executor-independent task yielding
-
xml-macro
A convenience macro for quick-xml
-
deadpool-fantoccini
Dead simple async session pool for fantoccini
-
mio-timerfd
mio support for linux's timerfd
-
busybody
Service Container and Dependency injector crate
-
aldrin
Message bus for service-oriented RPC and interprocess communication
-
stream-map-any
Allows merging async Streams of different output type
-
common-multipart-rfc7578
multipart/form-data (RFC7578)
-
tower-async-bridge
Bridges a
tower-async
Service
to be used within atower
(classic) environment, and also the other way around -
trovo
A trovo.live api & chat client written in and for rust
-
vesper-macros
Procedural macros used by Zephyrus
-
gloo-timers
Convenience crate for working with JavaScript timers
-
async-zmq-types
Types and traits to create a generic interface over asynchronous zmq implementations
-
elfo-pinger
Pings groups of the elfo system
-
tracing-subscriber
implementing and composing
tracing
subscribers -
lspower
A lightweight framework for implementing LSP servers
-
streaming-platform
Data streaming platform and message broker with concurrent data transfer capabilities
-
futures-stable-preview
futures which support internal references
-
mezzenger-channel
mezzenger transport over futures channels
-
mio-utun
Utun bindings for mio
-
spotify-rs
wrapper for the Spotify API
-
extern_executor
Async executor which delegates futures polling to external event-loop
-
rspc
A blazing fast and easy to use TRPC server for Rust
-
txrx
take on the C++ unified executors proposal
-
tigerbeetle-unofficial-core
Safe low level callback-based async bindings to tigerbeetle client library
-
arduino-plotter
API bindings (protocol) and Server/Client API for Arduino serial plotter
-
kompact-actor-derive
A derive macro for Kompact Actors
-
pipebuf_rustls
PipeBuf wrapper for Rustls
-
tokio-async-std
An async-std that can fit into tokio ecosystem straight ahead
-
deepwell
Wikijump API provider and database manager
-
futures-async-combinators
toy futures combinators
-
photonio
A runtime for asynchronous applications
-
tokio-timer-patched
Timer facilities for Tokio, patched for handling issue #36, and pushed to Crates.io so that it can be used in other open source crates
-
bounded_join_set
A Concurrency-Limited JoinSet for Tokio
-
failure_ext
Convenience extension traits for the failure error-handling crate
-
tokio-dbus
Pure Rust D-Bus implementation for Tokio
-
qcow2-rs
read/write qcow2 image in async/await
-
smol-macros
Macros for setting up a smol runtime
-
tower-sessions-deadpool-sqlite-store
deadpool-sqlite session store for
tower-sessions
-
memstore
An in-memory implementation of the
async-raft::RaftStorage
trait -
leaves
Distributed ID Allocator
-
async-tun
Asynchronous allocation of TUN/TAP devices using async-std
-
mlg
An asynchronous Log for Rust
-
async-thread
Futures version of std::thread
-
exponential-backoff
A small and flexible backoff function
-
noop-waker
A waker that does nothing
-
socketioxide
Socket IO server implementation in rust as a Tower Service
-
naumi
Lightweight and fast data transfer protocol. Fast de/serialization and tiny size!
-
futuresdr-pmt
Polymorphic Types for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
param
Param-style trait
-
jarust_rt
A janus client SDK in Rust
-
xorstream
xoring a vector of data with an (optionally async) stream of data
-
compio-dispatcher
Multithreading dispatcher for compio
-
suspend-channel
Channel and stream implementations
-
tokio-compat-02
Tokio 0.2 compat utilities
-
netbeam
a pure-rust asynchronous network synchronization crate (using tokio) that recreates familiar asynchronous paradigms but in a network context
-
ndless-async
Ndless-specific integration with async/await for the TI-Nspire
-
barrage
An async broadcast channel
-
accumulate-api
Lower-level API for interfacing with the Accumulate Protocol via JSON-RPC
-
chtsh
Rust CLI for interacting with https://cht.sh
-
libp2p-identify
Nodes identifcation protocol for libp2p
-
catalyzer-utils
development easier
-
misskey-util
High-level API for the misskey-rs library
-
agner-helm
An actor toolkit inspired by Erlang/OTP (control panel)
-
reqwest-streams
HTTP body streaming support for reqwest: JSON/CSV/Protobuf and others
-
causality
Event Driven Architecture Traits
-
prodash
A dashboard for visualizing progress of asynchronous and possibly blocking tasks
-
async-attributes
Experimental language-level polyfills for Async Rust
-
plctag
wrapper of libplctag, with rust style APIs and useful extensions
-
tower-balance
Balance load across a set of uniform services
-
drop-awaiter
that allows you to asynchronously wait for something to be dropped
-
motore-macros
Motore's proc macros
-
aio_event
A tokio event like asyncio event in python
-
tower-sessions-surrealdb-store
SurrealDB session store. Not for direct use; see the
tower-sessions
crate for details. -
heim-runtime
Runtime shims for heim crate
-
constellation-rs
Constellation is a framework for Rust (nightly) that aides in the writing, debugging and deployment of distributed programs
-
cf-pty-process-alpha
the tab multiplexer fork of tokio-pty-process. Interact with a child process through a pseudo-TTY, asynchronously using Tokio
-
stream-reduce
Fold a stream without an initial value
-
async-imap-lite
Asynchronous imap
-
eventbuzz_core
The core submodule of eventbuzz project
-
idb-sys
A callback based crate for interacting with IndexedDB on browsers using webassembly
-
async-stream-packed
Asynchronous stream packed
-
actor
Actors traits
-
peace_cmd_rt
Runtime types for commands for the Peace framework
-
smol-axum
Integrations between
smol
andaxum
-
basteh-redb
basteh based on redb
-
await_macros
Macros that expand to
(expr).await
-
tokio-nats
Async-await ready NATS library
-
async-spawner
executor independent task spawner
-
async-ready
Async readiness traits
-
relay
A lightweight oneshot Future channel
-
direct-executor
An executor that directly executes futures, suitable for embedded environments
-
simcore
A generic discrete-event simulation framework
-
async_dataloader
Powerful tool for avoiding N+1 queries using async/await, based on the DataLoader pattern
-
aligne
A small crate using tokio to synchronize asynchronous request/response with Ids
-
mqtt-channel-client
MQTT client that communicates over Tokio channels
-
gen-z
Macro-free stream construction through asynchronous generators via an awaitable sender
-
mamenoki
Complete implementation of a Beanstalkd client based on the Tokio runtime
-
rupnp
An asynchronous library for finding UPnP control points, performing actions on them and reading their service descriptions
-
thetvdb
API async client
-
async-time-mock-async-std
Mockable time for use in async runtimes (async-std compatibility)
-
toy-rpc
An async RPC that mimics golang net/rpc's usage and supports both async-std and tokio
-
async-ucx
Asynchronous Rust bindings to UCX
-
jackrabbit
Real-time Message Queue
-
gain-lep
Support for exposing Gain APIs via Lep
-
boomerang_runtime
"Reactors" Deterministic Actor Model
-
spin-executor
Spin SDK async executor
-
rw-stream-sink
Adaptator between Stream/Sink and AsyncRead/AsyncWrite
-
tower-load-shed
Immediately reject requests if the inner service is not ready. This is also known as load-shedding.
-
squinn
Versatile QUIC transport protocol implementation with SCION support
-
form-data
AsyncRead/AsyncWrite/Stream
multipart/form-data
-
flexi_func_declarative
exposes the fb! macro to create a function with a flexible signature
-
pulz-executor
Abstractions of some async runtimes
-
tower-helmet
securing your tower servers with various HTTP headers
-
actix-storage-dashmap
actix-storage based on dashmap
-
memberlist
A highly customable, adaptable, async runtime agnostic Gossip protocol which helps manage cluster membership and member failure detection
-
futures-enum
#[derive(Future, Stream, Sink, AsyncRead, AsyncWrite, AsyncSeek, AsyncBufRead)] for enums
-
esl01-nonblocking
Call non-blocking async Rust from non-async Rust
-
cqrs-core
Core types and traits for cqrs
-
async-component
Zero overhead reactive programming
-
tokio-metrics
Runtime and task level metrics for Tokio applications
-
tower-batch
batch-tower
is a Tower middleware that allows you to buffer requests for batch processing until the buffer reaches a maximum size OR a maximum duration elapses -
tower-timeout
Apply a timeout to requests, ensuring completion within a fixed time duration
-
delay
A collection of trait and classes to make your thread wait (and timeout)
-
freestuffapi
Freestuffbot API
-
psbus
Generic Publish / Subscribe model for application messaging
-
clia-ntex-files-mod
A mod to ntex-files, supporting '.' leading
-
async-mongodb-session
An async-session implementation for MongoDB
-
eventum
Asynchronous I/O Event manager
-
viz
Fast, robust, flexible, lightweight web framework for Rust
-
gidle_future
A future executor for the glib main loop idle time
-
wasm_main_executor
Run futures from web workers on the main browser thread
-
erkpht-tower
Tower is a library of modular and reusable components for building robust clients and servers
-
pingora-openssl
OpenSSL async APIs for Pingora
-
tower-retry
Retry failed requests
-
hyena
async task pool
-
what-the-async
runtime
-
scambio
Safe and efficient value exchanges between endpoint pairs
-
digtask
Dig is a YAML-defined, OS-level task orchestrator. It can 'dig into' a specifed task, or 'dig out' a desired output file
-
turbocharger
Autogenerated async RPC bindings that instantly connect a JS frontend to a Rust backend service via WebSockets and WASM
-
windows-async
async executor for windows application using windows crate
-
cynthia
A high performance asynchronous programming runtime for Rust
-
light-magic
A lightweight, fast and easy-to-use implementation of a persistent in-memory database
-
openssh-sftp-client
Highlevel API used to communicate with openssh sftp server
-
liburing
Rust liburing#24bd087 raw bindings with basic tests
-
asynchronous
Promises Q style , async and event loops
-
oai_rs
An async rust library that's a wrapper for the OpenAI API
-
upc
USB packet channel (UPC): provides a reliable, packet-based transport over USB
-
aredis
Redis client implemented in Rust
-
irc
usable, async IRC for Rust
-
librdkafka-sys
Native bindings to the librdkafka library
-
libp2p-mplex
Mplex multiplexing protocol for libp2p
-
juggle
Async task switching for cooperative multitasking in single thread environments with no_std support
-
zephyrus-macros
Procedural macros used by Zephyrus
-
d3
A framework for server development
-
async-std-test
Alternate implementation of the #[async_std::test] macro
-
celery-rs-core
Core utilities for a celery client and worker in rust
-
stream_multiplexer
Combines many streams into a few
-
socksv5_future
Socks v5 futures for Server and Client
-
futures-await-test-preview
Async test support for Rust through a procedural macro. This crate defines the
#[async_test]
attribute to make writing tests that use async/await easier. -
eventual
Future & Stream abstraction
-
stream-body
An HttpBody implementation with efficient streaming support for the Rust HTTP library hyper
-
pychan
A collection of channels for sending around items of type
pyo3::Py<T>
-
shuller
Lib to get links to images for your favourite tags on rule34 and any
-
compio-tls
TLS adaptor with compio
-
tonic-health
Health Checking module of
tonic
gRPC implementation -
tokio-dbus-macros
Pure Rust D-Bus implementation for Tokio
-
async-await
Just some macros to emulate the Async and Await :)
-
actix-codec
Codec utilities for working with framed protocols
-
tower-http
Tower middleware and utilities for HTTP clients and servers
-
elfo-telemeter
Collects and exposes metrics of the elfo system
-
tangle
Future implementation for Rust
-
future_pubsub
A tokio based publish-subscibe channel
-
pn532
protocol implementation
-
thespis_impl
Reference implementation for the thespis actor model
-
coerce-rt
Async actor runtime
-
ianaio-events
Convenience crate for working with DOM event listeners
-
thread-executor
Lightweight futures executor using std::thread::park
-
safe-async-scoped
A minimal, safe library for scoped async tasks
-
completable_future
CompletableFuture for Rust
-
async-graphql-parser
GraphQL query parser for async-graphql
-
diath
light-weight library for communication between tokio async tasks
-
futuresdr-types
Polymorphic Types for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
turmoil
Simulation testing framework for distributed systems
-
tokio-non-async
Helpers for dealing with tokio channels in non-async code
-
atomic-actor
An
Actor
withasync fn
handlers -
mio-byte-fifo
Concurrent non-blocking byte SPSC FIFO buffer intended for use in Mio poll
-
async-timer-rs
**Hashed timer wheel** implementation compatible with asynchronous tasks, support async_std/tokio and other futures base framework
-
ws-lite
Naive websocket server implemented using async / await
-
volo-grpc
gRPC framework implementation of volo
-
axum-macros
Macros for axum
-
async-watch
Async watch channel
-
async-psec
Asynchronous PSEC implementation
-
task_scheduler
easilty schedule an FnOnce to run in the future
-
koibumi-socks
A minimal SOCKS5 client library
-
st7735-async-low
Low-level async library for 4-wire serial ST7735
-
tower-worker
Tower layers focused on wrapping services with asynchronous worker tasks that may also make requests to the wrapped service
-
specta-serde
Serde support for Specta
-
tarpc-lib
An RPC framework for Rust with a focus on ease of use
-
task-executor
A task executor
-
compio-signal
Signal handling for compio
-
titdb
Trails in the Database API
-
aldrin-gen
Aldrin code generator
-
nb-executor
Single-future, #![no_std] executor based on event bitmasks
-
see-you-later
Delay and schedule async task
-
mini-telnet
Asynchronous minimal telnet library
-
futures-executor-preview
Executors for asynchronous tasks based on the futures-rs library
-
one-file-raft
Raft consensus in 300 LOC
-
tokio_safe_block_on
ability to execute async code from a sync context, without blocking a tokio core thread or busy looping the cpu
-
taskio
Abstractions for non-blocking tasks and IO
-
peace_value_traits
Trait bounds for value types for the Peace framework
-
elfo-logger
Logs events of the elfo system
-
task_scope
asynchronous runtime extension for supporting Structured Concurrency with task spawning
-
axum-messages
🛎️ One-time notification messages for Axum
-
iroh-quinn-proto
State machine for the QUIC transport protocol
-
hydro
cooperative green tasks
-
shutdown-async
Asynchronous Shutdown
-
elfo-network
Distributed actors for elfo
-
peace_item_sh_sync_cmd
Manages a synchronization shell command for the peace framework
-
tokio01-test
Testing utilities for Tokio and futures-based code
-
tokio-eventfd
Linux eventfd for tokio
-
ratchet_ext
WebSocket extensions for Ratchet
-
hop
Rust client library for the Api
-
prefect
An embeddable task queue based on SQLite (renamed to effectum)
-
fil_actors_runtime_v11
System actors for the Filecoin protocol
-
async-graphql-actix-web
async-graphql for actix-web
-
ratchet_core
Async WebSocket implementation
-
jarust_transport
A janus client SDK in Rust
-
fieldset
Struct to enum derivation
-
dialectic-tokio-mpsc
A backend for the Dialectic crate using Tokio's MPSC channels
-
toy-rpc-ha421
An async RPC that mimics golang net/rpc's usage and supports both async-std and tokio
-
cassandra-protocol
Cassandra protocol implementation
-
redeez
queueing system for Redis
-
flysystem
A filesystem abstraction layer for Rust
-
tower-sessions-mongodb-store
MongoDB session store for
tower-sessions
-
compio-log
Log of compio
-
futures-async-runtime-preview
Runtime for the async/await macros in the
futures
crate -
fsdr-blocks
Building blocks for FutureSDR signal processing library for SDR and real-time DSP
-
stream_generator
Allows to easily generate streams with async/await
-
tokio-fastcgi
FastCGI handler (responder, authorizer, filter) library for Tokio
-
tokio-blocking
A thin wrapper to provide a simple interface to insert blocking operations between non-blocking operations in the context of futures
-
entangled
fork-join task executor
-
nephele
A high performance asynchronous programming runtime for Rust
-
tower-async
Tower Async is a library of modular and reusable components for building robust clients and servers. An "Async Trait" fork from the original Tower Library.
-
mio_channel
Provide a wrapper of the standard channel that can be polled with Mio
-
tokio_safe_for_aingle
execute async code from a sync context, without blocking a tokio core thread or busy looping the cpu
-
tokio-channel
Channels for asynchronous communication using Tokio
-
async-h1
Asynchronous HTTP 1.1 parser
-
ockam_node_no_std
Ockam library types that do not need
std
-
tokio-zookeeper
Asynchronous client library for interacting with Apache ZooKeeper
-
futures-macro-await-preview
Definition of the
await!
macro for thefutures
crate -
mirai
A Futures layer over Mio
-
openssh-sftp-error
Error type used when communicating with openssh sftp server
-
genawaiter-macro
Convenience macros for generators (genawaiter)
-
futures2
Enables depending on futures 0.2 and futures 0.1 in the same crate
-
futures-macro-await
Definition of the
await!
macro for thefutures
crate -
simple-async
Very simple async runtime for Rust
-
tinyio-core
Core of tinyio
-
uasync
fast, safe, async executor
-
poem-openapi
OpenAPI support for Poem
-
wta-reactor
Reactor for the what-the-async runtime
-
mercury
The official Rust client for the Mercury Parser
-
tokio-pty-process
Interact with a child process through a pseudo-TTY, asynchronously using Tokio
-
sendfile
wrapper around the sendfile(2) system call
-
tokio-fd
Non-blocking Read and Write a Linux File Descriptor
-
just-watch
Async watch channel
-
somen
An asynchronous parser combinator
-
d3-components
A framework for server development -- the component layer
-
tower-service
Trait representing an asynchronous, request / response based, client or server
-
armature
An event-driven stateful actor framework for Rust
-
actm
Tiny async actors framework for rust
-
lucia-apis
A set of API collections based on the lucia framework
-
rxqlite-notification
A distributed sqlite database built upon
openraft
,sqlx
andsqlite
-
diny
An asynchronous, alloc-free serialization framework
-
lelet
golang like task executor
-
stream-consumer-task
Start asynchronous task in background to consume stream
-
axum-serveplus
High level server designed to be used with axum framework
-
libp2p-wasm-ext
Allows passing in an external transport in a WASM environment
-
waaaa
WebAssembly, Automatically Abstracted Away
-
spawns-core
Async runtime agnostic thread context task spawner for Rust
-
alzheimer
Async implementation of brainfuck interpreter
-
core-futures-tls
A libcore wrapper allowing async/await to be used from no_std crates
-
sfu
WebRTC Selective Forwarding Unit (SFU) in Rust with Sans-IO
-
smol-executor-trait
executor-trait implementation for smol
-
futures-glib
Spawn futures on the glib event loop
-
unisub
A Pub/Sub library for Rust backed by Postgres
-
madsim-tonic
The
tonic
simulator on madsim -
vkteams-bot
VK Teams Bot API client
-
actix-service
Service trait and combinators for representing asynchronous request/response operations
-
batch
Distributed task queue library based on RabbitMQ
-
dialectic-null
A no-op backend for the Dialectic crate, intended for benchmarking and testing
-
async-graphql-rocket
async-graphql for Rocket.rs
-
specta-util
High-level utilities for working with Specta
-
poem-grpc-build
Codegen module of poem-grpc
-
ntex-io
encoding and decoding frames
-
selectme-macros
A fast and fair select! macro for asynchronous Rust
-
tokio-tls-api
TLS/SSL streams for Tokio giving an implementation of TLS for nonblocking I/O streams
-
futures-mpsc
A futures aware, bounded, MPSC channel with back pressure support
-
async-task-group
Manage groups of
async-std
tasks as a single unit -
async-bincode
Asynchronous access to a bincode-encoded item stream
-
holiday_event_api
The Official Holiday and Event API for Rust
-
forkable
Fork-able iterators and asynchronous streams
-
uring
Pure Rust library for io_uring
-
monoio-macros
Monoio proc macros
-
tower-layer
Decorates a
Service
to allow easy composition betweenService
s -
yaar-reactor
Non-blocking IO abstractions for building executors
-
photonio-uring
A PhotonIO implementation based on io_uring
-
v_rusty_tarantool
Tarantul async client based on tokio framework
-
protwrap
Thin protocol wrapper for network applications
-
ntex-rt
ntex runtime
-
misskey-core
Core traits and types in misskey-rs
-
multitask
An executor for running async tasks
-
libp2p-request-response
Generic Request/Response Protocols
-
madsim-etcd-client
The etcd simulator on madsim
-
async-timer
Timers for Rust async story
-
catalyzer-core
Core of Catalyzer
-
tokio-dbus-xml
Pure Rust D-Bus implementation for Tokio
-
rspc-axum
Axum adapter for rspc
-
wamp_async
An asynchronous WAMP implementation
-
memberlist-types
Types used in the memberlist crate
-
libp2p-stream
Generic stream protocols for libp2p
-
tokio-net
Event loop that drives Tokio I/O resources
-
mioqu
queuing and processing background tasks
-
compio-macros
Proc macro of compio
-
echannel
Async channel for mixed events
-
async-watch2
Async watch channel
-
poller
File I/O events library for Rust
-
core-futures-stateless
Workaround for no_std async-await that doesn't store task contexts
-
async-graphql-poem
async-graphql for poem
-
agnostic_async_executor
Agnostic Rust Async Executor
-
tower-async-test
writing client and server
Service
tests. An “Async Trait” spiritual fork from the original tower-test Library -
task-compat
compat futures 0.1 and futures 0.3 tasks
-
async-backtrace
Efficient, logical 'backtraces' of async tasks
-
nb-connect
Non-blocking TCP or Unix connect
-
retty
— an asynchronous Rust networking framework that makes it easy to build protocols, application clients/servers
-
ntex-service
ntex service
-
futuresdr-frontend
Web Frontend for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
rxqlite-common
A distributed sqlite database built upon
openraft
,sqlx
andsqlite
-
peace_core
Low level data types for the peace automation framework
-
openraft-sledstore
A sled based implementation of the
openraft::RaftStorage
trait -
libp2p-pnet
Private swarm support for libp2p
-
ntex-async-std
async-std intergration for ntex framework
-
ntex-net
ntexwork utils for ntex framework
-
yaar
asynchronous runtime optimized around configuration and no_std
-
h2
An HTTP/2 client and server
-
peace_rt_model_core
Core runtime traits for the peace automation framework
-
rxqlite-tests-common
A distributed sqlite database built upon
openraft
,sqlx
andsqlite
-
threader
A performant multithreaded future executor and event loop
-
romio
Event loop and I/O resources for asynchronous network services using futures
-
openraft-macros
Advanced Raft consensus
-
mpool
A generic connection pool
-
async-graphql-axum
async-graphql for axum