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