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