-
tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
async-io
Async I/O and timers
-
actix
Actor framework for Rust
-
async-std
Async version of the Rust standard library
-
rdkafka
Rust wrapper for librdkafka
-
tower
Tower is a library of modular and reusable components for building robust clients and servers
-
multer
An async parser for
multipart/form-datacontent-type in Rust -
async-graphql
A GraphQL server library implemented in Rust
-
tokio-stream
Utilities to work with
Streamandtokio -
polling
Portable interface to epoll, kqueue, event ports, and wepoll
-
wiremock
HTTP mocking to test Rust applications
-
async-channel
Async multi-producer multi-consumer channel
-
tokio-rustls
Asynchronous TLS/SSL streams for Tokio using Rustls
-
mlua
High level bindings to Lua 5.4/5.3/5.2/5.1 (including LuaJIT) with async/await features and support of writing native Lua modules in Rust
-
lspower
A lightweight framework for implementing LSP servers
-
celery
Rust implementation of Celery
-
stream-cancel
A library for interrupting asynchronous streams
-
tokio-serial
A serial port implementation for tokio
-
bb8
Full-featured async (tokio-based) connection pool (like r2d2)
-
ghost_actor
GhostActor makes it simple, ergonomic, and idiomatic to implement async / concurrent code using an Actor model
-
async-task
Task abstraction for building executors
-
etcd-client
An etcd v3 API client
-
fred
An async Redis client for Rust built on Futures and Tokio
-
relm
Asynchronous, GTK+-based, GUI library, inspired by Elm, written in Rust
-
tokio-util
Additional utilities for working with Tokio
-
maybe-async
A procedure macro to unify SYNC and ASYNC implementation
-
pharos
Observer pattern which generates a futures 0.3 stream of events
-
csv-async
CSV parsing for async
-
mobc
A generic connection pool with async/await support
-
h2
An HTTP/2.0 client and server
-
cl3
A Rust implementation of the Khronos OpenCL 3.0 API and extensions
-
rusty_pool
Self growing / shrinking
ThreadPoolimplementation based on crossbeam’s multi-producer multi-consumer channels that enables awaiting the result of a task and offers async support -
twilight-standby
Utility to filter wait for filtered incoming events for the Twilight ecosystem
-
minus
An asynchronous paging library for Rust
-
background-jobs
Background Jobs implemented with actix and futures
-
rdkafka-sys
Native bindings to the librdkafka library
-
ldap3
Pure-Rust LDAP Client
-
paho-mqtt
The Official Eclipse Paho MQTT Rust Client Library. This is a wrapper around the Paho C library
-
nb
Minimal non-blocking I/O layer
-
mio
Lightweight non-blocking IO
-
async-oneshot
A fast, small, full-featured, async-aware oneshot channel
-
async-executor
Async executor
-
xtra
A tiny actor framework
-
async_executors
Implements Spawn, SpawnLocal and SpawnHandle for commonly used executors
-
sidekiq
Rust Sidekiq Client
-
keycloak
Keycloak Admin REST API
-
rxrust
A Rust implementation of Reactive Extensions
-
deadpool-lapin
Dead simple async pool for lapin
-
async-sse
Async Server Sent Event parser and encoder
-
futures-locks
Futures-aware lock primitives
-
actix_derive
Derive macros for
actixactors -
suppaftp
A super FTP/FTPS client library for Rust
-
mio-serial
A serial port implementation for mio
-
triggered
Triggers for one time events between tasks and threads
-
async-native-tls
Native TLS using futures
-
zookeeper-async
An async ZooKeeper client
-
async-graphql-parser
GraphQL query parser for async-graphql
-
rio
GPL-3.0 nice bindings for io_uring. MIT/Apache-2.0 license is available for spacejam’s github sponsors.
-
redis-async
An asynchronous futures based Redis client for Rust using Tokio
-
remoc
🦑 Remote multiplexed objects and channels that make remote interactions seamless
-
postage
An async channel library
-
futures-rustls
Asynchronous TLS/SSL streams for futures using Rustls
-
event-listener
Notify async tasks or threads
-
didcomm-rs
DIDComm messaging v2 specifications implementation: https://identity.foundation/didcomm-messaging/spec/
-
futures-signals
Zero cost FRP signals using the futures crate
-
kdbplus
Dual q/kdb+ interface for API to build a shared library and an IPC client
-
ate
Distributed immutable data store with strong encryption and authentication
-
messagebus
MessageBus allows intercommunicate with messages between modules
-
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.
-
async-graphql-extension-apollo-tracing
An async_graphql extension to send traces & metrics to Apollo Studio
-
miow
A zero overhead I/O library for Windows, focusing on IOCP and Async I/O abstractions
-
tower-lsp
Language Server Protocol implementation based on Tower
-
smol-potat
Proc macro for smol runtime
-
async-attributes
Experimental language-level polyfills for Async Rust
-
teloxide-core
Core part of the
teloxidelibrary - telegram bot API client -
tower-service
Trait representing an asynchronous, request / response based, client or server
-
linemux
A library providing asynchronous, multiplexed tailing for (namely log) files
-
par-stream
Asynchronous parallel streams analogous to rayon
-
futures-micro
Minimal, no_std compatible async prelude
-
async-injector
Reactive dependency injection for Rust
-
capnp-futures
async serialization for Cap’n Proto messages
-
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)…
-
actix-broker
Message broker for the Actix actor framework
-
tokio-pipe
Asynchronous pipe(2) library using tokio
-
pollster
A minimal async executor that lets you block on a future
-
futures-core
The core traits and types in for the
futureslibrary -
async_io_stream
IntoAsyncRead on steriods
-
toy-rpc
An async RPC that mimics golang net/rpc’s usage and supports both async-std and tokio
-
dataloader
Rust implementation of Facebook’s DataLoader using async-await
-
rants
An async NATS client library
-
queen
message queue
-
tmq
ZeroMQ bindings for Tokio
-
bus_queue
Lock-free Bounded non-Blocking Pub-Sub Queue
-
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
-
ginepro
A client-side gRPC channel implementation for tonic
-
gcs-rsync
rsync support for gcs with higher perf than gsutil rsync
-
tokio-test
Testing utilities for Tokio- and futures-based code
-
safina-timer
Safe async timers
-
syslog-rs
A native Rust implementation of the glibc/libc syslog
-
c-ares-resolver
An asynchronous DNS resolver, backed by c-ares
-
tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
synchronized-writer
A tiny implement for synchronously writing data
-
tiny-tokio-actor
A simple and tiny actor library on top of tokio
-
stop-token
Experimental cooperative cancellation for async Rust
-
smolscale
A global, auto-scaling, preemptive scheduler
-
streamcatcher
A thread-safe, shared (asynchronous), almost-lockless stream buffer
-
async-shutdown
one-stop solution for async graceful shutdown
-
flo_binding
Declarative binding library for Rust
-
desync
A hassle-free data type for asynchronous programming
-
cache_loader_async
A thread safe loading cache with async loader functions based on tokio
-
actix-daemon-utils
Daemon Utilities by actix
-
opencl3
A Rust implementation of the Khronos OpenCL 3.0 API and extensions
-
eventuals
Eventually consistent values
-
mux-stream
Asynchronous hierarchical update dispatching for Rust
-
stream-reconnect
Stream-wrapping traits/structs that automatically recover from potential disconnections/interruptions
-
tokio-graceful-shutdown
Utilities to perform a graceful shutdown on a Tokio based service
-
streamunordered
An efficient async stream multiplexer
-
stakker
A lightweight low-level single-threaded actor runtime
-
fluvio-future
I/O futures for Fluvio project
-
ksoft
KSoft.SI api wrapper written in pure Rust
-
lua_actor
Lua Actor for Rust(sync/async)
-
oneshot
Oneshot spsc channel with lock-free non-blocking send and a receiver supporting both thread blocking receive operations as well as Future based async polling
-
aster-proxy
A light, fast and powerful cache proxy written in Rust
-
async-raft
An async implementation of the Raft distributed consensus protocol
-
async_cell
A Cell<Option> that you can await on
-
async-ssh2-lite
Asynchronous ssh2
-
charred
charred char checking
-
asynchron
Asynchronize blocking operation
-
persway
Sway IPC daemon
-
pwner
Pwner is a Process Owner crate that allows ergonomic access to child processes
-
dbus-async-derive
Handler trait derive macro for dbus-async
-
rmp-futures
Async Rust MessagePack and MessagePack-RPC
-
unicycle
A scheduler for driving a large number of futures
-
blocking-permit
Permits and a thread pool for blocking operations
-
futures
An implementation of futures and streams featuring zero allocations, composability, and iterator-like interfaces
-
fure
Retrying futures using different policies
-
micro_http_async
A small, lightweight and hassle-free crate using async to serve web pages or web apis with high performance and extremely low overhead
-
genawaiter
Stackless generators on stable Rust
-
bb8-bolt
A bolt-client adaptor for the bb8 connection pool
-
lamellar
Lamellar is an asynchronous tasking runtime for HPC systems developed in RUST
-
plumbing
An async abstraction to pipeline requests through a channel
-
futures-retry
Retry your Futures and Streams!
-
retainer
Minimal async cache in Rust with support for key expirations
-
yt-api
a work in progress library to interact asynchronously with the youtube api
-
nuclei
Proactive IO & runtime system
-
pasts
Minimal and simpler alternative to the futures crate
-
background-jobs-core
Core types for implementing an asynchronous jobs processor
-
elfo
Your next actor system
-
streamline
Reversible futures::Stream-based state machines
-
webhdfs
Hadoop WebHDFS client library
-
asynchronous-codec
Utilities for encoding and decoding frames using
async/await -
pinky-swear
Futures and async/await-ready Promises
-
async-tar
A Rust implementation of an 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…
-
tracing-layer-slack
Send filtered tracing events to Slack
-
futures-delay-queue
Async delay queue backed by async-std and futures-timer
-
futuresdr-pmt
An Experimental Async SDR Runtime for Heterogeneous Architectures
-
heim
Cross-platform framework for system information
-
dndx-fork-tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
async_logger
Asyncronous logger allows writing arbitrary slices to a memory buffer, which then processed by a writer in it’s own thread
-
rmw_ttlmap
Minimal async cache in Rust with support for key expirations
-
next-gen
Safe generators on stable Rust
-
tokio-tower
Bridging the protocol gap between Tokio and Tower
-
async-graphql-value
GraphQL value for async-graphql
-
eventador
lock-free pub/sub event-bus with sync and async APIs
-
apis
Reactive, session-oriented, asynchronous process-calculus framework
-
lsp-codec
Simple Tokio-compatible codec implementation for Language Server Protocol
-
async-scoped
Spawn scoped (non ’static) asynchronous futures for async_std and tokio runtimes
-
tokio-lxi
LXI protocol abstractions for Tokio
-
round-based
Driver for round-based protocols
-
actix-interop
Use async/await syntax with actix actors
-
tokio-js-set-interval
Allows you to use
setInterval(callback, ms)andsetTimeout(callback, ms)as in Javascript inside atokioruntime. For this, it offers the macrosset_interval!(callback, ms)andset_timeout!(callback, ms) -
reool
An asynchrounous connection pool for Redis based on tokio and redis-rs
-
async-minecraft-ping
An async Rust client for the Minecraft ServerListPing protocol
-
stream_throttle
Provides a Stream combinator, to limit the rate at which items are produced
-
async-ops
Use std::ops traits with Futures
-
monzo-lib
async Monzo client in pure rust
-
ya-gcp
APIs for using Google Cloud Platform services
-
tbot
Make cool Telegram bots with Rust easily
-
poolparty
Added functionality for the
futures::executor::ThreadPoolfutures executor -
kompact-component-derive
A derive macro for Kompact component definitions
-
actix-mqtt-client
A MQTT client based on the actix framework
-
plctag-async
tokio based async wrapper for libplctag
-
any-mpsc
An mpsc that allows arbitrary types to be passed through
-
glommio
A set of utilities to allow one to write thread per core applications
-
tokio-context
Contexts for cancelling asynchronous tasks using tokio
-
async-ffi
Make async Futures FFI compatible
-
pty-process
spawn commands attached to a pty
-
safina-executor
Safe async runtime
-
futures-lite
Futures, streams, and async I/O combinators
-
egs-api
Interface to the Epic Games API
-
eventsourcing
Event Sourcing for Rust
-
paranoid-hash
A Hashing Library For Those Paranoid With Their Security
-
etcd-rs
etcd client for rust
-
fastcgi-client
Fastcgi client implemented for Rust
-
tokio-macros
Tokio’s proc macros
-
aiven_rs
This is a rust sdk to interact with aiven-cloud apis
-
web3-async-native-tls
Temporary package released to crates.io. Fork of async-native-tls. Please don’t use.
-
mobc-redis
Redis support for the mobc connection pool
-
actix-web-flash-messages
Flash messages for actix-web applications
-
switchyard
Real-time compute focused async executor
-
actix-redis
Redis integration for Actix and session store for Actix Web
-
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.
-
lifeline
Lifeline is a dependency injection library for asynchronous message-based applications
-
async-ctrlc
Async wrapper of
ctrlc -
apocalypse
Simple actor framework for Rust
-
textmode
terminal interaction library backed by a real terminal parser
-
dencode
Utilities for decoding and encoding frames from readers and writers
-
garcon
A collection of trait and classes to make your thread or async function wait
-
c-ares
A Rust wrapper for the c-ares library, for asynchronous DNS requests
-
async-codec
Utilities for creating async codecs
-
thin_main_loop
Thin, cross-platform, main event loop. A building block for native GUI applications, among other use cases.
-
tourniquet
Async native round-robin manager for remote services
-
etcdv3client
a simple etcdv3 client
-
tracing-tools
Quick and simple band aid for instrumenting async code with tracing
-
smol
A small and fast async runtime
-
scrappy_do
A concurrent asynchronous webscraping framework
-
alopecosa
Pure rust async Tarantool 1.6+ connector built on tokio
-
side-futures
Send future for execution on the runtime that may be in a different thread
-
async-socks5
An async/.await SOCKS5 implementation
-
popol
Minimal non-blocking I/O
-
stakker_mio
Mio I/O polling integration for the Stakker crate
-
async-psec
Asynchronous PSEC implementation
-
backstage
A framework for building data-driven distributed systems
-
miau
Async aware and extensible layered configuration system
-
coachman
rust asynchronous task manager built on top of tokio framework
-
again
wasm-compatible retry util for std library futures
-
acteur
A safe actor-like framework that just works. Simple, robust, fast, documented.
-
paypal-rs
A library that wraps the paypal api asynchronously
-
libaio-futures
Straightforward Linux AIO using Futures/async/await
-
nbchan
Highly optimized non-blocking communication channels
-
mio-misc
Miscellaneous components for use with Mio
-
async-tun
Asynchronous allocation of TUN/TAP devices using async-std
-
ws_stream_tungstenite
Provide AsyncRead/AsyncWrite over Tungstenite WebSockets
-
gain-lep
Support for exposing Gain APIs via Lep
-
async_msp_cli
Async msp cli for iNav and BetaFlight
-
piston_rs
An async wrapper for the Piston code execution engine
-
async-change-tracker
reactive change notifications using 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. -
circulate
Lightweight async PubSub framework
-
transform-stream
Lightweight async stream wrapper
-
wookie
Async test/bench toolkit including single stepping executors. No-std compatible.
-
agnostik
Executor Agnostic Runtime that can run your futures with your favourite Executor
-
wg
Golang like WaitGroup implementation for sync/async Rust
-
signal-hook-async-std
async-std support for signal-hook
-
futures-x-io-timeoutable
Timeout ext for futures io and tokio io
-
bb8-diesel
bb8 connection manager for Diesel
-
pcap-async
Async/Stream Extensions for libpcap
-
taskwait
Runtime agnostic way to wait for a group of async tasks
-
quiverquant
A crate for accessing the QuiverQuant API
-
async-refresh
Create values that refresh automatically and asynchronously after a given duration
-
qutex
Synchronization mechanisms that rely on lock-free and other non-(thread)blocking techniques, such as Rust futures, to guarantee mutually exclusive or shared exclusive access to data
-
scipio
A set of utilities to allow one to write thread per core applications
-
actors-rs
Easily build fast, highly concurrent and resilient applications. An Actor Framework for Rust.
-
idcurl
Idiomatic synchronous http client based on curl
-
dwbhk
dwbhk-rs is a library for working with Discord Webhooks
-
c_mcai_worker_sdk
AMQP Worker to listen and provide trait to process message
-
async_singleflight
Async singleflight
-
untokio
Automatically create tokio runtimes
-
tokio-serde-cbor
Integration of serde_cbor into tokio-io, to allow sending CBOR encoded frames across network (and possibly through other transports)
-
agnostik-attributes
Executor agnostik attributes
-
async-backplane
Simple, Erlang-inspired reliability framework for Rust Futures
-
agreed
Fork of async-raft, the Tokio-based Rust implementation of the Raft protocol
-
tokio-zmq
Provides Futures abstractions for ZeroMQ on the Tokio event-loop
-
tonari-actor
A minimalist actor framework aiming for high performance and simplicity
-
iou
io_uring bindings
-
async-object-pool
A simple object pool implementation that uses asynchronous synchronization primitives only
-
appliance
A lightweight framework to build async-friendly components with message-based intercommunications
-
plumb
A functional, async pipeline framework
-
zeebe
A rust client for defining, orchestrating, and monitoring business processes across microservices using Zeebe
-
blocking
A thread pool for isolating blocking I/O in async programs
-
async-file-lock
Asynchronous file lock that can auto lock and auto seek
-
cooper
A simple, in-process, async Actor library for Rust
-
hl7-mllp-codec
A Tokio codec for HL7 Minimal Lower Layer Message Transport protocol (MLLP)
-
bleasy
High-level BLE communication library
-
dialectic-compiler
Session type macro compiler for the Dialectic crate
-
streamson-futures
A library which integrates streamson with futures stream
-
conch-runtime-pshaw
A library for evaluating/executing programs written in the shell programming language
-
mpart-async
Asynchronous (Futures-Base) Multipart Requests for Rust
-
spaad
Zero boilerplate actor systems with xtra
-
nominatim
A reverse geocoding API client powered by openstreetmap
-
riker
Easily build fast, highly concurrent and resilient applications. An Actor Framework for Rust.
-
vmcircbuffer
Double Mapped Circular Buffer
-
libevent
Rust bindings to the libevent async I/O framework
-
task-group
manage groups of tokio tasks
-
tokio-rayon
Mix async code with CPU-heavy thread pools using Tokio + Rayon
-
paho-mqtt-sys
Rust wrapper for the Paho MQTT C Client Library. This is part of the official Eclipse Paho Rust Client Library
-
local-waker
A synchronization primitive for thread-local task wakeup
-
async-scgi
Async SCGI Client & Server
-
frosty
A thread per core runtime based on iouring
-
sonor
a library for controlling sonos speakers
-
completion
Utilities for writing completion-based asynchronous code
-
mio-extras
Extra components for use with Mio
-
paperplane
Async WebSocket library
-
conch-runtime
A library for evaluating/executing programs written in the shell programming language
-
fluvio-async-tls
Asynchronous TLS/SSL streams using Rustls
-
foxhole-api
A rust wrapper for the Foxhole War API
-
cb_fut
Call function that return value via callback without a callback
-
vampirc-io
A library for asynchronous, non-blocking, UCI protocol–based communication between chess UIs and chess engines
-
webex
Interface to Webex Teams REST and WebSocket APIs
-
packet-ipc
Share packets between services using servo ipc
-
implicit-await
Implicitly await calls returning Future impls
-
protobuf_codec
Encoders and decoders for Protocol Buffers based on bytecodec crate
-
openai-api
OpenAI API library for rust
-
async-mq
Zero-cost async-await abstraction of lapin AMQP client crate
-
futures_cbor_codec
A codec for framing an AsyncRead/AsyncWrite with cbor for all types that are serializable with serde
-
archlinux-repo
Arch Linux repositories parser
-
smelling_salts
Abstraction over file descriptors to wake futures when ready
-
mio-uds
Unix domain socket bindings for mio
-
heim-cpu
Cross-platform CPU information
-
ferinth
A simple library to use the Modrinth API in Rust projects
-
async-copy-progress
Asynchronous copying with progress callbacks
-
simple_futures
Simple futures for use in async operations
-
nbd-async
Block device drivers in userspace
-
parquet-format-async-temp
Temporary crate containing thrift library + parquet definitions compiled to support read+write async
-
madsim-macros
Madsim’s proc-macro
-
scoped_spawn
Full structured concurrency for asynchronous programming
-
async-priority-channel
An async channel where pending messages are delivered in order of priority
-
aiur
Single threaded async executor with structured concurrency
-
uringy
Single-threaded async runtime based on io_uring
-
tokio-retry
Extensible, asynchronous retry behaviours for futures/tokio
-
fb-api
Facebook Api abstraction for async rust
-
zonyitoo/coio
Coroutine scheduler with non-blocking I/O support
-
koit
A simple, asynchronous, pure-Rust, structured, embedded database
-
reqchan
This is a 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…
-
callbag
An implementation of the callbag spec
-
futures-rate
This library provides easy tools to help Rust applications guide critical resources or code paths from being overwhelmed
-
vino-packet
Rust library encapsulating the message packets sent across Vino components
-
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.
-
d3-core
A framework for server development – the core layer
-
closure-future
Easily run closures on thread pools and turn their result into Futures
-
stund
An SSH tunnel maintenance daemon
-
killswitch
Killswitch used to broadcast a task termination request
-
waitgroup
Async waitgroup for a collection of task to finish
-
koit-toml
A simple, asynchronous, pure-Rust, structured, embedded database
-
stream_router
A Future aware router to dynamically route between Streams and Sinks
-
spekt
std::future::Future and Result-based testing trait for managing the lifecycle of stateful, asynchronous tests
-
tonic_lnd
An async library implementing LND RPC via tonic and prost
-
craftio-rs
A crate to read & write packets defined in mcproto-rs to I/O sinks/sources
-
elegant-departure
Utility crate to simplify graceful shutdown
-
async_linux_spec_fd
asynchronous linux specific fd in rust
-
dbus-async
Asynchronous DBus library
-
async-broadcast
Async broadcast channels
-
tokio-stomp-2
Unofficial successor to Asynchronous streaming STOMP client
-
happyeyeballs
Simple Happy Eyeballs implementation in Tokio (not RFC compliant atm)
-
async-log
Async tracing capabilities for the log crate
-
double-checked-cell-async
A thread-safe lazily initialized cell using double-checked locking
-
tokio-io-compat
Compatibility wrapper around std io traits that implements tokio io traits
-
medea-reactive
Reactive mutable data containers
-
itla
ITLA (micro laser) non-blocking control library using embedded-hal
-
ert
A combinator to control future execution order
-
juggle
Async task switching for cooperative multitasking in single thread environments with no_std support
-
ardop_interface
Interface to the Amateur Radio Digital Open Protocol (ARDOP)
-
actix-elastic
elasticsearch 7.x actix actor
-
async-graphql-actix-web
async-graphql for actix-web
-
deadpool-fantoccini
Dead simple async session pool for fantoccini
-
async-oncecell
Asynchronous versions of OnceCell and Lazy
-
async-trait-ext
a procedural macro for async traits
-
noob
A WIP futures-based Discord bot library
-
async-fuse
Helpers for fusing asynchronous computations
-
pin-utils
Utilities for pinning
-
linked-futures
Link futures into a block, which stops all of the included futures when any of the futures complete
-
extreme
Extremely boring async function runner. MIT/Apache-2.0 license is available for spacejam’s github sponsors.
-
gen-z
Macro-free stream construction through asynchronous generators via an awaitable sender
-
awaitgroup
Wait for a collection of async tasks to finish
-
potential
Borrowing for futures - Potential enables interior mutation using mutex and asynchronous borrowing (leasing) through a oneshot channel
-
rumpsteak
Session types for asynchronous communication between multiple parties
-
tractor
Actor system modelled after Pony’s actors
-
hreq-h2
An HTTP/2.0 client and server
-
thunks
Asynchronous composer for Rust
-
newsblur_api
rust implementation of the NewsBlur-API
-
async-utf8-decoder
Convert AsyncRead to incremental UTF8 string stream
-
stream-map-any
Allows merging async Streams of different output type
-
bitcoin-zmq
A library providing a relatively thin wrapper around Bitcoin ZMQ, allowing the construction of asynchronous streams of transaction or block data
-
stow
Cloud storage abstraction package for Rust
-
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.
-
ssh-muxcontrol
A library which controls existing SSH sessions
-
pmpmc
A priority multi producer multi consumer channel
-
messagebus_derive
MessageBus allows intercommunicate with messages between modules
-
dyn-future
Convenient and fast dynamic Futures for Rust
-
pantry
Temporary storage for reusing values that may decay
-
luis_sys
FFI bindings for Microsoft LUIS API
-
intervalier
Interval events with handling notifications
-
simple-async-pipe
Aims to provide a simple pipe-like functionality for async code
-
tokio-file
Asynchronous file I/O for Tokio
-
tokio_schedule
This crate helps schedule tasks in tokio runtime
-
rdeploy
Simple deployment for everyone
-
blocker
Block rust futures to create a synchronous wrapper around an asynchronous api
-
async-walkdir
Asynchronous directory traversal for Rust
-
dapr-derive
Dapr SDK for Rust
-
termion-input-tokio
An adapter that exposes termion’s input and key event iterators as asynchronous streams
-
signals
A functional-reactive-like library for Rust that allows asynchronous chaining
-
hbbft
The Honey Badger of Byzantine Fault Tolerant Consensus Protocols
-
task_yield
Executor-independent task yielding
-
mlua_actor
Lua Actor for Rust(sync/async)
-
toy-rpc-macros
Macros for toy-rpc
-
kompact-actor-derive
A derive macro for Kompact Actors
-
read-progress-stream
Stream reader wrapper that tracks the number of bytes read
-
tokio-switching-sleep
A tokio Sleep with a switchable state
-
want
Detect when another Future wants a result
-
tracing-actix
Allow tracing actor futures in actix
-
signald-rust
A library to interface with Signald
-
scpsl-api
A SCP: Secret Laboratory API wrapper
-
dstream
DelayedStream - delays items and drops same items coming within given interval
-
futures-async-combinators
toy futures combinators
-
xo-api-client
Unofficial crate for accessing Xen Orchestra through its API
-
heph-inbox
Bounded capacity channel designed to be used as inbox for actors. Also supports one shot channels.
-
yaaf
Yet Another Actor Framework
-
rustun
A library for implementing STUN server and client asynchronously
-
rusty_tarantool
Tarantul async client based on tokio framework
-
deferred
Rust crate to help perform deferred execution of code logic
-
serial-io
A serial port implementation
-
async-process
Async interface for working with processes
-
core-futures-tls
A libcore wrapper allowing async/await to be used from no_std crates
-
mobc-lapin
RabbitMQ support for the async mobc connection pool
-
poller
File I/O events library for Rust
-
beatsaver-rs
A Rust library for interacting with the beatsaver.com api
-
panda
An async Rust library for Discord
-
async_once
async once tool for lazy_static
-
tokio-diesel
Integrate Diesel into Tokio cleanly and efficiently
-
thread_timer
A simple, cancelable timer with no external dependencies
-
async-alloc-counter
async-alloc-counter measures max allocations in a future invocation
-
flowync
A simple utility for multithreading a/synchronization
-
futures-executor
Executors for asynchronous tasks based on the futures-rs library
-
mutex-extra
RefMutex<T>that is similar toMutex<T>but isSyncandSendeven ifTisn’tSend -
lamellar-impl
Lamellar is an asynchronous tasking runtime for HPC systems developed in RUST
-
visiting_ref
Container types that asynchronously return ownership of a value to another context upon exiting scope
-
quicksink
Create a Sink from some value and a closure returning a Future
-
sidekiq-rs
Sidekiq compatible server in Rust
-
simple-process-stats
Get memory usage and CPU time on Linux and Windows
-
ws-gonzale
Naive websocket server implemented using async / await
-
merge-io
Merge two separate
AsyncReadandAsyncWriteobjects into a single I/O stream -
connpass-rs
An api client for connpass.com
-
funfsm
An FSM library where the states are functions
-
slock
An async mutex that never deadlocks
-
gabelung
Branch an asynchronous stream of cloneable items into two
-
zeebest
An unofficial zeebe client for the future!
-
leaves
Distributed ID Allocator
-
lol-async
async html-rewriter
-
librdkafka-sys
Native bindings to the librdkafka library
-
apex_legends
An API wrapper for the MozambiqueHe.re Apex Legends API
-
tower-worker
Provides Tower layers focused on wrapping services with asynchronous worker tasks that may also make requests to the wrapped service
-
stakker_log
Logging support for Stakker
-
async-task-ffi
Task abstraction for building executors
-
tari_pubsub
Single publisher with multiple subscribers to topic messages
-
real-async-trait
A proc macro that uses experimental features to work around type erasure for async traits
-
bandar-log
async logular storage
-
futurify
Convert your sync functions into non-blocking thread futures
-
async_smux
Asynchronous smux multiplexing library
-
lease
Object pool that leases values and automatically returns them with async support
-
ruyi
An event-driven framework for non-blocking, asynchronous I/O in Rust
-
async-stream-tls-upgrader
Asynchronous stream tls upgrader
-
lib3h_zombie_actor
lib3h actor request tracking module
-
settimeout
Creates a std::future::Future implementation to be ready at some point
-
actix-raft
An implementation of the Raft distributed consensus protocol using the Actix actor framework
-
spin_on
A simple, inefficient Future executor
-
erkpht-tower
Tower is a library of modular and reusable components for building robust clients and servers
-
manual_future
A future that must be manually completed, similar to Java’s CompletableFuture
-
hypercore
Secure, distributed, append-only log
-
clap-and-async-test
Is a example to use clap with tokio and futures, how run concurrently some functions with a loop inside
-
fut_rwlock
A read-write lock that is read and written via Futures
-
requiem
Actor framework for Rust
-
async-lease
Essentially a futures-oriented Arc<Mutex<Option>>
-
epoxy_frp
The Reactive Glue for Frontend Applications
-
cqrs-core
Core types and traits for cqrs
-
gidle_future
A future executor for the glib main loop idle time
-
yaar-reactor
Non-blocking IO abstractions for building executors
-
async-graphql-viz
async-graphql for viz
-
async_zmq
Async version for ZeroMQ bindings
-
icanhazdadjoke-sdk
An SDK to interact with the icanhazdadjoke Dad Jokes API
-
dialectic
Transport-polymorphic, asynchronous session types for Rust
-
async-global-executor
A global executor built on top of async-executor and async-io
-
shared_stream
A crate for easily cloneable streams
-
goods
Asset pipeline complete with loader, database, importing plugins and procedural macros for asset definition from user-types
-
coerce
Async actor runtime and distributed systems framework
-
eventually-postgres
Event Store implementation using PostgreSQL for the Eventually crate
-
stateful_async_worker
Asynchronous stateful worker threads utilizable as futures
-
heph
Heph is an actor framework based on asynchronous functions
-
git-event
Customizable event handler for updates in remote git repositories
-
safina
Safe async runtime
-
lsp-async-stub
An LSP server stub for futures
-
deadpool-bolt
A bolt-client manager for the deadpool connection pool
-
domain-resolv
An asynchronous DNS stub resolver
-
adventure
Helps your great adventure for the various type of requests
-
async-shell
Asynchronous process child wait
-
futures-jsonrpc
Futures implementation for JSON-RPC
-
greenthread-future
Convert closures to futures based on greenthread on bare-metal (no_std + no_alloc)
-
ipc-orchestrator
Orchestion of command line processes for local dev usage with IPC communication
-
lookit
Rust crate to asynchronously get device connection events
-
promising-future
Implementation of Promise/Future pairs
-
stream-flatten-iters
Flattens a stream of iterators into one continuous stream
-
futures-cputask
Turn synchronous CPU-bound tasks into futures
-
wait-for-me
Async CountDownLatch
-
deadqueue
Dead simple async queue
-
tokio-nsq
A Rust NSQ client built on Tokio. Tokio NSQ aims to be a feature complete NSQ client implementation.
-
diath
diath is a light-weight library for communication between tokio async tasks
-
callback-future
Adapter between callbacks and futures
-
cntrlr
Simple, async embedded framework
-
futures-mockstream
Minimal mockstream which implements futures async traits
-
throttled-reader
An io::Read proxy that limits calls to read()
-
async-tls
Asynchronous TLS/SSL streams using Rustls
-
async-await
Just some macros to emulate the Async and Await :)
-
syncthing
A Rust library for controlling syncthing file synchronization through its REST interface
-
futures-task
Tools for working with tasks
-
tokio-anon-pipe
Asynchronous anonymous pipe for Windows
-
suspend
A common mechanism for suspending a thread or a Future until notified
-
fluvio-test-derive
Procedure macro to run async fn as test
-
actix-redis-jobs
Simple and reliable background processing for Rust using Actix and Redis
-
tokio-uring
io-uring support for the Tokio asynchronous runtime
-
tokio-stdin-stdout
Thread- and future::sync::mpsc-based AsyncRead/AsyncWrite stdin/stdout with little buffering
-
async_msp_lib
Async msp library for iNav and BetaFlight
-
tokio-async-write-utility
Some helper functions for types impl AsyncWrite
-
one-of-futures
Future-aware Either-like type with multiple variants
-
lazy_async_pool
An asyncronous object pool that generates objects on the fly
-
await_macros
Macros that expand to
(expr).await -
bp3d-threads
Yet another threading library intended to simplify thread pools in BP3D
-
dynamodb-mutex
Use Dymanodb mutex library
-
ultra-batch
Tokio-based library to batch and cache database queries or other data lookups
-
observable-btree
Reactive Observable BTree
-
tokio-lk
Futures-aware lock-by-id primitives
-
st7735-async-low
Low-level async library for 4-wire serial ST7735
-
bastion-utils
Utilities for Bastion, the highly-available, fault-tolerant, async communication oriented executor
-
promises
Effective, simple, lightweight Javascript promises in Rust
-
tokio-compat
Compatibility between
tokio0.2 and legacy versions -
handy_async
A handy library for describing asynchronous code declaratively
-
futuresdr
An Experimental Async SDR Runtime for Heterogeneous Architectures
-
async-select-all
A futures library adapter for selecting over a list of futures
-
async-weighted-semaphore
An async weighted semaphore
-
actix-signal
Manage the lifecycle of an actix actor with its address
-
bottle
Actor model framework for Rust
-
runtime-loop
Runtime loop for Rust
-
agreed-memstore
An in-memory implementation of the
agreed::RaftStoragetrait. Fork of async-raft’s memstore crate. -
tokio-async-std
An async-std that can fit into tokio ecosystem straight ahead
-
frosty-macros
Frosty proc macros
-
async-graphql-relay
Relay support for async-graphql
-
d3-derive
A framework for server development – the derive macro
-
mqttc
Mqttc is a client for the MQTT protocol
-
nsq-client
Rust client for the NSQ realtime message processing system
-
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. -
async-graphql-warp
async-graphql for warp
-
genawaiter-macro
Convenience macros for generators (genawaiter)
-
async-priority-queue
An async-aware priority queue
-
heim-disk
Cross-platform disk information
-
heim-derive
Derive macros for heim crates
-
stalk
Simple library for sending serialized data with tokio
-
futures-enum
#[derive(Future, Stream, Sink, AsyncRead, AsyncWrite, AsyncSeek, AsyncBufRead)] for enums
-
async-handle
A reference-counted async RwLock
-
gj
Event loop and promises
-
ex-futures
An extension of
futures -
connman
A ConnMan library that abstracts the D-Bus layer
-
safina-sync
Safe structs for sharing or sending data between async tasks
-
strawpoll
A wrapper to avoid spurious polling
-
delay
A collection of trait and classes to make your thread wait (and timeout)
-
async-pipe
Creates an asynchronous piped reader and writer pair using tokio.rs
-
safina-async-test
Macro for running async tests
-
yaaf-macros
Procedural macros for using YAAF
-
async-compat
Compatibility adapter between tokio and futures
-
must_future
A wrapper future marked must_use - mainly to wrap BoxFutures
-
fourche
A simple task queue named after a lion with forked tail (queue fourché), works with Redis
-
tempest-source-mock
Tempest source implementation of a Mock Queue
-
blocking_pool
A thread pool for running synchronous I/O in asynchronous applications
-
async-stream-http-tunnel-grader
Asynchronous stream http tunnel grader
-
minimal-executor
A minimal executor for asynchronous tasks based on the futures-rs library
-
rumpsteak-macros
Session types for asynchronous communication between multiple parties
-
riker-cqrs
Provides Command Query Responsibility Separation for Riker applications
-
eventsourcing-derive
Custom derive macros for Eventsourcing components
-
executor-trait
A collection of traits to define a common interface across executors
-
libaster
A light, fast and powerful cache proxy written in Rust
-
reusable-box-future
A reusable
Pin<Box<dyn Future<Output = T> + Send>> -
futures-util
Common utilities and extension traits for the futures-rs library
-
opendht
A Rust API for OpenDHT
-
actix-rt
Tokio-based single-threaded async runtime for the Actix ecosystem
-
completion-io
Core traits and types for asynchronous completion-based I/O
-
implicit-await-macro
#[implicit_await] procedural macro implementation
-
stopper
an async stream and future stopper mechanism
-
futures-zmq
Provides Futures abstractions for ZeroMQ on any futures executor
-
mailgun_api
Api for Mailgun in rust
-
sealrs
Set of classic asynchronous primitives (Actors, Executors, Futures / Promises)
-
hyper_lua_actor
Binding of lua_actor & hyper
-
dummy-waker
Get a
core::task::Wakerthat does absolutely nothing -
wombo
Utilities for managing event loop threads
-
mirai
A Futures layer over Mio
-
lelet
golang like task executor
-
retry_fn
A simple retry function with versions for blocking or non-blocking, tokio or async-std
-
mio-pidfd
mio support for Linux’s pidfd
-
bastion-qutex
Synchronization mechanisms that rely on lock-free and other non-(thread)blocking techniques, such as Rust futures, to guarantee mutually exclusive or shared exclusive access to data
-
thespis_impl
Reference implementation for the thespis actor model
-
gw2rs
A Rust library for the Guild Wars 2 API
-
futures-timer
Timeouts for futures
-
kompact
Kompact is a Rust implementation of the Kompics component model combined with the Actor model
-
futuristic
Extensions to the futures crate
-
ws-lite
Naive websocket server implemented using async / await
-
yaar
Yet another asynchronous runtime optimized around configuration and no_std
-
xilinx-dma
Userspace Xilinx AXI DMA Interface
-
lamellar-prof
Lamellar is an asynchronous tasking runtime for HPC systems developed in RUST
-
futures-x-io
Compatible with futures io and tokio io
-
tokio-file-unix
Asynchronous support for epollable files via Tokio on Unix-like platforms
-
hitbox-redis
Hitbox redis backend actor
-
tokio-buf
Asynchronous stream of byte buffers
-
heim-memory
Cross-platform memory information
-
async-graphql-tide
async-graphql for tide
-
tower-buffer
Buffer requests before dispatching to a
Service -
mobc-bolt
A bolt-client manager for the mobc connection pool
-
async-fs
Async filesystem primitives
-
memstore
An in-memory implementation of the
async-raft::RaftStoragetrait -
futures-async-runtime-preview
Runtime for the async/await macros in the
futurescrate -
local-pool-with-id
A minor variation on a LocalPool executor which exposes unique IDs for tracking future completion
-
async-dup
Duplicate an async I/O handle
-
mio-timerfd
mio support for linux’s timerfd
-
novaposhta
[UPDATED] Api for novapostha
-
background-jobs-server
Jobs processor server based on ZeroMQ
-
thetvdb
TheTVDB API async client
-
safina-threadpool
Safe thread pool
-
extern_executor
Async executor which delegates futures polling to external event-loop
-
futures-polling
An enum similar to Poll, but containing a future in its Pending variant
-
dialectic-macro
Procedural macros used by and exported from the Dialectic crate
-
smol-timeout
A way to poll a future until it or a timer completes
-
heim-sensors
Cross-platform sensors information
-
d3
A framework for server development
-
stream_multiplexer
Combines many streams into a few
-
catty
Send and await a value asynchronously
-
futures-io
The
AsyncRead,AsyncWrite,AsyncSeek, andAsyncBufReadtraits for the futures-rs library -
relay
A lightweight oneshot Future channel
-
futures-fs
A Futures implementation for File System operations
-
futures-channel
Channels for asynchronous communication using futures-rs
-
uexec
Simple work-stealing global and local executor
-
simple-async-local-executor
A single-threaded polling-based executor suitable for use in games, embedded systems or WASM
-
tokio-udp-framed
Based on UdpFramed from tokio-util but with some quality of life modifications to support shared ownership of
UdpSocketand to split Send/Recv into their own types -
tokio-beanstalkd
Asynchronous client library for interacting with Beanstalkd work queue
-
remem
Thread-safe object reuse
-
safina-net
Safe async network functions
-
tempest-source-redis
Tempest source implementation for Redis Streams
-
direct-executor
An executor that directly executes futures, suitable for embedded environments
-
futures-macro
The futures-rs procedural macro implementations
-
async-graphql-derive
Macros for async-graphql
-
futures-async-stream-macro
Implementation detail of the
futures-async-streamcrate -
async-macros
Macros for async-std
-
tower-retry
Retry failed requests
-
thespis
The interface of the thespis actor model (contains only traits)
-
safina-select
Safe async select function, for awaiting multiple futures
-
redis-asio
Asynchronous Redis driver based on tokio
-
async-graphql-axum
async-graphql for axum
-
heim-runtime
Runtime shims for heim crate
-
sendfile
Sendfile is a wrapper around the sendfile(2) system call
-
heim-host
Cross-platform host information
-
actix-multipart
Multipart form support for Actix Web
-
tower-timeout
Apply a timeout to requests, ensuring completion within a fixed time duration
-
async-reactor-trait
reactor-trait implementation for async-io
-
suspend-channel
Channel and stream implementations
-
duplexify
Combine a reader + writer into a duplex of Read + Write
-
async-thread
Futures version of std::thread