-
tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
actix
Actor framework for Rust
-
async-io
Async I/O and timers
-
async-std
Async version of the Rust standard library
-
async-task
Task abstraction for building executors
-
rdkafka
Rust wrapper for librdkafka
-
async-channel
Async multi-producer multi-consumer channel
-
tokio-stream
Utilities to work with
Streamandtokio -
tokio-rustls
Asynchronous TLS/SSL streams for Tokio using Rustls
-
async-graphql
A GraphQL server library implemented in Rust
-
mobc
A generic connection pool with async/await support
-
smol
A small and fast async runtime
-
nb
Minimal non-blocking I/O layer
-
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
-
bb8
Full-featured async (tokio-based) connection pool (like r2d2)
-
futures
An implementation of futures and streams featuring zero allocations, composability, and iterator-like interfaces
-
tower-lsp
Language Server Protocol implementation based on Tower
-
multer
An async parser for
multipart/form-datacontent-type in Rust -
actix_derive
Derive macros for
actixactors -
rio
GPL-3.0 nice bindings for io_uring. MIT/Apache-2.0 license is available for spacejam’s github sponsors.
-
async-attributes
Experimental language-level polyfills for Async Rust
-
ghost_actor
GhostActor makes it simple, ergonomic, and idiomatic to implement async / concurrent code using an Actor model
-
heim
Cross-platform framework for system information
-
pharos
Observer pattern which generates a futures 0.3 stream of events
-
dataloader
Rust implementation of Facebook’s DataLoader using async-await
-
miow
A zero overhead I/O library for Windows, focusing on IOCP and Async I/O abstractions
-
minus
An asynchronous paging library for Rust
-
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 -
tower
Tower is a library of modular and reusable components for building robust clients and servers
-
tmq
ZeroMQ bindings for Tokio
-
fred
A Redis client for Rust built on Futures and Tokio
-
xtra
A tiny actor framework
-
async-oneshot
A fast, small, full-featured, async-aware oneshot channel
-
redis-async
An asynchronous futures based Redis client for Rust using Tokio
-
async-executor
Async executor
-
riker
Easily build fast, highly concurrent and resilient applications. An Actor Framework for Rust.
-
celery
Rust implementation of Celery
-
futures-executor
Executors for asynchronous tasks based on the futures-rs library
-
actix-broker
Message broker for the Actix actor framework
-
deadpool-lapin
Dead simple async pool for lapin
-
async-graphql-warp
async-graphql for warp
-
twilight-standby
Utility to filter wait for filtered incoming events for the Twilight ecosystem
-
streamunordered
An efficient async stream multiplexer
-
event-listener
Notify async tasks or threads
-
rxrust
A Rust implementation of Reactive Extensions
-
bus_queue
Lock-free Bounded non-Blocking Pub-Sub Queue
-
c-ares-resolver
An asynchronous DNS resolver, backed by c-ares
-
async_executors
Implements Spawn, SpawnLocal and SpawnHandle for commonly used executors
-
futures-signals
Zero cost FRP signals using the futures crate
-
capnp-futures
async serialization for Cap’n Proto messages
-
postage
An async channel library
-
tokio-util
Additional utilities for working with Tokio
-
background-jobs
Background Jobs implemented with actix and futures
-
csv-async
CSV parsing for async
-
h2
An HTTP/2.0 client and server
-
opencl3
A Rust implementation of the Khronos OpenCL 3.0 API and extensions
-
smol-potat
Proc macro for smol runtime
-
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)…
-
etcd-rs
etcd client for rust
-
asynchronous-codec
Utilities for encoding and decoding frames using
async/await -
mux-stream
Asynchronous hierarchical update dispatching for Rust
-
futures-retry
Retry your Futures and Streams!
-
unicycle
A scheduler for driving a large number of futures
-
mio-uds
Unix domain socket bindings for mio
-
pollster
A minimal async executor that lets you block on a future
-
async-socks5
An async/.await SOCKS5 implementation
-
keycloak
Keycloak Admin REST API
-
stream-cancel
A library for interrupting asynchronous streams
-
futures-locks
Futures-aware lock primitives
-
stakker
A lightweight low-level single-threaded actor runtime
-
linemux
A library providing asynchronous, multiplexed tailing for (namely log) files
-
genawaiter
Stackless generators on stable Rust
-
safina-timer
Safe async timers
-
mio-serial
A serial port implementation for mio
-
pinky-swear
Futures and async/await-ready Promises
-
ate
Distributed immutable data store with strong encryption and authentication
-
polling
Portable interface to epoll, kqueue, event ports, and wepoll
-
futures-micro
Zero dependency, no_std compatible async prelude
-
async-raft
An async implementation of the Raft distributed consensus protocol
-
nuclei
Proactive IO & runtime system
-
synchronized-writer
A tiny implement for synchronously writing data
-
actix-daemon-utils
Daemon Utilities by actix
-
eventsourcing
Event Sourcing for Rust
-
messagebus
MessageBus allows intercommunicate with messages between modules
-
rants
An async NATS client library
-
lamellar
Lamellar is an asynchronous tasking runtime for HPC systems developed in RUST
-
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
-
backstage
A framework for building data-driven distributed systems
-
tokio-pipe
Asynchronous pipe(2) library using 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.
-
dialectic-compiler
Session type macro compiler for the Dialectic crate
-
again
wasm-compatible retry util for std library futures
-
ksoft
KSoft.SI api wrapper written in pure Rust
-
syslog-rs
A native Rust implementation of the glibc/libc syslog
-
retainer
Minimal async cache in Rust with support for key expirations
-
dencode
Utilities for decoding and encoding frames from readers and writers
-
zeebe
A rust client for defining, orchestrating, and monitoring business processes across microservices using Zeebe
-
libzmq
A strict subset of ØMQ with a high level API
-
tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
teloxide-core
Core part of the
teloxidelibrary - telegram bot API client -
tiny-tokio-actor
A simple and tiny actor library on top of tokio
-
next-gen
Safe generators on stable Rust
-
persway
Sway IPC daemon
-
tbot
Make cool Telegram bots with Rust easily
-
kompact-component-derive
A derive macro for Kompact component definitions
-
async_logger
Asyncronous logger allows writing arbitrary slices to a memory buffer, which then processed by a writer in it’s own thread
-
miau
Async aware and extensible layered configuration system
-
fastcgi-client
Fastcgi client implemented for Rust
-
async-ssh2-lite
Asynchronous ssh2
-
rusty_tarantool
Tarantul async client based on tokio framework
-
yt-api
a work in progress library to interact asynchronously with the youtube api
-
kuska-handshake
Secure Scuttlebutt handshake + boxstream library
-
etcdv3client
a simple etcdv3 client
-
heim-cpu
Cross-platform CPU information
-
async-task-ffi
Task abstraction for building executors
-
elfo
Your next actor system
-
fluvio-future
I/O futures for Fluvio project
-
blocking
A thread pool for isolating blocking I/O in async programs
-
idcurl
Idiomatic synchronous http client based on curl
-
async-minecraft-ping
An async Rust client for the Minecraft ServerListPing protocol
-
agnostik-attributes
Executor agnostik attributes
-
rmp-futures
Async Rust MessagePack and MessagePack-RPC
-
stream_throttle
Provides a Stream combinator, to limit the rate at which items are produced
-
par-stream
Asynchronous parallel streams analogous to rayon
-
async-weighted-semaphore
An async weighted semaphore
-
mio-extras
Extra components for use with Mio
-
webhdfs
Hadoop WebHDFS client library
-
tokio-serde-cbor
Integration of serde_cbor into tokio-io, to allow sending CBOR encoded frames across network (and possibly through other transports)
-
async-change-tracker
reactive change notifications using futures
-
local-waker
A synchronization primitive for thread-local task wakeup
-
async-object-pool
A simple object pool implementation that uses asynchronous synchronization primitives only
-
medea-reactive
Reactive mutable data containers
-
pasts
Minimal and simpler alternative to the futures crate
-
futures-rustls
Asynchronous TLS/SSL streams for futures using Rustls
-
futures-delay-queue
Async delay queue backed by async-std and futures-timer
-
poolparty
Added functionality for the
futures::executor::ThreadPoolfutures executor -
cache_loader_async
A thread safe loading cache with async loader functions based on tokio
-
ert
A combinator to control future execution order
-
dbus-async-derive
Handler trait derive macro for dbus-async
-
acteur
A safe actor-like framework that just works. Simple, robust, fast, documented.
-
paperplane
Async WebSocket library
-
pcap-async
Async/Stream Extensions for libpcap
-
eventador
lock-free pub/sub event-bus with sync and async APIs
-
glommio
A set of utilities to allow one to write thread per core applications
-
ws_stream_tungstenite
Provide AsyncRead/AsyncWrite over Tungstenite WebSockets
-
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
-
hbbft
The Honey Badger of Byzantine Fault Tolerant Consensus Protocols
-
blocking-permit
Permits and a thread pool for blocking operations
-
mio-misc
Miscellaneous components for use with Mio
-
futures-timer
Timeouts for futures
-
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) -
spekt
std::future::Future and Result-based testing trait for managing the lifecycle of stateful, asynchronous tests
-
async-ctrlc
Async wrapper of
ctrlc -
async_msp_cli
Async msp cli for iNav and BetaFlight
-
heph
Heph is an actor framework based on asynchronous functions
-
rustun
A library for implementing STUN server and client asynchronously
-
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. -
agnostik
Executor Agnostic Runtime that can run your futures with your favourite Executor
-
background-jobs-core
Core types for implementing an asynchronous jobs processor
-
lifeline
Lifeline is a dependency injection library for asynchronous message-based applications
-
packet-ipc
Share packets between services using servo ipc
-
cl3
A Rust implementation of the Khronos OpenCL 3.0 API and extensions
-
futures-x-io-timeoutable
Timeout ext for futures io and tokio io
-
protobuf_codec
Encoders and decoders for Protocol Buffers based on bytecodec crate
-
side-futures
Send future for execution on the runtime that may be in a different thread
-
async-graphql-parser
GraphQL query parser for async-graphql
-
async-native-tls
Native TLS using futures
-
aiven_rs
This is a rust sdk to interact with aiven-cloud apis
-
iou
io_uring bindings
-
stakker_mio
Mio I/O polling integration for the Stakker crate
-
mpart-async
Asynchronous (Futures-Base) Multipart Requests for Rust
-
cooper
A simple, in-process, async Actor library for Rust
-
futures_codec
Utilities for encoding and decoding frames using
async/await -
actix-redis
Redis integration for Actix and session store for Actix Web
-
beatsaver-rs
A Rust library for interacting with the beatsaver.com api
-
thin_main_loop
Thin, cross-platform, main event loop. A building block for native GUI applications, among other use cases.
-
c_mcai_worker_sdk
AMQP Worker to listen and provide trait to process message
-
untokio
Automatically create tokio runtimes
-
tokio-nsq
A Rust NSQ client built on Tokio. Tokio NSQ aims to be a feature complete NSQ client implementation.
-
actors-rs
Easily build fast, highly concurrent and resilient applications. An Actor Framework for Rust.
-
fourche
A simple task queue named after a lion with forked tail (queue fourché), works with Redis
-
fluvio-async-tls
Asynchronous TLS/SSL streams using Rustls
-
sonor
a library for controlling sonos speakers
-
futures-core
The core traits and types in for the
futureslibrary -
futures-task
Tools for working with tasks
-
serial-io
A serial port implementation
-
scoped_spawn
Full structured concurrency for asynchronous programming
-
bb8-bolt
A bolt-client adaptor for the bb8 connection pool
-
paypal-rs
A library that wraps the paypal api asynchronously
-
ginepro
A client-side gRPC channel implementation for tonic
-
libaio-futures
Straightforward Linux AIO using Futures/async/await
-
tokio_schedule
This crate helps schedule tasks in tokio runtime
-
c-ares
A Rust wrapper for the c-ares library, for asynchronous DNS requests
-
gain-lep
Support for exposing Gain APIs via Lep
-
lsp-codec
Simple Tokio 0.1-based Codec implementation for Language Server Protocol
-
safina-executor
Safe async runtime
-
async-log
Async tracing capabilities for the log crate
-
lua_actor
Lua Actor for Rust(sync/async)
-
noob
A WIP futures-based Discord bot library
-
actori
Actor framework for Rust
-
async-codec
Utilities for creating async codecs
-
tokio-test
Testing utilities for Tokio- and futures-based code
-
libevent
Rust bindings to the libevent async I/O framework
-
want
Detect when another Future wants a result
-
async-psec
Asynchronous PSEC implementation
-
async-ffi
Make async Futures FFI compatible
-
actix-redis-jobs
Simple and reliable background processing for Rust using Actix and Redis
-
coerce
Async actor runtime and distributed systems framework
-
archlinux-repo
Arch Linux repositories parser
-
async-mq
Zero-cost async-await abstraction of lapin AMQP client crate
-
openai-api
OpenAI API library for rust
-
egs-api
Interface to the Epic Games API
-
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…
-
futures-rate
This library provides easy tools to help Rust applications guide critical resources or code paths from being overwhelmed
-
messagebird-async
Wrapper around the message bird SMS API
-
round-based
Driver for round-based protocols
-
async-stm32f1xx
Abstractions for asynchronous programming on the STM32F1xx family of microcontrollers
-
async-scoped
Spawn scoped (non ’static) asynchronous futures for async_std and tokio runtimes
-
tokio-retry
Extensible, asynchronous retry behaviours for futures/tokio
-
smol-timeout
A way to poll a future until it or a timer completes
-
garcon
A collection of trait and classes to make your thread or async function wait
-
streamson-futures
A library which integrates streamson with futures stream
-
promising-future
Implementation of Promise/Future pairs
-
simple_futures
Simple futures for use in async operations
-
waitgroup
Async waitgroup for a collection of task to finish
-
async-tun
Asynchronous allocation of TUN/TAP devices using async-std
-
craftio-rs
A crate to read & write packets defined in mcproto-rs to I/O sinks/sources
-
tokio-compat-02
Tokio 0.2 compat utilities
-
tokio-zmq
Provides Futures abstractions for ZeroMQ on the Tokio event-loop
-
async-tls
Asynchronous TLS/SSL streams using Rustls
-
dynamodb-mutex
Use Dymanodb mutex library
-
cb_fut
Call function that return value via callback without a callback
-
pantry
Temporary storage for reusing values that may decay
-
domain-resolv
An asynchronous DNS stub resolver
-
appliance
A lightweight framework to build async-friendly components with message-based intercommunications
-
async_io_stream
IntoAsyncRead on steriods
-
tokio-file-unix
Asynchronous support for epollable files via Tokio on Unix-like platforms
-
completion
Utilities for writing completion-based asynchronous code
-
mio-pidfd
mio support for Linux’s pidfd
-
tonari-actor
A minimalist actor framework aiming for high performance and simplicity
-
pwner
Pwner is a Process Owner crate that allows ergonomic access to child processes
-
taskwait
Runtime agnostic way to wait for a group of async tasks
-
tokio-serial
A serial port implementation for tokio
-
termion-input-tokio
An adapter that exposes termion’s input and key event iterators as asynchronous streams
-
nbchan
Highly optimized non-blocking communication channels
-
stream_router
A Future aware router to dynamically route between Streams and Sinks
-
vampirc-io
A library for asynchronous, non-blocking, UCI protocol–based communication between chess UIs and chess engines
-
rumpsteak
Session types for asynchronous communication between multiple parties
-
gidle_future
A future executor for the glib main loop idle time
-
blocker
Block rust futures to create a synchronous wrapper around an asynchronous api
-
async-priority-queue
An async-aware priority queue
-
implicit-await
Implicitly await calls returning Future impls
-
one-of-futures
Future-aware Either-like type with multiple variants
-
ntex-codec
Utilities for encoding and decoding frames
-
async-file-lock
Asynchronous file lock that can auto lock and auto seek
-
potential
Borrowing for futures - Potential enables interior mutation using mutex and asynchronous borrowing (leasing) through a oneshot channel
-
heim-memory
Cross-platform memory information
-
juggle
Async task switching for cooperative multitasking in single thread environments with no_std support
-
heph-inbox
Bounded capacity channel designed to be used as inbox for actors. Also supports one shot channels.
-
stund
An SSH tunnel maintenance daemon
-
triggered
Triggers for one time events between tasks and threads
-
double-checked-cell-async
A thread-safe lazily initialized cell using double-checked locking
-
async-fuse
Helpers for fusing asynchronous computations
-
async_cell
A Cell<Option> that you can await on
-
tracing-actix
Allow tracing actor futures in actix
-
tokio-file
Asynchronous file I/O for Tokio
-
tokio-lxi
LXI protocol abstractions for Tokio
-
awaitgroup
Wait for a collection of async tasks to finish
-
yaaf
Yet Another Actor Framework
-
futures_cbor_codec
A codec for framing an AsyncRead/AsyncWrite with cbor for all types that are serializable with serde
-
web3-async-native-tls
Temporary package released to crates.io. Fork of async-native-tls. Please don’t use.
-
nbd-async
Block device drivers in userspace
-
fibers
A Rust library to execute a number of lightweight asynchronous tasks (a.k.a, fibers) based on futures and mio
-
epoxy_frp
The Reactive Glue for Frontend Applications
-
signald-rust
A library to interface with Signald
-
async-stream-tls-upgrader
Asynchronous stream tls upgrader
-
async-trait-ext
a procedural macro for async traits
-
eventually-postgres
Event Store implementation using PostgreSQL for the Eventually crate
-
mio
Lightweight non-blocking IO
-
lib3h_zombie_actor
lib3h actor request tracking module
-
extreme
Extremely boring async function runner. MIT/Apache-2.0 license is available for spacejam’s github sponsors.
-
git-event
Customizable event handler for updates in remote git repositories
-
tokio-rayon
Mix async code with CPU-heavy thread pools using Tokio + Rayon
-
async_zmq
Async version for ZeroMQ bindings
-
aiur
Async executor with structured concurrency
-
reusable-box-future
A reusable
Pin<Box<dyn Future<Output = T> + Send>> -
quicksink
Create a Sink from some value and a closure returning a Future
-
lazy_async_pool
An asyncronous object pool that generates objects on the fly
-
d3-core
A framework for server development – the core layer
-
agreed-memstore
An in-memory implementation of the
agreed::RaftStoragetrait. Fork of async-raft’s memstore crate. -
circulate
Lightweight async PubSub framework
-
spin_on
A simple, inefficient Future executor
-
thread_timer
A simple, cancelable timer with no external dependencies
-
async-copy-progress
Asynchronous copying with progress callbacks
-
ardop_interface
Interface to the Amateur Radio Digital Open Protocol (ARDOP)
-
luis_sys
FFI bindings for Microsoft LUIS API
-
actix-elastic
elasticsearch 7.x actix actor
-
kompact-actor-derive
A derive macro for Kompact Actors
-
icanhazdadjoke-sdk
An SDK to interact with the icanhazdadjoke Dad Jokes API
-
intervalier
Interval events with handling notifications
-
gabelung
Branch an asynchronous stream of cloneable items into two
-
async-global-executor
A global executor built on top of async-executor and async-io
-
signals
A functional-reactive-like library for Rust that allows asynchronous chaining
-
actor-es
An event sourcing + CQRS abstraction on top of Riker
-
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.
-
shared_stream
A crate for easily cloneable streams
-
tokio-switching-sleep
A tokio Sleep with a switchable state
-
dbus-async
Asynchronous DBus library
-
st7735-async-low
Low-level async library for 4-wire serial ST7735
-
suspend
A common mechanism for suspending a thread or a Future until notified
-
hreq-h2
An HTTP/2.0 client and server
-
rustracts
Rust crate for cancellable time based contracts in async/await
-
tractor
Actor system modelled after Pony’s actors
-
smelling_salts
Start a thread to wake an async executor when the OS’s I/O event notifier discovers that the hardware is ready
-
lelet
golang like task executor
-
dstream
DelayedStream - delays items and drops same items coming within given interval
-
tokio-diesel
Integrate Diesel into Tokio cleanly and efficiently
-
fb-api
Facebook Api abstraction for async rust
-
syncthing
A Rust library for controlling syncthing file synchronization through its REST interface
-
dyn-future
Convenient and fast dynamic Futures for Rust
-
stakker_log
Logging support for Stakker
-
tari_pubsub
Single publisher with multiple subscribers to topic messages
-
must_future
A wrapper future marked must_use - mainly to wrap BoxFutures
-
simple-async-local-executor
A single-threaded polling-based executor suitable for use in games, embedded systems or WASM
-
real-async-trait
A proc macro that uses experimental features to work around type erasure for async traits
-
futures-async-combinators
toy futures combinators
-
stateful_async_worker
Asynchronous stateful worker threads utilizable as futures
-
dapr-derive
Dapr SDK for Rust
-
sidekiq-rs
Sidekiq compatible server in Rust
-
poller
File I/O events library for Rust
-
lease
Object pool that leases values and automatically returns them with async support
-
strawpoll
A wrapper to avoid spurious polling
-
tourniquet
Async native round-robin manager for remote services
-
async-utf8-decoder
Convert AsyncRead to incremental UTF8 string stream
-
async-graphql-relay
Relay support for async-graphql
-
mio-timerfd
mio support for linux’s timerfd
-
tokio-dns-unofficial
Unofficial extension to tokio to provide asynchronous DNS resolution
-
futures-async-runtime-preview
Runtime for the async/await macros in the
futurescrate -
futuristic
Extensions to the futures crate
-
cqrs-core
Core types and traits for cqrs
-
lamellar-prof
Lamellar is an asynchronous tasking runtime for HPC systems developed in RUST
-
webex
Interface to Webex Teams REST and WebSocket APIs
-
dropbear
Awaitable drop container based on Tokio oneshots
-
core-futures-tls
A libcore wrapper allowing async/await to be used from no_std crates
-
deferred
Rust crate to help perform deferred execution of code logic
-
bandar-log
async logular storage
-
async-walkdir
Asynchronous directory traversal for Rust
-
extern_executor
Async executor which delegates futures polling to external event-loop
-
stream_multiplexer
Combines many streams into a few
-
async_smux
Asynchronous smux multiplexing library
-
maybe-async
A procedure macro to unify SYNC and ASYNC implementation
-
tower-pipeline
A Tower Service combinator that “pipelines” two services
-
funfsm
An FSM library where the states are functions
-
visiting_ref
Container types that asynchronously return ownership of a value to another context upon exiting scope
-
tiny_future
This library provides spin-loop-free futures and a helper functions to run a job asynchronously
-
async-graphql-value
GraphQL value for async-graphql
-
textmode
terminal interaction library backed by a real terminal parser
-
actix-raft
An implementation of the Raft distributed consensus protocol using the Actix actor framework
-
heim-disk
Cross-platform disk information
-
iterstream
Converts Iterator into real asynchronous Stream
-
fastsink
Create a Sink from some value and a closure returning a Future
-
async-lease
Essentially a futures-oriented Arc<Mutex<Option>>
-
requiem
Actor framework for Rust
-
deepwell
Database management and migrations service
-
local-pool-with-id
A minor variation on a LocalPool executor which exposes unique IDs for tracking future completion
-
scipio
A set of utilities to allow one to write thread per core applications
-
zeebest
An unofficial zeebe client for the future!
-
website_crawler
crawl all urls on a website async & sync
-
async-await
Just some macros to emulate the Async and Await :)
-
killswitch
Broadcast a task termination request
-
safina-sync
Safe structs for sharing or sending data between async tasks
-
async-watch
Async watch channel
-
tokio-lk
Futures-aware lock-by-id primitives
-
transform-stream
Lightweight async stream wrapper
-
tokio_safe_for_aingle
execute async code from a sync context, without blocking a tokio core thread or busy looping the cpu
-
futures-async-stream-macro
Implementation detail of the
futures-async-streamcrate -
newsblur_api
rust implementation of the NewsBlur-API
-
async-select-all
A futures library adapter for selecting over a list of futures
-
manual_future
A future that must be manually completed, similar to Java’s CompletableFuture
-
duplexify
Combine a reader + writer into a duplex of Read + Write
-
wait-for-me
Async CountDownLatch
-
async-pipe
Creates an asynchronous piped reader and writer pair using tokio.rs
-
pty-process
spawn commands attached to a pty
-
async-backplane
Simple, Erlang-inspired reliability backplane for Rust Futures
-
nylon
An async/.await based job system where futures live in fibers that are run on core-pinned threads
-
tk-listen
A set of helper futures allowing to listen TCP (or unix) socket with resource limits and proper error handling
-
ipc-orchestrator
Orchestion of command line processes for local dev usage with IPC communication
-
futures-x-io
Compatible with futures io and tokio io
-
futures-jsonrpc
Futures implementation for JSON-RPC
-
rlua-async
Async support for rlua, via coroutines
-
tokio-beanstalkd
Asynchronous client library for interacting with Beanstalkd work queue
-
back-to-the-future
Conversions between std::future::Future and futures::Future
-
futures-cputask
Turn synchronous CPU-bound tasks into futures
-
linked-futures
Link futures into a block, which stops all of the included futures when any of the futures complete
-
spaad
Zero boilerplate actor systems with xtra
-
tokio-async-std
An async-std that can fit into tokio ecosystem straight ahead
-
wookie
A very small and fast executor for one Future on one thread. Lightweight enough to have many of them.
-
futures-await-await-macro
Definition of the
await!macro for thefutures-awaitcrate -
heim-runtime
Runtime shims for heim crate
-
tangle
Future implementation for Rust
-
futures-mockstream
Minimal mockstream which implements futures async traits
-
async-stream-http-tunnel-grader
Asynchronous stream http tunnel grader
-
bottle
Actor model framework for Rust
-
lol-async
async html-rewriter
-
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.
-
executor-trait
A collection of traits to define a common interface across executors
-
async-process
Async interface for working with processes
-
conch-runtime
A library for evaluating/executing programs written in the shell programming language
-
tower-ready-cache
Caches a set of services
-
async_msp_lib
Async msp library for iNav and BetaFlight
-
nsq-client
Rust client for the NSQ realtime message processing system
-
safina-async-test
Macro for running async tests
-
promises
Effective, simple, lightweight Javascript promises in Rust
-
ws-lite
Naive websocket server implemented using async / await
-
async-shell
Asynchronous process child wait
-
ex-futures
An extension of
futures -
librdkafka-sys
Native bindings to the librdkafka library
-
settimeout
Creates a std::future::Future implementation to be ready at some point
-
yaaf-macros
Procedural macros for using YAAF
-
eventsourcing-derive
Custom derive macros for Eventsourcing components
-
stream-map-any
Allows merging async Streams of different output type
-
gw2rs
A Rust library for the Guild Wars 2 API
-
opendht
A Rust API for OpenDHT
-
cntrlr
Simple, async embedded framework
-
futures-enum
#[derive(Future, Stream, Sink, AsyncRead, AsyncWrite, AsyncSeek, AsyncBufRead)] for enums
-
retry_fn
A simple retry function with versions for blocking or non-blocking, tokio or async-std
-
tokio-stdin-stdout
Thread- and future::sync::mpsc-based AsyncRead/AsyncWrite stdin/stdout with little buffering
-
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. -
rumpsteak-macros
Session types for asynchronous communication between multiple parties
-
blocking_pool
A thread pool for running synchronous I/O in asynchronous applications
-
await_macros
Macros that expand to
(expr).await -
thetvdb
TheTVDB API async client
-
fluvio-test-derive
Procedure macro to run async fn as test
-
completion-io
Core traits and types for asynchronous completion-based I/O
-
hitbox-redis
Hitbox redis backend actor
-
futures-lite
Futures, streams, and async I/O combinators
-
genawaiter-macro
Convenience macros for generators (genawaiter)
-
actori-testing
Actori testing utils
-
gen-z
Macro-free stream construction through asynchronous generators via an awaitable sender
-
mio-utun
Utun bindings for mio
-
jstream-ext
A crate which adds some extra extensions to futures Stream traits
-
eventually-redis
Event Store implementation using Redis, for Eventually crate
-
connman
A ConnMan library that abstracts the D-Bus layer
-
beeswax
An easy to use CRUD client for the Beeswax API
-
tokio-macros
Tokio’s proc macros
-
d3-components
A framework for server development – the component layer
-
riker-cqrs
Provides Command Query Responsibility Separation for Riker applications
-
tls-async
TLS support for AsyncRead/AsyncWrite using native-tls
-
tower-buffer
Buffer requests before dispatching to a
Service -
stream-body
An HttpBody implementation with efficient streaming support for the Rust HTTP library hyper
-
async-graphql-tide
async-graphql for tide
-
futurify
Convert your sync functions into non-blocking thread futures
-
wombo
Utilities for managing event loop threads
-
tokio_safe_block_on
Provides the ability to execute async code from a sync context, without blocking a tokio core thread or busy looping the cpu
-
heim-sensors
Cross-platform sensors information
-
memstore
An in-memory implementation of the
async-raft::RaftStoragetrait -
kompact
Kompact is a Rust implementation of the Kompics component model combined with the Actor model
-
dialectic
Transport-polymorphic, asynchronous session types for Rust
-
implicit-await-macro
#[implicit_await] procedural macro implementation
-
relay
A lightweight oneshot Future channel
-
mirai
A Futures layer over Mio
-
num_stream
Rust crate that provides a Stream that yields incrementing numbers at a specified interval
-
coerce-rt
Async actor runtime
-
tari_broadcast_channel
Bounded non-blocking single-producer-multi-consumer broadcast channel
-
futures-zmq
Provides Futures abstractions for ZeroMQ on any futures executor
-
v_rusty_tarantool
Tarantul async client based on tokio framework
-
futures-fs
A Futures implementation for File System operations
-
handy_async
A handy library for describing asynchronous code declaratively
-
async-dup
Duplicate an async I/O handle
-
ruyi
An event-driven framework for non-blocking, asynchronous I/O in Rust
-
erkpht-tower
Tower is a library of modular and reusable components for building robust clients and servers
-
lamellar-impl
Lamellar is an asynchronous tasking runtime for HPC systems developed in RUST
-
async-macros
Macros for async-std
-
async-sse
Async Server Sent Event parser and encoder
-
async-fs
Async filesystem primitives
-
thespis_impl
Reference implementation for the thespis actor model
-
yaar-reactor
Non-blocking IO abstractions for building executors
-
ws-gonzale
Naive websocket server implemented using async / await
-
mio-st
Single threaded, lightweight non-blocking IO
-
async-compat
Compatibility adapter between tokio and futures
-
futures-polling
An enum similar to Poll, but containing a future in its Pending variant
-
futures-macro-await-preview
Definition of the
await!macro for thefuturescrate -
async-graphql-actix-web
async-graphql for actix-web
-
uexec
Simple work-stealing global and local executor
-
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 -
safina-threadpool
Safe thread pool
-
async-stream-packed
Asynchronous stream packed
-
background-jobs-server
Jobs processor server based on ZeroMQ
-
tokio-compat
Compatibility between
tokio0.2 and legacy versions -
async-smtp-lite
Asynchronous smtp
-
d3
A framework for server development
-
scambio
Safe and efficient value exchanges between endpoint pairs
-
tower-retry
Retry failed requests
-
heim-derive
Derive macros for heim crates
-
xactor
Xactor is a rust actors framework based on async-std
-
catty
Send and await a value asynchronously
-
futures-async-stream
Async stream for Rust and the futures crate
-
safina
Safe async runtime
-
suspend-channel
Channel and stream implementations