-
tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
futures
An implementation of futures and streams featuring zero allocations, composability, and iterator-like interfaces
-
async-std
Async version of the Rust standard library
-
mio
Lightweight non-blocking IO
-
tokio-rustls
Asynchronous TLS/SSL streams for Tokio using Rustls
-
async-graphql
A GraphQL server library implemented in Rust
-
rdkafka
Rust wrapper for librdkafka
-
wiremock
HTTP mocking to test Rust applications
-
futures-channel
Channels for asynchronous communication using futures-rs
-
async-io
Async I/O and timers
-
tokio-stream
Utilities to work with
Streamandtokio -
async-global-executor
A global executor built on top of async-executor and async-io
-
futures-io
The
AsyncRead,AsyncWrite,AsyncSeek, andAsyncBufReadtraits for the futures-rs library -
event-listener
Notify async tasks or threads
-
suppaftp
A super FTP/FTPS client library for Rust
-
tokio-serial
A serial port implementation for tokio
-
paho-mqtt
The Official Eclipse Paho MQTT Rust Client Library. This is a wrapper around the Paho C library
-
async-stream
Asynchronous streams using async & await notation
-
pollster
Synchronously block the thread until a future completes
-
multer
An async parser for
multipart/form-datacontent-type in Rust -
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
-
fred
An async Redis client built on Tokio
-
tower-lsp
Language Server Protocol implementation based on Tower
-
asynchronous-codec
Utilities for encoding and decoding frames using
async/await -
tower-service
Trait representing an asynchronous, request / response based, client or server
-
csv-async
CSV parsing for async
-
mio-serial
A serial port implementation for mio
-
futures-executor
Executors for asynchronous tasks based on the futures-rs library
-
pharos
Observer pattern which generates a futures 0.3 stream of events
-
futures-signals
Zero cost FRP signals using the futures crate
-
etcd-client
An etcd v3 API client
-
polling
Portable interface to epoll, kqueue, event ports, and wepoll
-
miow
A zero overhead I/O library for Windows, focusing on IOCP and async I/O abstractions
-
actix
Actor framework for Rust
-
async-graphql-actix-web
async-graphql for actix-web
-
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.
-
tokio-util
Additional utilities for working with Tokio
-
twilight-standby
Utility to filter wait for filtered incoming events for the Twilight ecosystem
-
rusty-penguin
A fast TCP/UDP tunnel, transported over HTTP WebSocket
-
fluvio-future
I/O futures for Fluvio project
-
bb8
Full-featured async (tokio-based) connection pool (like r2d2)
-
scc
High performance containers and utilities for concurrent and asynchronous programming
-
redis-async
An asynchronous futures based Redis client for Rust using Tokio
-
tokio_wasi
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
futures-locks
Futures-aware lock primitives
-
rxrust
A Rust implementation of Reactive Extensions
-
kdbplus
Dual q/kdb+ interface for API to build a shared library and an IPC client
-
linemux
A library providing asynchronous, multiplexed tailing for (namely log) files
-
rust-parallel
Run commands in parallel
-
ate
Distributed immutable data store with strong encryption and authentication
-
async_executors
Implements Spawn, SpawnLocal and SpawnHandle for commonly used executors
-
delay_timer
Time-manager of delayed tasks. Like crontab, but synchronous asynchronous tasks are possible, and dynamic add/cancel/remove is supported.
-
etcd-rs
etcd client for rust
-
tokio-pipe
Asynchronous pipe(2) library using tokio
-
krecik
Asynchronous, parallel external service checker (and reporter), using industry standard libraries: Curl, ngHTTP2 and OpenSSL
-
next-gen
Safe generators on stable Rust
-
keycloak
Keycloak Admin REST API
-
dataloader
Rust implementation of Facebook's DataLoader using async-await
-
background-jobs
Background Jobs implemented with actix and futures
-
local-channel
A non-threadsafe multi-producer, single-consumer, futures-aware, FIFO queue
-
rdkafka-sys
Native bindings to the librdkafka library
-
tor-rtcompat
Compatibility layer for asynchronous runtimes, used by Tor
-
tokio-graceful-shutdown
Utilities to perform a graceful shutdown on a Tokio based service
-
tmq
ZeroMQ bindings for Tokio
-
pasts
Minimal and simpler alternative to the futures crate
-
stream-cancel
A library for interrupting asynchronous streams
-
apis
Reactive, session-oriented, asynchronous process-calculus framework
-
coerce
Async actor runtime and distributed systems framework
-
aqueue
fast speed thread safe async execute queue
-
ractor
A actor framework for Rust
-
postage
An async channel library
-
futures-rustls
Asynchronous TLS/SSL streams for futures using Rustls
-
actix-web-flash-messages
Flash messages for actix-web applications
-
ghost_actor
GhostActor makes it simple, ergonomic, and idiomatic to implement async / concurrent code using an Actor model
-
celery
Rust implementation of Celery
-
glommio
Glommio is a thread-per-core crate that makes writing highly parallel asynchronous applications in a thread-per-core architecture easier for rustaceans
-
nb
Minimal non-blocking I/O layer
-
flo_binding
Declarative binding library for Rust
-
mpart-async
Asynchronous (Futures-Base) Multipart Requests for Rust
-
rfd
Rusty File Dialog
-
toy-rpc
An async RPC that mimics golang net/rpc's usage and supports both async-std and tokio
-
nature
Nature is a development support platform, it separates data definition from code, so it decouple the data from business system
-
tokio-retry
Extensible, asynchronous retry behaviours for futures/tokio
-
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-socks5
An async/.await SOCKS5 implementation
-
futures-timer
Timeouts for futures
-
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)…
-
sn_sdkg
Safe Network Synchronous Distributed Key Generation: enables dealerless section key generation
-
axum-sessions
🥠 Cookie-based sessions for Axum via async-session
-
syslog-rs
A native Rust implementation of the glibc/libc syslog
-
futures-concurrency
Concurrency extensions for Future
-
c-ares-resolver
An asynchronous DNS resolver, backed by c-ares
-
rseip
rseip - Ethernet/IP (CIP) client in pure Rust
-
mobc
A generic connection pool with async/await support
-
git-actor
A way to identify git actors
-
async-oneshot
A fast, small, full-featured, async-aware oneshot channel
-
unicycle
A scheduler for driving a large number of futures
-
zephyrus
A slash-command framework meant to be used with twilight
-
dptree
An asynchronous event dispatch mechanism for Rust
-
hyper-proxy
A proxy connector for Hyper-based applications
-
blocking
A thread pool for isolating blocking I/O in async programs
-
esrs
A Prima.it-opinionated library to achieve cqrs/es
-
safina-timer
Safe async timers
-
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.)
-
synchronized-writer
A tiny implement for synchronously writing data
-
tiny-tokio-actor
A simple and tiny actor library on top of tokio
-
actix-rt
Tokio-based single-threaded async runtime for the Actix ecosystem
-
round-based
Driver for round-based protocols
-
deduplicate
caching, asynchronous, request deduplication
-
tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
stream-reconnect
Stream-wrapping traits/structs that automatically recover from potential disconnections/interruptions
-
rusty_falcon
Rust bindings for CrowdStrike Falcon API
-
nuclei
Proactive IO & runtime system
-
lamellar
Lamellar is an asynchronous tasking runtime for HPC systems developed in RUST
-
async-native-tls
Native TLS using futures
-
triggered
Triggers for one time events between tasks and threads
-
tokio-tower
Bridging the protocol gap between Tokio and Tower
-
eventuals
Eventually consistent values
-
fastcgi-client
Fastcgi client implemented for Rust
-
tonari-actor
A minimalist actor framework aiming for high performance and simplicity
-
ginepro
A client-side gRPC channel implementation for tonic
-
fibers
A Rust library to execute a number of lightweight asynchronous tasks (a.k.a, fibers) based on futures and mio
-
async-scoped
Spawn scoped (non 'static) asynchronous futures for async_std and tokio runtimes
-
wasmbus-rpc
Runtime library for actors and capability providers
-
teloxide-core
Core part of the
teloxidelibrary - telegram bot API client -
tokio-test
Testing utilities for Tokio- and futures-based code
-
poll-promise
Poll the result of an async operation in a game or immediate mode GUI
-
smolscale
A high-performance async-task scheduler
-
smelling_salts
Abstraction over OS APIs to handle asynchronous device waking
-
kafka-threadpool
An async rust threadpool for publishing messages to kafka using SSL (mTLS) or PLAINTEXT protocols
-
stakker
A lightweight low-level single-threaded actor runtime
-
didcomm-rs
DIDComm messaging v2 specifications implementation: https://identity.foundation/didcomm-messaging/spec/
-
overclock
A framework for building data-driven distributed systems
-
prost-codec
Asynchronous de-/encoding of Protobuf structs using asynchronous-codec, unsigned-varint and prost
-
tokio-js-set-interval
Allows you to use
setInterval(callback, ms)andsetTimeout(callback, ms)as in Javascript inside atokioruntime. The library provides the macrosset_interval!(callback, ms)andset_timeout!(callback, ms) -
progenitor
An OpenAPI client generator
-
capnp-futures
async serialization for Cap'n Proto messages
-
buffer-unordered-weighted
Stream::buffer_unordered where each future can have a different weight
-
smol-potat
Proc macro for smol runtime
-
async-graphql-warp
async-graphql for warp
-
tokio-socketcan
Asynchronous Linux SocketCAN sockets with tokio
-
youtubei-rs
A asynchronous implementation of the invidious innertube aka youtubei API wrapper
-
passivized_docker_engine_client
Docker Engine Client - manage and run containers, images, and volumes
-
ya-gcp
APIs for using Google Cloud Platform services
-
gcra
A basic implementation of GCRA algorithm for rate limiting
-
r2r
Easy to use, runtime-agnostic, async rust bindings for ROS2
-
image_search
A crate designed to search Google Images based on provided arguments
-
conjure-object
Runtime support for generated Conjure objects
-
openraft
Advanced Raft consensus
-
async-shutdown
one-stop solution for async graceful shutdown
-
async_io_utilities
An asynchronous IO utilities crate powered by
tokio -
wg
Golang like WaitGroup implementation for sync/async Rust
-
async-trait-fn
A fork of async-trait with some useful options
-
par-stream
Asynchronous parallel streams analogous to rayon
-
ratsio
Ratsio is a Rust client library for NATS messaging system and NATS Event Streaming
-
peace_rt_model
Runtime data types for the peace automation framework
-
async-ssh2-lite
Asynchronous ssh2
-
dark-std
dark-std is an Implementation of asynchronous containers build on tokio. It uses a read-write separation design borrowed from Golang
-
async-process
Async interface for working with processes
-
retainer
Minimal async cache in Rust with support for key expirations
-
atedb
Distributed datachain (database) built on an immutable data store with strong encryption and authentication
-
pi_async
Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
-
eventsource-stream
A basic building block for building an Eventsource from a Stream of bytes
-
futures-delay-queue
Async delay queue backed by async-std and futures-timer
-
futuresdr
An Experimental Async SDR Runtime for Heterogeneous Architectures
-
coerce-redis
Redis actor persistence provider for Coerce. Supports event sourcing and snapshots
-
ipc-rpc
A wrapper over servo/ipc-channel which provides many high level features
-
deluge
A highly concurrent stream library driving the underlying futures either concurrently or in parallel to process streaming operations as quickly as possible
-
etcdv3client
a simple etcdv3 client
-
nominatim
A reverse geocoding API client powered by openstreetmap
-
torut
torut is reasonable tor controller written in rust utilizing tokio for async communication
-
selectme
A fast and fair select! macro for asynchronous Rust
-
messagebus
MessageBus allows intercommunicate with messages between modules
-
genawaiter
Stackless generators on stable Rust
-
actix-ws
Websockets for the Actix runtime, without Actors
-
tor-rtmock
Testing mock support for tor-rtcomapt
-
scoped-futures
A utility crate for imposing upper bounds on Future lifetimes
-
reducer
A predictable reactive framework for Rust apps
-
minus
An asynchronous paging library for Rust
-
opencl-sys
OpenCL C FFI bindings for the Rust programming language
-
stop-token
Experimental cooperative cancellation for async Rust
-
async-bincode
Asynchronous access to a bincode-encoded item stream
-
lsp-async-stub
An LSP server stub for futures
-
smol
A small and fast async runtime
-
catty
Send and await a value asynchronously
-
monzo-lib
async Monzo client in pure rust
-
process-stream
Thin wrapper around [
tokio::process] to make it streamable -
lunatic-process
Lunatic's core process, mailbox and message abstraction'
-
minetestworld
Read and modify Minetest worlds
-
futures-buffered
future concurrency primitives with emphasis on performance and low memory usage
-
effectum
An embeddable task queue based on SQLite
-
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
-
tokio-interruptible-future
Easily interrupt async code in given check points. It's useful to interrupt threads/fibers.
-
apollo-router
A configurable, high-performance routing runtime for Apollo Federation 🚀
-
async_zmq
Async version for ZeroMQ bindings
-
backon
Retry futures in backoff without effort
-
rmp-futures
Async Rust MessagePack and MessagePack-RPC
-
swarm-commander
Manage tons of commands asynchronously
-
async-variadic
Simple async variadic functions in Rust with trait bounds
-
futures-retry
Retry your Futures and Streams!
-
lua_actor
Lua Actor for Rust(sync/async)
-
tokio-smoltcp
An asynchronous wrapper for smoltcp
-
async-observable
Async & reactive synchronization model to keep multiple async tasks / threads partially synchronized
-
destream
Library for async stream (de)serialization
-
async-utf8-decoder
Convert AsyncRead to incremental UTF8 string stream
-
async-codec
Utilities for creating async codecs
-
puppet
A simple actor framework which uses no dynamic dispatch or boxing
-
mio_wasi
Lightweight non-blocking IO
-
elfo
Your next actor system
-
hentai
API wrapper for nhentai.net
-
twilight-http-ratelimiting
Discord REST API ratelimiter implementations for the Twilight ecosystem
-
tokio-io-timeout
Tokio wrappers which apply timeouts to IO operations
-
aiur
Single threaded async executor with structured concurrency
-
safina-executor
Safe async runtime
-
c-ares
A Rust wrapper for the c-ares library, for asynchronous DNS requests
-
fluvio-async-tls
Asynchronous TLS/SSL streams using Rustls
-
poster
MQTTv5 client library written in Rust
-
tokio-rusqlite
Asynchronous handle for rusqlite library
-
deadpool-fantoccini
Dead simple async session pool for fantoccini
-
kumoko
A simple asynchronous server/client crate built on tokio for easy two-way streaming
-
smux
Asynchronous smux multiplexing library
-
msq
Rust library implementation of the legacy Master Server Query Protocol
-
agnostik
Executor Agnostic Runtime that can run your futures with your favourite Executor
-
name-it
Give a name to async fn return types
-
quickwit-actors
Actor framework used in quickwit
-
task-exec-queue
A asynchronous task execution queue
-
lazy_async_promise
Primitives for lazily getting data from futures with tokio for immediate mode guis
-
monoio-compat
A compat wrapper for monoio
-
ipc-queue
An implementation of FIFO queue described in fortanix-sgx-abi used for asynchronous usercalls
-
ctrlgen
Generate enums for message-passing services
-
mailbox_processor
A small little actor abstraction inspired by the FSharp Mailbox Processor which in turn was inspired by erlang
-
iap
async google/apple receipt validation using hyper
-
actix-interop
Use async/await syntax with actix actors
-
transform-stream
Lightweight async stream wrapper
-
piston_rs
An async wrapper for the Piston code execution engine
-
acu
Utilities for building asynchronous actors
-
handle
A Handle Trait for asynchronous context pipeline
-
ksoft
KSoft.SI api wrapper written in pure Rust
-
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-scopes
Runtime agnostic, nestable, scopes for spawning non-static futures
-
tokio-xmpp
Asynchronous XMPP for Rust with tokio
-
elk-mq
A Message Queue implementation in rust, using Redis as a communication medium
-
ebus
Basic Event Bus implementation
-
dynamodb-lease
Dynamodb distributed lock client
-
heph-inbox
Bounded capacity channel designed to be used as inbox for actors. Also supports one shot channels.
-
mio-extras
Extra components for use with Mio
-
protobuf_codec
Encoders and decoders for Protocol Buffers based on bytecodec crate
-
goods
Async assets system
-
async-ctrlc
Async wrapper of
ctrlc -
lease
Object pool that leases values and automatically returns them with async support
-
peace_rt_model_native
Runtime data types for the peace automation framework
-
apocalypse
Simple actor framework for Rust
-
stakker_mio
Mio I/O polling integration for the Stakker crate
-
async-executor
Async executor
-
hypixel_api
Generic wrapper around the hypixel api (automatic rate-limiting on client-side)
-
minimal-executor
A minimal executor for asynchronous tasks based on the futures-rs library
-
ferrisgram
An elegent rust client for the Telegram Bot API
-
async_singleflight
Async singleflight
-
async-io-typed
Adapts any AsyncRead or AsyncWrite type to send serde compatible types
-
tokio-uring
io-uring support for the Tokio asynchronous runtime
-
stream_throttle
Provides a Stream combinator, to limit the rate at which items are produced
-
tcpclient
Asynchronous tcpclient based on aqueue actor
-
futures-micro
Minimal, no_std compatible async prelude
-
workflow-async-trait
Type erasure for async trait methods (customized, see README.md notes)
-
async-change-tracker
reactive change notifications using futures
-
libaio-futures
Straightforward Linux AIO using Futures/async/await
-
fluvio-stream-model
Fluvio Event Stream Model
-
zippyst
Resolve zippyshare.com download links
-
poolparty
Added functionality for the
futures::executor::ThreadPoolfutures executor -
streamline
Reversible futures::Stream-based state machines
-
ws_stream_tungstenite
Provide AsyncRead/AsyncWrite over Tungstenite WebSockets
-
pwner
Pwner is a Process Owner crate that allows ergonomic access to child processes
-
zeebe
A rust client for defining, orchestrating, and monitoring business processes across microservices using Zeebe
-
async-ringbuf
Async SPSC FIFO ring buffer
-
cxx-async
Simple interoperability between C++ coroutines and asynchronous Rust
-
slings
A small async runtime based on io-uring for Rust
-
ractor_cluster
Distributed cluster environment of Ractor actors
-
futures-test
Common utilities for testing components built off futures-rs
-
akt
An actors library for Rust and Tokio designed to work with async / await message handlers out of the box
-
multishot
An async, lock-free, reusable channel for sending single values to asynchronous tasks
-
mini-telnet
Asynchronous minimal telnet library
-
oc-wasm-futures
Futures that allow async/await to be used in OC-Wasm for a more ergonomic experience
-
webex
Interface to Webex Teams REST and WebSocket APIs
-
csnmp
Community-based async (Tokio) SNMP client library
-
prokio
An asynchronous runtime compatible with WebAssembly and non-WebAssembly targets
-
murray
A minimal actor definition macro using Tokio
-
thin_main_loop
Thin, cross-platform, main event loop. A building block for native GUI applications, among other use cases.
-
hls_lfcd_lds_driver
Rust driver for ROBOTIS HLDS HLS-LFCD-LDS (LDS-01)
-
actix-broker
Message broker for the Actix actor framework
-
stream-future
Implement an async iterator with return value
-
async-codec-lite
Adaptors from AsyncRead/AsyncWrite to Stream/Sink using futures
-
lighthouse-client
API client for a light installation at the University of Kiel
-
async-raft
An async implementation of the Raft distributed consensus protocol
-
async_main
Runtime-agnostic async main proc macro
-
waitgroup
Async waitgroup for a collection of task to finish
-
async-entry
extended Tokio's proc macros
-
retry_future
Retry futures mechanism
-
par_io
Parallel, async file I/O library with control over memory usage with no dependencies
-
async-ops
Use std::ops traits with Futures
-
actox
FIXME
-
arrows
An actor framework in rust with message durability and ingestion order processing of of messages
-
permit
A struct for cancelling operations
-
tokio-stream-multiplexor-fork
Stream Multiplexor for tokio with a tcp like interface
-
tokio-serde-cbor
Integration of serde_cbor into tokio-io, to allow sending CBOR encoded frames across network (and possibly through other transports)
-
passivized_vault_client
Vault Client - initialize and monitor Hashicorp Vault nodes
-
dbus-async
Asynchronous DBus library
-
uppercut
Small and simple actor model implementation
-
bp3d-threads
Yet another threading library intended to simplify concurrency in BP3D
-
async-timers
Provides asynchronous timer primitives
-
tonic_lnd
An async library implementing LND RPC via tonic and prost
-
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
-
async-gcode
An async gcode parser for no_std targets
-
sparkle-convenience
A wrapper over Twilight designed to make it more convenient to use
-
heim
Cross-platform framework for system information
-
madsim-tokio
The
tokiosimulator on madsim -
gentian
gentian: a proc macro that transforms generators to state machines
-
rspl
A stream processor language
-
async-fuse
Helpers for fusing asynchronous computations
-
async_cell
A Cell<Option<T>> that you can await on
-
dd-tracing-layer
Send your logs to Datadog
-
gritlab
Gitlab rust API sdk
-
async_dag
An async task scheduling utilitiy
-
mqtt_actor
An mqtt adapters (from port and adapters) to be used with actix actors
-
cooked-waker
A safe interface for creating async Wakers
-
xtra
A tiny actor framework
-
tokio-tasker
Lets you stop and join groups of Tokio tasks
-
selecting
Cross-platform wrapper over select
-
actix-daemon-utils
Daemon Utilities by actix
-
hannibal
a small actor library
-
queen
message queue
-
batrachia
Facilitating high-level interactions between Rust and WebRTC
-
tokio-shutdown
Wait for a stop signal across multiple threads
-
speedracer
A crate for racing futures and ranking the results
-
killswitch
Killswitch used to broadcast a shutdown request
-
hl7-mllp-codec
A Tokio codec for HL7 Minimal Lower Layer Message Transport protocol (MLLP)
-
async_event_streams
Asynchronous Events Pub/Sub Library
-
rx_rust_mp
A protoype implementation of the ReactiveX API in Rust using a message passing approach
-
garcon
A collection of trait and classes to make your thread or async function wait
-
wag
Go like sync.WaitGroup implementation in Rust. (sync/async)
-
jsonrpc-rs
Futures base jsonrpc server/client framework
-
stomp-rs
STOMP client
-
local-waker
A synchronization primitive for thread-local task wakeup
-
awaitable
Awaitable type with input and output that can be stored in container
-
money2
For storing and asynchronously converting between (a subset of) ISO-4217 currencies
-
kvarn_async
Async utilities used in the Kvarn web server
-
uringy
A simple single-threaded async runtime for Rust based on io_uring
-
datacake
A batteries included framework for building fault-tolerance distributed data systems
-
tokio_schedule
This crate helps schedule tasks in tokio runtime
-
rustyline-async
A minimal readline with multiline and async support
-
crown
The crown jewel of rust libraries
-
zookeeper-async
An async ZooKeeper client
-
strawpoll
A wrapper to avoid spurious polling
-
tokio-scoped
Scoped Runtime for tokio
-
background-jobs-core
Core types for implementing an asynchronous jobs processor
-
worst-executor
A spin-loop like executor for async
-
async-minecraft-ping
An async Rust client for the Minecraft ServerListPing protocol
-
mediatrix
Strongly typed, extensible event mediator
-
pandet
A lightweight library to help act on panics of detached async tasks
-
async-broadcast
Async broadcast channels
-
ib_tws_tokio
An Interactive Broker's TWS API client for Tokio
-
phoenix_channels_client
Provides an async-ready client for Phoenix Channels in Rust
-
switchyard
Real-time compute focused async executor
-
futures-util-either
futures_util::future::Either Ext
-
async-tls
Asynchronous TLS/SSL streams using Rustls
-
auto-future
For quickly making a struct into a future via an async fn
-
tokio-process-stream
Simple crate that wraps a tokio::process into a tokio::stream
-
graceful-shutdown
Graceful Shutdown for async code
-
async_io_stream
IntoAsyncRead on steriods
-
dencode
Utilities for decoding and encoding frames from readers and writers
-
libevent
Rust bindings to the libevent async I/O framework
-
actors-rs
Easily build fast, highly concurrent and resilient applications. An Actor Framework for Rust.
-
async-liveliness-monitor
A Liveliness Monitor for your Asynchronous Runtimes
-
abar
An interface for creating dynamic, "blocks"-style status strings
-
parallel-stream
Data parallelism library for async-std
-
tracing-layer-slack
Send filtered tracing events to Slack
-
async-speed-limit
Asynchronously speed-limiting multiple byte streams
-
noosphere-core
Core data types of the Rust Noosphere implementation
-
async-tun
Asynchronous allocation of TUN/TAP devices using async-std
-
plctag-async
async wrapper for libplctag
-
async-walkdir
Asynchronous directory traversal for Rust
-
safina-async-test
Macro for running async tests
-
stream-operators
a collection of selected rxjs operators for rust standard Stream
-
dabus
Dynamic Aplication Controll Bus - an asynchronous, event based module system for thoes who want to move fast and *not* break things
-
async_object
Async Object wrapper
-
async-component-winit
winit async-component wrapper
-
fibers_rpc
RPC library built on top of fibers crate
-
futures-await-test
Async test support for Rust through a procedural macro. This crate defines the
#[async_test]attribute to make writing tests that use async/await easier. -
futures-util
Common utilities and extension traits for the futures-rs library
-
webrocket
A closure focused WebSocket server implementation
-
discro
DISCRete Observables for asynchronous Functional Reactive Programming (FRP)
-
tokio-nsq
A Rust NSQ client built on Tokio. Tokio NSQ aims to be a feature complete NSQ client implementation.
-
tokio-send-fd
A wrapper for tokio::net::UnixStream to send file descriptors
-
peace_rt
Runtime logic for the peace automation library
-
ultra-batch
Tokio-based library to batch and cache database queries or other data lookups
-
detect-targets
Detect the target of the env at runtime
-
nexmark
Nexmark data stream generator
-
async_logger
Asyncronous logger allows writing arbitrary slices to a memory buffer, which then processed by a writer in it's own thread
-
blobnet
Non-volatile, distributed file cache backed by content-addressed storage
-
key-lock
Library for mutual exclusion by keys
-
otdb
An open trivia database API wrapper
-
stackfuture
StackFuture is a wrapper around futures that stores the wrapped future in space provided by the caller
-
fure
Retrying futures using different policies
-
future-clicker
Reimplementation of manual_future without using
futuresunstable -
web3-async-native-tls
Temporary package released to crates.io. Fork of async-native-tls. Please don't use.
-
async-xml
A crate for deserializing XML data asynchronously
-
deadpool-bolt
A bolt-client manager for the deadpool connection pool
-
snowflake
A module for generating guaranteed process unique IDs
-
async-drop-guard
This library offers hash map and cache data structures where individual entries can be locked
-
any-mpsc
An mpsc that allows arbitrary types to be passed through
-
fil_actors_runtime
System actors for the Filecoin protocol
-
eventador
lock-free pub/sub event-bus with sync and async APIs
-
persway
Sway IPC daemon
-
deadpool-lapin
Dead simple async pool for lapin
-
zeromq
A native Rust implementation of ZeroMQ
-
from-pest
Convert from a pest grammar to a typed AST
-
async-pidfd
Process file descriptors (pidfd) for Linux
-
tourniquet-tonic
Async native round-robin manager for remote services. Tonic integration.
-
bipe
asynchronous I/O pipe
-
tokio-io-utility
Some helper functions for tokio::io
-
thinnbox
An expansion of the currently nightly ThinBox of the standard library
-
kompact
Kompact is a Rust implementation of the Kompics component model combined with the Actor model
-
holidayapi_rust
A HolidayAPI library for Rust
-
basteh-redis
An implementation of basteh based on redis-rs
-
bleasy
High-level BLE communication library
-
dndx-fork-tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
miau
Async aware and extensible layered configuration system
-
cb_fut
Call function that return value via callback without a callback
-
tbot
Make cool Telegram bots with Rust easily
-
flo-state
Lightweight actor library
-
vampirc-io
A library for asynchronous, non-blocking, UCI protocol–based communication between chess UIs and chess engines
-
agner-actors
An actor toolkit inspired by Erlang/OTP (actors)
-
openmensa-rs
A library to interact with the openmensa api
-
future-combinator-params
A simple functions to inject extra arguments between futures combinators Then/AndThen
-
circulate
Lightweight PubSub framework that supports both sync and async
-
pirates
Simple async RPC lib
-
moxie
Incremental runtime for interactive software
-
rs-copier
Copy and move files asynchronously
-
hash-map-id
HashMap wrapper with incremental ID (u64) as key
-
thesis
Rust library for controlling & monitoring experimental code paths
-
tokio-stream-multiplexor
Stream Multiplexor for tokio with a tcp like interface
-
task-group
manage groups of tokio tasks
-
kerberos_constants
Constants used by differente objects and actors of the Kerberos protocol
-
wgpu_tokio
Async bindings using tokio for wgpu
-
tokio-takconnect
Asynchronous Playtak client
-
future-queue
Adapters to manage a queue of futures, where each future can have a different weight
-
beul
It executes futures
-
pris
A library for interfacing with players compatible with the MPRIS DBus specification
-
signals
A functional-reactive-like library for Rust that allows asynchronous chaining
-
ector
Ector is an open source async, no-alloc actor framework for embedded devices
-
pinarcmutex
Provides a
PinArcMutextype, for shared mutable access to pinned data -
charred
charred char checking
-
tokio-executor-trait
executor-trait implementation for tokio
-
async-ucx
Asynchronous Rust bindings to UCX
-
act-zero
Ergonomic actor system
-
tokio-util_wasi
Additional utilities for working with Tokio
-
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
-
tokio-zmq
Provides Futures abstractions for ZeroMQ on the Tokio event-loop
-
rlua-async
Async support for rlua, via coroutines
-
tokio-easy-timer
A tokio-based task scheduler, with a user-friendly API
-
stund
An SSH tunnel maintenance daemon
-
framed_aio
A crate which allows performing async io operations in a framed manner
-
implicit-await
Implicitly await calls returning Future impls
-
signal-hook-async-std
async-std support for signal-hook
-
funfsm
An FSM library where the states are functions
-
qp
Quick Pool: High Performance Async Generic Pool
-
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
-
minehut
Simple, easy to use Rust wrapper for the Minehut API
-
tabs
A collection of asynchronous task abstractions, based on tokio
-
streammap-ext
StreamMap of Tokio with altered
nextthat returns when stream is dropped -
bromine
A flexible ipc protocol (previously rmp-ipc)
-
async-graphql-poem
async-graphql for poem
-
async-ioutil
A collection of Rust asynchronous I/O utilities
-
blocking-permit
Permits and a thread pool for blocking operations
-
calloop-notify
Calloop adapter for Notify
-
rmw_ttlmap
Minimal async cache in Rust with support for key expirations
-
jittr
A binary heap based jitter buffer implementation for zero latency udp/rtp streams
-
async-rustls-stream
An async tls stream library based on rustls and futures-io. Both for server/client.
-
wasmflow-streams
Rust library encapsulating the message packets sent across Wasmflow components
-
kompact-component-derive
A derive macro for Kompact component definitions
-
nbd-async
Block device drivers in userspace
-
async-injector
Reactive dependency injection for Rust
-
nasu
Command-line utility which poll on remote addresses in order to perform status checks periodically
-
eventsourcing
Event Sourcing for Rust
-
xtor
Async Actor framework for Rust which is blazing fast and rock solid
-
deadline
A one-macro crate to ensure assertions meet their deadlines
-
tokio-lxi
LXI protocol abstractions for Tokio
-
rusty_tarantool
Tarantul async client based on tokio framework
-
watermill
Blazingly fast, generic, and serializable online statistics
-
cohere
Async bindings for Cohere REST API
-
craftio-rs
A crate to read & write packets defined in mcproto-rs to I/O sinks/sources
-
mpi-sys
Message Passing Interface bindings for Rust
-
mikrotik_api
Rust library & minimal client to connect and interact with Mikrotik RouterOS API, usually exposed on port 8728
-
lagoinha
Lagoinha is a 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.
-
async-http-body
Agit init HttpBody Support Async Expressions
-
cf-pty-process-alpha
the tab multiplexer fork of tokio-pty-process. Interact with a child process through a pseudo-TTY, asynchronously using Tokio
-
aiven_rs
This is a rust sdk to interact with aiven-cloud apis
-
futures-rate
This library provides easy tools to help Rust applications guide critical resources or code paths from being overwhelmed
-
casus
A simple library containing a handful of event-based async primitives
-
abstract-ns
Abstract name service traits for use with futures (and tokio)
-
monoio
A thread per core runtime based on iouring
-
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.
-
oports
Async library to retrieve open ports for a given IP address
-
git-event
Customizable event handler for updates in remote git repositories
-
shared_stream
A crate for easily cloneable streams
-
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.
-
spin_on
A simple, inefficient Future executor
-
lookit
Asynchronously connect to devices
-
ads_client
An asynchronous, non-blocking ADS client
-
openai-api-fork
OpenAI API library for rust
-
pi_futures
feature select
-
tastyworks
Unofficial Tastyworks API
-
nb-executor
Single-future, #![no_std] executor based on event bitmasks
-
riker-patterns
A collection of common actor patterns for Riker
-
agnostik-attributes
Executor agnostik attributes
-
task-motel
Opinionated (Tokio) task manager with nested task groups and stoppable tasks
-
vmcircbuffer
Double Mapped Circular Buffer
-
futuresdr-frontend
Web Frontend for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
stakker_log
Logging support for Stakker
-
random-access-storage
Abstract interface to implement random-access instances
-
scipio
A set of utilities to allow one to write thread per core applications
-
futures-test-sink
Test utilities for futures::sink
-
rusturn
A Rust implementation of TURN server and client
-
tokio-scheduler-rs
Yet Another JobScheduler written with tokio runtime
-
side-futures
Send future for execution on the runtime that may be in a different thread
-
heph
Heph is an actor framework based on asynchronous functions
-
untokio
Automatically create tokio runtimes
-
bastor
A wrapper helps implementing actor with Bastion more easier with self-implemented state
-
reqwest-eventsource
Helper to build an Eventsource using reqwest
-
async-hofs
Various extention traits for providing asynchronous higher-order functions
-
tokio-iocp
IOCP support for the Tokio asynchronous runtime
-
callbag
Rust implementation of the callbag spec for reactive/iterable programming
-
async-mq
Zero-cost async-await abstraction of lapin AMQP client crate
-
codeforces
An asynchronous library for talking to the Codeforces API
-
craweb
Multithreaded asynchronous web server, written in Rust
-
runloop
Cancelable non-blocking polling threads (with optional timeouts)
-
linked-futures
Link futures into a block, which stops all of the included futures when any of the futures complete
-
taskwait
Runtime agnostic way to wait for a group of async tasks
-
signalr_rs
SignalR client based on actix web client and async await
-
stream_router
A Future aware router to dynamically route between Streams and Sinks
-
tokio-stomp
Asynchronous streaming STOMP client
-
aktors
Driver for derive-aktor
-
dyn-future
Convenient and fast dynamic Futures for Rust
-
jni-utils
Extra Utilities for JNI in Rust
-
pcap-async
Async/Stream Extensions for libpcap
-
itla
ITLA (micro laser) non-blocking control library using embedded-hal
-
async-oncecell
Asynchronous versions of OnceCell and Lazy
-
appliance
A lightweight framework to build async-friendly components with message-based intercommunications
-
mofo
Multiple Ongoing Futures Object - an abstraction for easily managing ongoing child tasks with futures
-
diny
An asynchronous, alloc-free serialization framework
-
async-mavlink
An async adapter for mavlink conections
-
northstar-rcon-client
Asynchronous RCON client for the Northstar mod
-
extreme
Extremely boring async function runner. MIT/Apache-2.0 license is available for spacejam's github sponsors.
-
rumpsteak
Session types for asynchronous communication between multiple parties
-
coachman
rust asynchronous task manager built on top of tokio framework
-
c_mcai_worker_sdk
AMQP Worker to listen and provide trait to process message
-
photonio
A runtime for asynchronous applications
-
async-ringbuffer
A nonblocking spsc ring buffer with fixed capacity
-
embedded-executor
Embedded systems-friendly
Futuresexecutor -
luis_sys
FFI bindings for Microsoft LUIS API
-
iou
io_uring bindings
-
archlinux-repo
Arch Linux repositories parser
-
txrx
A Rust take on the C++ unified executors proposal
-
tractor
Actor system modelled after Pony's actors
-
stream-ext
An extension trait for Streams that provides a variety of convenient combinator functions
-
golgi
An asynchronous, experimental Scuttlebutt client library
-
async_msp_cli
Async msp cli for iNav and BetaFlight
-
futuristic
Extensions to the futures crate
-
js-sys-futures
Utilities for working with the futures and js-sys crates
-
manual_future
A future that must be manually completed, similar to Java's CompletableFuture
-
tobytcp
A little library for sending messages over a tcp stream
-
sonor
a library for controlling sonos speakers
-
imgur2018
An Imgur upload client for async Rust
-
lib3h_zombie_actor
lib3h actor request tracking module
-
futures-ticker
An asynchronous recurring time event
-
quiverquant
A crate for accessing the QuiverQuant API
-
tokio-rayon
Mix async code with CPU-heavy thread pools using Tokio + Rayon
-
want
Detect when another Future wants a result
-
rt-local
Thread local asynchronous runtime working with platform-specific event loops
-
foxhole-api
A rust wrapper for the Foxhole War API
-
lazy_async_pool
An asyncronous object pool that generates objects on the fly
-
tokio-file
Asynchronous file I/O for Tokio
-
pcat
A dead-lock free parallel cat implementation
-
dialectic-compiler
Session type macro compiler for the Dialectic crate
-
named-retry
A simple utility for retrying fallible asynchronous operations
-
tokio-stdin-stdout
Thread- and future::sync::mpsc-based AsyncRead/AsyncWrite stdin/stdout with little buffering
-
gritea
Gitea API sdk
-
deferred
Rust crate to help perform deferred execution of code logic
-
peace_rt_model_web
Web support for the peace automation framework
-
kad
A generic / futures based implementation of the Kademlia Distributed Hash Table (DHT)
-
wookie
Async test/bench toolkit including single stepping executors. No-std compatible.
-
streamson-tokio
Tokio and streamson integration library
-
zeebest
An unofficial zeebe client for the future!
-
async-copy-progress
Asynchronous copying with progress callbacks
-
openraft-memstore
An in-memory implementation of the
openraft::RaftStoragetrait -
futures-async-combinators
toy futures combinators
-
tachyonix
A very fast asynchronous, multi-producer, single-consumer bounded channel
-
gen-z
Macro-free stream construction through asynchronous generators via an awaitable sender
-
tracing-actix
Allow tracing actor futures in actix
-
agreed
Fork of async-raft, the Tokio-based Rust implementation of the Raft protocol
-
dbus-async-derive
Handler trait derive macro for dbus-async
-
visiting_ref
Container types that asynchronously return ownership of a value to another context upon exiting scope
-
extern_executor
Async executor which delegates futures polling to external event-loop
-
futures-lite
Futures, streams, and async I/O combinators
-
serenity_ctrlc
Ctrl+C handler for serenity
-
archimedes_crontab_types
Crontab types package for archimedes, a high performance Rust/PostgreSQL job queue
-
simple-actor
Helper to write actor-based async code
-
json-array-stream
Incrementally reads a JSON array through an async stream
-
local-pool-with-id
A minor variation on a LocalPool executor which exposes unique IDs for tracking future completion
-
wait_not_await
Simple awaiter implementation
-
pantry
Temporary storage for reusing values that may decay
-
akinator-rs
A simple wrapper around the undocumented Akinator API
-
yaaf
Yet Another Actor Framework
-
django-query
Tools for mocking Django-style endpoints
-
portaudio-rs
PortAudio bindings for Rust
-
scoped_async_spawn
spawn non-static futures
-
arti-bench
A simple benchmarking utility for Arti
-
awaitgroup
Wait for a collection of async tasks to finish
-
async-task-ffi
Task abstraction for building executors
-
async-component-components
async-component components
-
diatomic-waker
An async, lock-free synchronization primitive for task wakeup
-
picoquic
Tokio aware picoquic bindings. Picoquic is a minimalist implementation of the QUIC protocol of the IETF.
-
thread-control
Rust library to control threads' execution/status
-
actix-casbin
An Actix actor for casbin
-
tokio-graceful-shutdown-without-anyhow
Utilities to perform a graceful shutdown on a Tokio based service
-
agner-utils
An actor toolkit inspired by Erlang/OTP (utils)
-
tokio-context
Contexts for cancelling asynchronous tasks using tokio
-
plumbing
An async abstraction to pipeline requests through a channel
-
spekt
std::future::Future and Result-based testing trait for managing the lifecycle of stateful, asynchronous tests
-
simple-scheduler
Schedule periodic tasks to run asynchronously
-
async-middleware
Simple async monad(ish) middleware in Rust using tuples and async trait transforms
-
schedwalk
Test futures under all possible polling schedules
-
lifeline
Lifeline is a dependency injection library for asynchronous message-based applications
-
lwactors
Lightweight actors for Rust using futures-rs
-
kay
Experimental high-performance actor system framework for Rust
-
safina-sync
Safe structs for sharing or sending data between async tasks
-
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…
-
completeq-rs
An alternative to passing messages between asynchronous tasks
-
scoped_spawn
Full structured concurrency for asynchronous programming
-
dwbhk
dwbhk-rs is a library for working with Discord Webhooks
-
cannyls_rpc
RPC library for operating cannyls's devices from remote nodes
-
diath
diath is a light-weight library for communication between tokio async tasks
-
async-sse
Async Server Sent Event parser and encoder
-
meltdown
A lightweight service manager to help with graceful shutdown of asynchronous applications
-
basteh-memory
An implementation of basteh based on hashmap(in memory)
-
madsim-macros
Madsim's proc-macro
-
heim-disk
Cross-platform disk information
-
telegram-bot-ars
A library for creating Telegram bots
-
derive-tokio-io
Derive AsyncRead and AsyncWrite
-
log-tracing-layer
Build your own custom tracing layer
-
motore-macros
Motore's proc macros
-
tourniquet
Async native round-robin manager for remote services
-
asynchronous
Promises Q style , async and event loops
-
mezzenger-channel
mezzenger transport over futures channels
-
async-attributes
Experimental language-level polyfills for Async Rust
-
limitation
A rate limiter using a fixed window counter for arbitrary keys, backed by Redis
-
poller
File I/O events library for Rust
-
settimeout
Creates a std::future::Future implementation to be ready at some point
-
tokio-task-manager
Allow an async Tokio application to gracefully shutdown, waiting for all tasks to finish
-
set_timeout
A crate which allows efficiently executing futures after some delay has passed
-
actm
Tiny async actors framework for rust
-
noosphere-fs
A high-level, FS-like view over Noosphere content
-
safina-threadpool
Safe thread pool
-
epoxy_frp
The Reactive Glue for Frontend Applications
-
streamson-futures
A library which integrates streamson with futures stream
-
spielrs_diff
It is a library which compare two direcories or two files asynchronously
-
rotor
The mio-based framework for doing I/O in simple and composable way
-
zephyrus-macros
Procedural macros used by Zephyrus
-
monoio-rustls
Asynchronous TLS streams wrapper for Monoio based on Rustls
-
adventure
Helps your great adventure for the various type of requests
-
task-executor
A task executor
-
tls-async
TLS support for AsyncRead/AsyncWrite using native-tls
-
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. -
lamellar-impl
Lamellar is an asynchronous tasking runtime for HPC systems developed in RUST
-
fut-compat
Offers compatibility between the tokio and async_std runtimes
-
noosphere-storage
Pluggable backing storage for the Rust Noosphere implementation
-
rants
An async NATS client library
-
eventually-postgres
Event Store implementation using PostgreSQL for the Eventually crate
-
bb8-bolt
A bolt-client adaptor for the bb8 connection pool
-
gain-lep
Support for exposing Gain APIs via Lep
-
actix-lua
A safe scripting environment for actix with the Lua Programming Language
-
futures-sink
The asynchronous
Sinktrait for the futures-rs library -
async-xml-derive
Derive macros for async-xml
-
tokio-reactor-trait
reactor-trait implementation for tokio
-
futures-x-io-timeoutable
Timeout ext for futures io and tokio io
-
async-task
Task abstraction for building executors
-
pw-telegram-bot-fork
A library for creating Telegram bots
-
smol-timeout
A way to poll a future until it or a timer completes
-
pty-process
spawn commands attached to a pty
-
peace_data
Data model for the peace automation framework
-
pinky-swear
Futures and async/await-ready Promises
-
tokio-stream_wasi
Utilities to work with
Streamandtokio -
async-await
Just some macros to emulate the Async and Await :)
-
potential
Borrowing for futures - Potential enables interior mutation using mutex and asynchronous borrowing (leasing) through a oneshot channel
-
oasis-amqp
Asynchronous AMQP 1.0 protocol handling
-
akinator-py
Python bindings for akinator-rs
-
futures_ringbuf
Mock Type implementing AsyncRead/AsyncWrite for testing and examples
-
async-graphql-viz
async-graphql for viz
-
pinned
Synchronisation primitives for !Send tasks
-
actix_derive
Derive macros for
actixactors -
wasmflow-traits
Rust library encapsulating the message packets sent across Wasmflow components
-
async-component
Zero overhead reactive programming
-
librdkafka-sys
Native bindings to the librdkafka library
-
datacake-eventual-consistency
Eventually consistent state replication as a library (consensus, RPC and conflict resolution) for building your own eventually consistent databases
-
futures-cache
Futures-aware cache backed by sled
-
async-std-test
Alternate implementation of the #[async_std::test] macro
-
zonyitoo/coio
Coroutine scheduler with non-blocking I/O support
-
fibers_inotify
A futures friendly inotify wrapper for fibers crate
-
raftlog
An implementation of distributed replicated log based on the Raft algorithm
-
rtx
RTx is a zero-cost runtime-abstraction intended for use by Rust libraries to enable the Freedom of Choice between asynchronous runtimes
-
pin-utils
Utilities for pinning
-
actix-raft
An implementation of the Raft distributed consensus protocol using the Actix actor framework
-
requiem
Actor framework for Rust
-
bottle
Actor model framework for Rust
-
stream-future-impl
Implement an async iterator with return value
-
telegram-bot-fork-raw
Telegram Bot API types
-
kompact-actor-derive
A derive macro for Kompact Actors
-
prefect
An embeddable task queue based on SQLite (renamed to effectum)
-
actix-mqtt-client
A MQTT client based on the actix framework
-
nbchan
Highly optimized non-blocking communication channels
-
reusable-box-future
A reusable
Pin<Box<dyn Future<Output = T> + Send>> -
async-graphql-parser
GraphQL query parser for async-graphql
-
genawaiter-macro
Convenience macros for generators (genawaiter)
-
nsq-client
Rust client for the NSQ realtime message processing system
-
register-count
Counting
Registers created by aCounter -
await_macros
Macros that expand to
(expr).await -
lunatic-common-api
Common functionality for building lunatic host function APIs
-
async-backplane
Simple, Erlang-inspired reliability framework for Rust Futures
-
mlua_actor
Lua Actor for Rust(sync/async)
-
async-lease
Essentially a futures-oriented Arc<Mutex<Option<T>>>
-
xo-api-client
Unofficial crate for accessing Xen Orchestra through its API
-
awaitable-error
Awaitable type with input and output that can be stored in container
-
async-log
Async tracing capabilities for the log crate
-
throttled-reader
An io::Read proxy that limits calls to read()
-
actix-signal
Manage the lifecycle of an actix actor with its address
-
aspartam
Minimalistic actor framework based on tokio, inspired by actix
-
hypixel
Rust wrapper for the Hypixel public API
-
bililive
A simple stream-based bilibili live client library
-
koit
A simple, asynchronous, pure-Rust, structured, embedded database
-
failover
failover based on etcd
-
async_repeat
Retry futures mechanism
-
heim-memory
Cross-platform memory information
-
dialectic
Transport-polymorphic, asynchronous session types for Rust
-
handy_async
A handy library for describing asynchronous code declaratively
-
thread_timer
A simple, cancelable timer with no external dependencies
-
rusty-gql
Schema first GraphQL Library for Rust
-
async_main_macro
Runtime-agnostic async main proc macro
-
hypercore
Secure, distributed, append-only log
-
must_future
A wrapper future marked must_use - mainly to wrap BoxFutures
-
comet-eventbus
An implementation of strong-typed sync and asynchronous eventbus
-
stopper
an async stream and future stopper mechanism
-
projections
Macro-free pin projections because why not?
-
cooper
A simple, in-process, async Actor library for Rust
-
spaad
Zero boilerplate actor systems with xtra
-
backstage
A framework for building data-driven distributed systems
-
telegram-bot-async-raw
Telegram Bot API types
-
rt_map
Runtime managed mutable borrowing from a map
-
poem-dbsession
Session storage with database for Poem
-
futurify
Convert your sync functions into non-blocking thread futures
-
async-core
A standard for async runtimes
-
agner-sup
An actor toolkit inspired by Erlang/OTP (supervisors)
-
aector
Dynamic implementation of the actor model with a smart built-in testing framework
-
tact
Tiny Actors
-
beatsaver-rs
A Rust library for interacting with the beatsaver.com api
-
tor-events
A typed event broadcasting framework for Arti
-
futures-task
Tools for working with tasks
-
hitbox-actix
Asynchronous caching framework for Actix
-
generic-api-client
A client for HTTP/HTTPS/WebSocket APIs
-
tokio-nats
Async-await ready NATS library
-
async-timer-rs
**Hashed timer wheel** implementation compatible with asynchronous tasks, support async_std/tokio and other futures base framework
-
futures_cbor_codec
A codec for framing an AsyncRead/AsyncWrite with cbor for all types that are serializable with serde
-
django-query_derive
Macros for the django-query crate
-
selectme-macros
A fast and fair select! macro for asynchronous Rust
-
futures-zmq
Provides Futures abstractions for ZeroMQ on any futures executor
-
awaur
AWAUR: Asynchronous Web API Utilities for Rust
-
tower
Tower is a library of modular and reusable components for building robust clients and servers
-
joyent-tokio-zookeeper
Asynchronous client library for interacting with Apache ZooKeeper
-
vino-packet
Rust library encapsulating the message packets sent across Vino components
-
peace_item_spec_tar_x
Manages extracting a tar file for the peace framework
-
mioco
Scalable, asynchronous IO coroutine-based handling (aka MIO COroutines)
-
promising-future
Implementation of Promise/Future pairs
-
riker-cqrs
Provides Command Query Responsibility Separation for Riker applications
-
rseip-core
core module for rseip
-
heim-sensors
Cross-platform sensors information
-
tokio-zookeeper
Asynchronous client library for interacting with Apache ZooKeeper
-
futures-option
Extension traits for dealing with optional futures and streams
-
atomic-waker
A synchronization primitive for task wakeup
-
futures-stream-select-ext
futures::stream::select Ext
-
singleflight-async
Singleflight in async style
-
osu
Unofficial Rust wrapper for the osu! API
-
mio-pidfd
mio support for Linux's pidfd
-
safina
Safe async runtime
-
mio-misc
Miscellaneous components for use with Mio
-
tokio-task-queue
Execute futures from a stream of futures in order in a Tokio task
-
mobc-bolt
A bolt-client manager for the mobc connection pool
-
async-subscription-map
Async bookkeeping datastructure for state subscriptions
-
fibers_transport
Transport layer abstraction built on top of [
fibers] crate -
futuresdr-pmt
Polymorphic Types for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
shinemonitor
Rust library for the shinemonitor.com website
-
irc3
An IRC3 client and server toolchain
-
heph-rt
Heph-rt is a speciailised runtime for Heph's actor
-
rama
proxy framework using Tokio written purely in Rust
-
releez
An utility tool to run application release-checklist safely
-
rusty-gql-cli
A Command line tool for rusty-gql
-
koit-toml
A simple, asynchronous, pure-Rust, structured, embedded database
-
retry_fn
A simple retry function with versions for blocking or non-blocking, tokio or async-std
-
async_nursery
Primitive for structured concurrency
-
async_serde
Use Serde as a general-purpose data format API
-
agner-test-actor
An actor toolkit inspired by Erlang/OTP (test-actor)
-
async-graphql-value
GraphQL value for async-graphql
-
futures-x-io
Compatible with futures io and tokio io
-
ex-futures
An extension of
futures -
async-component-core
Zero overhead reactive programming
-
barrage
An async broadcast channel
-
stream-map-any
Allows merging async Streams of different output type
-
thespis_impl
Reference implementation for the thespis actor model
-
safina-net
Safe async network functions
-
tokio-macros
Tokio's proc macros
-
tower-buffer
Buffer requests before dispatching to a
Service -
futures-time
async time combinators
-
tokio-metrics
Runtime and task level metrics for Tokio applications
-
aredis
ARedis is a Redis client implemented in Rust
-
executor-trait
A collection of traits to define a common interface across executors
-
peace_item_spec_file_download
Manages downloading a file for the peace framework
-
duplexify
Combine a reader + writer into a duplex of Read + Write
-
background-jobs-server
Jobs processor server based on ZeroMQ
-
async-graphql-axum
async-graphql for axum
-
async-object-pool
A simple object pool implementation that uses asynchronous synchronization primitives only
-
async-thread
Futures version of std::thread
-
mio-uds
Unix domain socket bindings for mio
-
tower-timeout
Apply a timeout to requests, ensuring completion within a fixed time duration
-
hyper_lua_actor
Binding of lua_actor & hyper
-
heim-cpu
Cross-platform CPU information
-
delay
A collection of trait and classes to make your thread wait (and timeout)
-
noosphere-collections
Collection data types that are needed by an efficient implementation of Noosphere's IPLD data structures
-
futures-core
The core traits and types in for the
futureslibrary -
lunatic-stdout-capture
Helper library for holding stdout streams of lunatic processes
-
tokio-buf
Asynchronous stream of byte buffers
-
memstore
An in-memory implementation of the
async-raft::RaftStoragetrait -
rsteam
rsteam is a easy to use async wrapper for the steam web api
-
coerce-rt
Async actor runtime
-
gw2rs
A Rust library for the Guild Wars 2 API
-
async-weighted-semaphore
An async weighted semaphore
-
b2_backblaze
this is a basic async library to upload small files to backblaze b2 service
-
peace_item_spec_sh_cmd
Manages running a shell command for the peace framework
-
deadpool-runtime
Dead simple async pool utitities for sync managers
-
tokio-compat-02
Tokio 0.2 compat utilities
-
rseip-cip
common industry protocol for rseip
-
futures-to-stream
Turn heterogeneous Futures of same associated Output type to a stream
-
futuredsp
A signal processing library for SDR and real-time DSP
-
futures-async-stream
Async stream for Rust and the futures crate