-
futures
streams featuring zero allocations, composability, and iterator-like interfaces
-
async-stream
Asynchronous streams using async & await notation
-
futures-util
Common utilities and extension traits for the futures-rs library
-
ws_stream_wasm
A convenience library for using websockets in WASM
-
futures-concurrency
Structured concurrency operations for async Rust
-
yamux
Multiplexer over reliable, ordered connections
-
quiche
🥧 Savoury implementation of the QUIC transport protocol and HTTP/3
-
async-h1
Asynchronous HTTP 1.1 parser
-
minidump
A parser for the minidump format
-
tokio-stream
work with
Streamandtokio -
ws_stream_tungstenite
Provide AsyncRead/AsyncWrite over Tungstenite WebSockets
-
io-extras
File/socket handle/descriptor utilities
-
hypercore
Secure, distributed, append-only log
-
reqwest-eventsource
Helper to build an Eventsource using reqwest
-
futures-async-stream
Async stream for Rust and the futures crate
-
sval
Streaming, structured value serialization
-
iggy
persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second
-
supports-unicode
Detects whether a terminal supports unicode
-
pdf-writer
A step-by-step PDF writer
-
futures-buffered
future concurrency primitives with emphasis on performance and low memory usage
-
fluvio
The official Fluvio driver for Rust
-
aws-sdk-ivs
AWS SDK for Amazon Interactive Video Service
-
stream-download
streaming content to a local file-backed cache
-
axum-streams
HTTP body streaming support for Axum: json/csv/protobuf/arrow/txt
-
scanner-rust
text scanners which can parse primitive types and strings using UTF-8 or ASCII
-
wasm-streams
Bridging between web streams and Rust streams using WebAssembly
-
lzma-sys
Raw bindings to liblzma which contains an implementation of LZMA and xz stream encoding/decoding. High level Rust bindings are available in the
xz2crate -
supports-hyperlinks
Detects whether a terminal supports rendering hyperlinks
-
eventsource-stream
A basic building block for building an Eventsource from a Stream of bytes
-
pharos
Observer pattern which generates a futures 0.3 stream of events
-
twitch-hls-client
Minimal CLI client for watching/recording Twitch streams
-
cros-codecs
Hardware-accelerated codecs for Linux
-
sea-streamer
🌊 The stream processing toolkit for Rust
-
async-fn-stream
Lightweight implementation of
async-streamwithout macros -
gst-plugin-ndi
GStreamer NewTek NDI Plugin
-
libp2p-mplex
Mplex multiplexing protocol for libp2p
-
aws-sdk-dynamodbstreams
AWS SDK for Amazon DynamoDB Streams
-
async-walkdir
Asynchronous directory traversal for Rust
-
udp-stream
UdpSocket same as TcpStream
-
reqwest-websocket
WebSocket connections with reqwest
-
aws-sdk-chimesdkmediapipelines
AWS SDK for Amazon Chime SDK Media Pipelines
-
reqwest-streams
HTTP body streaming support for reqwest: JSON/CSV/Protobuf and others
-
creek
Realtime-safe disk streaming to/from audio files
-
interruptible
Stops a future producer or stream from producing values when interrupted
-
uwheel
Embeddable Aggregate Management System for Streams and Queries
-
rabbitmq-stream-client
client for RabbitMQ Stream
-
callysto
Stream processing framework
-
mpart-async
Asynchronous (Futures-Base) Multipart Requests for Rust
-
cjseq
Create/process/modify CityJSONSeq
-
gix-archive
archive generation from of a worktree stream
-
base64-stream
To encode/decode large data with the standard Base64 encoding
-
stream_throttle
Stream combinator, to limit the rate at which items are produced
-
debounced
building delayed
Futures and debouncedStreams that wait a given duration before yielding the most recent item -
iroh-quinn-proto
State machine for the QUIC transport protocol
-
channels
Bidirectional channel-like communication over generic Read/Write streams
-
elgato-streamdeck
HidApi driver for Elgato Stream Decks
-
gst-plugin-togglerecord
GStreamer Toggle Record Plugin
-
ufotofu
Abstractions for lazily consuming and producing sequences
-
basic-text
Basic Text strings and I/O streams
-
mp4parse
Parser for ISO base media file format (mp4)
-
s3m
CLI for streams of data in S3 buckets
-
sgxs
working with the SGX stream format
-
ofilter
fast thread-safe Bloom filter
-
stream-vbyte
Compress and decompress numbers efficiently in the Stream VByte encoding
-
asciinema
Terminal session recorder
-
scoped-stream-sink
Easy way to make streams and sinks
-
jppe
byte stream structured serialization and deserialization library
-
seekable-stream-cipher
Seekable stream cipher and encryption/decryption
-
srt-tokio
SRT implementation in Rust
-
snocat
Streaming Network Overlay Connection Arbitration Tunnel
-
rustyo
radio that uses mpv to play radio streams from publically available internet radiostations
-
lending-stream
A lending version of Stream
-
mapped_futures
A collection of futures based on FuturesUnordered that supports insertion, removal and mutation of futures by key
-
indicator
Abstractions for stream aggregation, we call them
Indicators -
futures-macro
The futures-rs procedural macro implementations
-
encoding_rs_io
Streaming transcoding for encoding_rs
-
collate
Traits and a data structure to support collation and bisection
-
layered-io
I/O traits extending Read and Write
-
selium
An extremely developer friendly, composable messaging platform with zero build time configuration
-
bzip2-sys
Bindings to libbzip2 for bzip2 compression and decompression exposed as Reader/Writer streams
-
pipebuf
Efficient byte-stream pipe buffer
-
picomux
A protocol to multiplex multiple AsyncRead/Write streams over a single one, inspired by smux and http2
-
trivet
Parser Library
-
drop-stream
A stream that wraps another stream with a closure that is called once it is dropped
-
wasm-ws
A convenience library for using websockets in WASM
-
lightws
Lightweight websocket implement for stream transmission
-
streamtools
Additional stream combinators
-
ordered-stream
Streams that are ordered relative to external events
-
tiktoklive
library. Use it to receive live stream events such as comments and gifts in realtime from TikTok LIVE No credentials are required.
-
misanthropic
An async, ergonomic, client for Anthropic's Messages API
-
bevy_streamdeck
Elgato Stream Deck plugin for Bevy
-
fun_run
The fun way to run your Rust Comand
-
asynk-strim
Lightweight stream generator library
-
splaycast
Stream-specific broadcast channel
-
tbon
TinyChain Binary Object Notation is a compact and versatile stream-friendly binary serialization format
-
flood-rs
Bit and octet streams
-
redsumer
Lightweight implementation of Redis Streams for Rust
-
futures_ringbuf
Mock Type implementing AsyncRead/AsyncWrite for testing and examples
-
changes-stream2
couchdb follower
-
fluvio-smartmodule
Used by Fluvio SmartModule
-
dynwave
Dynamic audio player based on fixed samples stream
-
ipstack
Asynchronous lightweight userspace implementation of TCP/IP stack for Tun device
-
destream
async stream (de)serialization
-
sval_dynamic
Object-safe versions of sval::Stream and sval::Value
-
data-stream
serialization library based on streams
-
async-shared-timeout
Async timeout that can be reset and shared
-
destream_json
decoding & encoding a JSON stream
-
binary-util
A panic-free binary utility crate to read/write binary streams over the wire
-
same-content
Determine whether data from different sources are the same
-
rw-stream-sink
Adaptator between Stream/Sink and AsyncRead/AsyncWrite
-
rs-tool
A command-line tool to perform reservoir sampling on a file or a stream
-
music-player-playback
The playback logic for music player
-
mozilla/neqo-http3
Neqo, an implementation of QUIC written in Rust
-
stream-tungstenite
A streaming implementation of the Tungstenite WebSocket protocol
-
telemetry-server
receiver of telemetry over HTTP POST/WS to sqlite3, Postgres, DuckDB or JSON files
-
libp2p-stream
Generic stream protocols for libp2p
-
mostlybot
twitch bot that I use for my stream on twitch
-
future-queue
Adapters to manage a queue of futures, where each future can have a different weight
-
utf8-io
Traits and types for UTF-8 I/O
-
spring-stream
rust microservice framework
-
icy-metadata
parsing Icecast metadata
-
tokio-dl-stream-to-disk
A micro-library for downloading from a URL and streaming it directly to the disk
-
ruchei
working with many streams
-
rust-box
odd set of tools for Rust programming
-
fire-stream
A more or less simple communication protocol library
-
jw_client
API wrapper for the JW Player media management API. List or stream library into native Rust structs and download renditions.
-
selium-log
open-source implementation of a log-based message queue
-
stdecor
Run a command with a decorated stdout/stderr
-
zzz
Fast progress bar with sane defaults
-
iof
Read from and write data to console or file in simple formats
-
tokio-io-rewind
rewind tokio::io::AsyncRead and tokio::io::AsyncWrite streams
-
aurora-streams
managing publish-subscribe channels using Tokio message passing channels
-
llm_stream
A very simple Rust library to simplify streaming api interaction with LLMs, free from complex async operations and redundant dependencies
-
oval
A stream abstraction designed for use with nom, winnow, etc
-
yosemite
Asynchronous SAMv3 library
-
sval_nested
A recursive variant of sval
-
sea-streamer-socket
🌊 SeaStreamer backend-agnostic Socket API
-
futures-ticker
An asynchronous recurring time event
-
omniqueue
An abstraction layer over various queue backends
-
snapup
Abstractions for handling snapshots with streams of subsequent updates
-
ts-analyzer
analyzing packets in MPEG/Transport Stream files
-
fe2o3-amqp-ws
WebSocket binding stream for AMQP1.0
-
serser
serialization crate
-
sea-streamer-file
🌊 SeaStreamer File Backend
-
av-bitstream
bit writer/reader
-
le-stream
De-/serialize objects from/to little endian byte streams
-
rtmp
rtmp library
-
tasmota-mqtt-client
interacting with tasmota devices over MQTT
-
bgp-rs
parsing Border Gateway Protocol (BGP) formatted streams
-
twitchalerts
when it detect that a streamer is live which trigger the event handler, more features to be added
-
rocket-multipart
multipart/mixedResponder implementation -
sea-streamer-stdio
🌊 SeaStreamer Standard I/O Backend
-
futures-stream-ext
Asynchronous stream extensions for the futures(-core) crate
-
sea-streamer-redis
🌊 SeaStreamer Redis Backend
-
nature
development support platform, it separates data definition from code, so it decouple the data from business system
-
swimos_multi_reader
SwimOS Stream Aggregator
-
fermentation
The good kind of decay; forward decay
-
blockwise_reader
Reading the first bytes and pre-parsing of large files or streams
-
stream-wave-parser
The
stream-wave-parseris a crate that treats a stream from WAVE file -
h3i
Low-level HTTP/3 debugging and testing
-
futures-http
http frameworks base on futures stream
-
reydenx
Reyden-X API. Reyden-X is an automated service for promoting live broadcasts on external sites with integrated system of viewers and views management.
-
futures-finally
that executes a future after the completion of a future or stream regardless of the value or outcome
-
stream_assert
Macros to simplify testing of
Streambased APIs -
respite
An async reader for RESP streams
-
gomander-engiffen
Encodes GIF images from sequences of images. Includes an installable command line bin as well as the library. Forked from https://github.com/TooManyBees/engiffen
-
rlink
High performance Stream Processing Framework
-
rust-tls-duplex-stream
Full Duplex stream Wrapper around rust-tls
-
simple-stream
Building blocks for streaming chunks of data over io::Read and io::Write impls
-
rabbitmq-stream-protocol
AMQP 1.0 message codec
-
uwheel-stats
profiling utility for uwheel
-
fluvio-smartengine
The official Fluvio SmartEngine
-
selium-server
The server-side binary for Selium, an extremely developer friendly, composable messaging platform with zero build time configuration
-
kalosm-streams
A set of streams for pretrained models in Kalosm
-
nimble-protocol-header
Nimble Protocol Header
-
stream-reconnect
Stream-wrapping traits/structs that automatically recover from potential disconnections/interruptions
-
pollable-map
Utilites for storing futures and streams in as a pollable map
-
squinn-proto
State machine for the QUIC transport protocol
-
stdin-to-cloudwatch
Send logs from stdin to AWS CloudWatch Logs
-
buffer-unordered-weighted
Stream::buffer_unordered where each future can have a different weight
-
stream-extractor
The TCP Stream Extractor is a small utility that can read in a PCAP file, search through it for TCP streams, and write out each stream to a separate new PCAP file
-
stream-rate-limiter
A rate limiter for Tokio streams
-
essential-node
State derivation and validation for Essential protocol
-
tokio-tls-upgrade
Upgrade a TCP stream to a TLS stream using certificates and keys in PEM format
-
libre-url2audio-lib
simple-to-use lib for playing audio streams
-
tokio-socketcan
Asynchronous Linux SocketCAN sockets with tokio
-
async-utf8-decoder
Convert AsyncRead to incremental UTF8 string stream
-
sea-streamer-kafka
🌊 SeaStreamer Kafka / Redpanda Backend
-
streamline
Reversible futures::Stream-based state machines
-
skrillax-stream
Combines skrillax-network crates to work nicely on top of a tokio tcp stream
-
tokio-stream_wasi
work with
Streamandtokio -
sea-streamer-types
🌊 SeaStreamer Traits & Types
-
unix_sock
unix control socket abstraction
-
async-h1b
hitdns fork of Asynchronous HTTP 1.1 parser
-
moosicbox_stream_utils
MoosicBox stream utils package
-
tokio-process-stream
that wraps a tokio::process into a tokio::stream
-
cstream
libc::FILEstreams ‘c streams’ -
ianaio-timers
IanaIO crate for working with JavaScript timers
-
callbag
spec for reactive/iterable programming
-
creek-decode-symphonia
Audio file decoding for creek
-
comfy-print
Non-panicking versions of println! and friends. Async implementation.
-
merkle-tree-stream
A stream that generates a merkle tree based on the incoming data
-
async-time-mock-async-std
Mockable time for use in async runtimes (async-std compatibility)
-
futuristic
Extensions to the futures crate
-
preflate-rs
Rust port of Preflate compression library
-
peekread
Allows peeking ahead in Read streams
-
time-key-stream-set
A time-keyed stream set
-
futures-io-preview
The
AsyncReadandAsyncWritetraits for the futures-rs library -
cj_ascii
working with ASCII strings in Rust
-
rabbitmq_http_client
RabbitMQ HTTP API client
-
wasmrs
Base host and client implementations of the wasmRS RSocket protocol
-
yaml-split
iterator over individual YAML documents in a YAML file or stream
-
scan2
Some helpers to get the next items from an underlying stream
-
plumbing
An async abstraction to pipeline requests through a channel
-
comfy-print-sync
Non-panicking versions of println! and friends. Sync implementation.
-
dlwp
The DLWP library
-
linurgy
Manipulate the output of multiple newlines. Replace/Insert/Append newlines with text. Input and output from stdio/files/buffers
-
task-stream
a global task executor, run in
no_std -
roux-stream
A streaming API for the roux Reddit client
-
lafere
A more or less simple communication protocol library
-
jaesve
A CLI utility for stream converting JSON objects to a series of CSV values
-
crab-dlna
A minimal UPnP/DLNA media streamer
-
vlsm-tree
Versioned Log Stream Merkle Tree
-
fopencookie
interface between std::io and libc::FILE
-
menemen
A streaming http request library
-
frappe
Functional Reactive Programming library for Rust
-
tokio-par-stream
parallel streams powered by tokio
-
progress-streams
Progress callbacks for types which implement Read/Write
-
humphrey_ws
WebSocket support for the Humphrey web server
-
async-rx
functions for async reactive programming
-
subunit-rust
A subunit v2 protocol implementation in Rust
-
stream_limiter
Synchronously speed-limiting streams based on token bucket algorithm
-
twitter-stream
listening on Twitter Streaming API
-
progress_string
Generate a progress bar string
-
kvarn-quinn
Temporary Kvarn fork: Versatile QUIC transport protocol implementation
-
watermill
Blazingly fast, generic, and serializable online statistics
-
juliet
A safe stream multiplexing protocol
-
fluvio_ws_stream_wasm
A convenience library for using websockets in WASM
-
cudarse-npp
High-level bindings to the CUDA NPP libraries
-
chic
Pretty parser error reporting
-
byte_stream_splitter
Splitting a stream of bytes by separator sequence
-
egzreader
Read gzip/non-gzip stream easily
-
wasmrs-rx
Base host and client implementations of the wasmRS RSocket protocol
-
log-writer
write a stream to disk while adhering usage limits
-
kconfig-parser
Kconfig parser for the Kconfig file format from the Linux Kernel for the Cargo Kconfig crate
-
rand_krull
Krull64/65 random number generators
-
json-walker
JSON stream parser and deserializer. In this package you decide what part of json must be parsed
Try searching with DuckDuckGo.