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