-
actix-web
Actix Web is a powerful, pragmatic, and extremely fast web framework for Rust
-
tokio-stream
work with
Streamandtokio -
xz2
Rust bindings to liblzma providing Read/Write streams as well as low-level in-memory encoding/decoding
-
supports-color
Detects whether a terminal supports color, and gives details about that support
-
io-extras
File/socket handle/descriptor utilities
-
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-native-tls
TLS/SSL streams for Tokio using native-tls giving an implementation of TLS for nonblocking I/O streams
-
reqwest-eventsource
Helper to build an Eventsource using reqwest
-
gix-archive
archive generation from of a worktree stream
-
gix-worktree-stream
generate a byte-stream from a git-tree
-
stream-download
streaming content to a local cache
-
axum-streams
HTTP body streaming support for Axum: json/csv/protobuf/arrow/txt
-
fluvio
The official Fluvio driver for Rust
-
eventsource-stream
A basic building block for building an Eventsource from a Stream of bytes
-
pdbtool
reading Program Database (PDB) files and displaying information about them
-
async-walkdir
Asynchronous directory traversal for Rust
-
twitch-hls-client
Minimal CLI client for watching/recording Twitch streams
-
future-queue
Adapters to manage a queue of futures, where each future can have a different weight
-
aws-sdk-kinesisvideo
AWS SDK for Amazon Kinesis Video Streams
-
supports-hyperlinks
Detects whether a terminal supports rendering hyperlinks
-
gst-plugin-mp4
GStreamer Rust MP4 Plugin
-
rabbitmq-stream-client
client for RabbitMQ Stream
-
gst-plugin-fmp4
GStreamer Fragmented MP4 Plugin
-
wasm-streams
Bridging between web streams and Rust streams using WebAssembly
-
web-transport-quinn
WebTransport library for Quinn
-
supports-unicode
Detects whether a terminal supports unicode
-
streamstore-cli
CLI for S2
-
pharos
Observer pattern which generates a futures 0.3 stream of events
-
reqwest-streams
HTTP body streaming support for reqwest: JSON/CSV/Protobuf and others
-
async-speed-limit
Asynchronously speed-limiting multiple byte streams
-
marmite
easiest static site generator
-
aws-sdk-dynamodbstreams
AWS SDK for Amazon DynamoDB Streams
-
hannibal
A small actor library
-
stream_throttle
Stream combinator, to limit the rate at which items are produced
-
scanner-rust
text scanners which can parse primitive types and strings using UTF-8 or ASCII
-
v4l
Safe video4linux (v4l) bindings
-
libbz2-rs-sys
a drop-in compatible rust bzip2 implementation
-
quantiles
a collection of approximate quantile algorithms
-
interruptible
Stops a future producer or stream from producing values when interrupted
-
send_wrapper
implements a wrapper type called SendWrapper which allows you to move around non-Send types between threads, as long as you access the contained value only from within the original thread…
-
reqwest-websocket
WebSocket connections with reqwest
-
binary-stream
Binary stream reader and writer
-
sortuniq
Find or count unique values in an input stream
-
futures-async-stream
Async stream for Rust and the futures crate
-
hypercore
Secure, distributed, append-only log
-
streamstore
Rust SDK for S2
-
srt_whep
SRT to WHEP (WebRTC)
-
rabbitmq_http_client
RabbitMQ HTTP API client
-
chewdata
Extract Transform and Load data
-
async-fn-stream
Lightweight implementation of
async-streamwithout macros -
tinkoff-invest
tinkoff invest library
-
streamunordered
An efficient async stream multiplexer
-
jppe
byte stream structured serialization and deserialization library
-
futures-stream-ext
Asynchronous stream extensions for the futures(-core) crate
-
kalosm-streams
A set of streams for pretrained models in Kalosm
-
scoped-stream-sink
Easy way to make streams and sinks
-
creek
Realtime-safe disk streaming to/from audio files
-
io-streams
Unbuffered and unlocked I/O streams
-
fun_run
The fun way to run your Rust Comand
-
aead-gcm-stream
Pure Rust implementaion of AES GCM cipher for data streams
-
musicgpt
Generate music based on natural language prompts using LLMs running locally
-
gabriel2
Indeed, an actor library based on Tokio, written in Rust
-
wsrx
Controlled TCP-over-WebSocket forwarding tunnel
-
tokio-icmp-echo
Asynchronous ICMP pinging library
-
fasyslog
A fast syslog client written in Rust
-
http-cache-stream
A HTTP cache implementation for streaming bodies
-
http-test-server
Programatically create resources and pre-defined responses for tests
-
channels
Bidirectional channel-like communication over generic Read/Write streams
-
aws-sdk-gameliftstreams
AWS SDK for Amazon GameLift Streams
-
portaudio
bindings for Rust
-
waypoint
Farcaster synchronization tool built in Rust, optimized for memory efficiency
-
transform-stream
Lightweight async stream wrapper
-
aes-gcm-stream
AES GCM stream encrypt and decrypt library, supports AES128/192/256 bit keys
-
basic-text
Basic Text strings and I/O streams
-
mapped_futures
A collection of futures based on FuturesUnordered that supports insertion, removal and mutation of futures by key
-
futures_ringbuf
Mock Type implementing AsyncRead/AsyncWrite for testing and examples
-
destream_json
decoding & encoding a JSON stream
-
tokio-par-util
running computations in parallel on top of Tokio
-
emojfuscate
Tools for turning any data into emoji and back again
-
xz
Rust bindings to liblzma providing Read/Write streams as well as low-level in-memory encoding/decoding. Alias of
xz2crate -
videocall-cli
Effortlessly stream video from the CLI with our native client, designed for your desktop, robot, or Raspberry Pi
-
stop-token
Experimental cooperative cancellation for async Rust
-
tbon
TinyChain Binary Object Notation is a compact and versatile stream-friendly binary serialization format
-
base64-stream
To encode/decode large data with the standard Base64 encoding
-
rust-box
odd set of tools for Rust programming
-
scte35dump
Dump SCTE-35 data from a Transport Stream contained within a file or RTP network stream
-
ofilter
fast thread-safe Bloom filter
-
encoding_rs_io
Streaming transcoding for encoding_rs
-
ehttpd
A thread-based HTTP server library, which can be used to create custom HTTP server applications
-
oggmux
A remuxing kit for combined Ogg Vorbis streams
-
tiktoklive
library. Use it to receive live stream events such as comments and gifts in realtime from TikTok LIVE No credentials are required.
-
indicator
Abstractions for stream aggregation, we call them
Indicators -
rs_openai
The OpenAI Rust library provides convenient access to the OpenAI API from Rust applications
-
ausnd
Reader and writer for the AU audio format
-
aurora-streams
managing publish-subscribe channels using Tokio message passing channels
-
ordered-stream
Streams that are ordered relative to external events
-
icy-metadata
parsing Icecast metadata
-
drop-stream
A stream that wraps another stream with a closure that is called once it is dropped
-
s3m
CLI for streams of data in S3 buckets
-
mangling
generates safe, recognizable identifiers from byte streams
-
ctf-pwn
Pwn utilities for Rust
-
sse-stream
Convert a http body into sse stream
-
ruchei
working with many streams
-
flood-rs
Bit and octet streams
-
destream
async stream (de)serialization
-
libp2p-stream
Generic stream protocols for libp2p
-
data-stream
serialization library based on streams
-
async-hash
Traits and helper functions for SHA256 hashing of async data types
-
kalosm-sound
A set of pretrained audio models
-
fluvio-smartmodule
Used by Fluvio SmartModule
-
irox
Tools & Libraries
-
limnus-audio-stream
Audio low level stream
-
drasi-source-sdk
Source SDK for Drasi
-
data-streams
Extension traits for reading and writing data with streams
-
pipebuf
Efficient byte-stream pipe buffer
-
rabbitmq-stream-protocol
AMQP 1.0 message codec
-
streamson-lib
processing large JSONs
-
gel-stream
streaming data between clients and servers
-
cvmcount
CVM algorithm to quickly estimate the number of distinct elements in a stream
-
stream_lib
download differnt types of streams
-
layered-io
I/O traits extending Read and Write
-
ssh-rs
In addition to encryption library, pure RUST implementation of SSH-2.0 client protocol
-
scan_json
React to elements in a JSON stream
-
rw-stream-sink
Adaptator between Stream/Sink and AsyncRead/AsyncWrite
-
cryptostream
Transparent encryption and decryption for Read and Write streams
-
stream-vbyte
Compress and decompress numbers efficiently in the Stream VByte encoding
-
voice-stream
Voice stream is a real-time audio stream processing with voice activity detection. This library provides a high-level interface for capturing audio input, performing voice detection using Silero VAD…
-
tokio-yamux
Yamux
-
futures-timeout
that provides timeouts for futures and streams
-
polars-stream
Private crate for the streaming execution engine for the Polars DataFrame library
-
call2-for-syn
Apply parser functions to proc-macro2 token streams
-
parail
Easily switch between sequential and parallel
-
rabbitmq_streamer
consume RabbiMQ streams
-
debounced
building delayed
Futures and debouncedStreams that wait a given duration before yielding the most recent item -
krpc-client
A stand-alone client for the Kerbal Space Program kRPC mod
-
creek-decode-symphonia
Audio file decoding for creek
-
forked_stream
Convert any Stream with cloneable items into a cloneable stream
-
symbolic-ppdb
parsing and performing lookups on Portable PDB files
-
passcod-web-transport-quinn
[PATCHED] WebTransport library for Quinn
-
iof
Read from and write data to console or file in simple formats
-
twitch_oauth_token
Twitch oauth
-
taskmanager
Manage groups of background tasks
-
selium
An extremely developer friendly, composable messaging platform with zero build time configuration
-
crosstermion
crossterm, without ties totermion -
jsonit
A way to parse Json Items using iterators from streams
-
mpart-async
Asynchronous (Futures-Base) Multipart Requests for Rust
-
async-fuse
Helpers for fusing asynchronous computations
-
async-opcua-types
OPC UA data types
-
barectf-parser
parse barectf-generated CTF trace data
-
http-cache-stream-reqwest
A caching middleware for reqwest that supports streaming bodies
-
twinleaf
working with the Twinleaf I/O protocol and Twinleaf quantum sensors
-
wscat-rs
A cli tool for tailing wss websocket streams
-
uactor
The fastest and most modular actor system that doesn't force you to pay for what you don't need
-
hls_client
generate a single stream from HLS segments
-
event_iterator
Asynchronous lending iterator
-
stream_assert
Macros to simplify testing of
Streambased APIs -
mozilla/neqo-http3
Neqo, an implementation of QUIC written in Rust
-
betfair-stream-api
interacting with Betfair from Rust
-
bromine
A flexible ipc protocol (previously rmp-ipc)
-
parallel-stream
Data parallelism library for async-std
-
ldap-rs
LDAP client for Rust
-
zzz
Fast progress bar with sane defaults
-
same-content
Determine whether data from different sources are the same
-
streamtools
Additional stream combinators
-
betfair-stream-types
interacting with Betfair from Rust
-
tokio-dl-stream-to-disk
A micro-library for downloading from a URL and streaming it directly to the disk
-
fire-http-api
Make web apis
-
irox-networking
irox Networking Tools
-
pxl-rust
XCENA PXL Binding Library
-
merge-streams
Merge multiple streams into one
-
pdfrust
PDF parser
-
moosicbox_stream_utils
MoosicBox stream utils package
-
wasm-http-hyper
WebAssembly library that provides seamless integration between Node.js's IncomingMessage and Rust's hyper::Request
-
respite
An async reader for RESP streams
-
fast-ordered-buffer
A faster buffering implementation for asynchronous streams, trading off memory usage for speed
-
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.
-
lending-stream
A lending version of Stream
-
dynwave
Dynamic audio player based on fixed samples stream
-
tcp-lib
I/O-free library to manage TCP streams
-
nimble-blob-stream
Nimble Blob transfer over datagrams
-
merkle-tree-stream
A stream that generates a merkle tree based on the incoming data
-
entest
similar to ent tool: https://www.fourmilab.ch/random/
-
deluge
A highly concurrent stream library driving the underlying futures either concurrently or in parallel to process streaming operations as quickly as possible
-
betfair-types
interacting with Betfair from Rust
-
saddle
Async seat managment made easy
-
asynk-strim
Lightweight stream generator library
-
sosistab2
An obfuscated datagram transport for horrible networks
-
hefty
Parser for streaming data
-
irox-bits
Bits & Bobs. No-std/No-alloc bit/byte manipulation of streams
-
processmanager
manage process lifecycles, graceful shutdown and process faults
-
rlink
High performance Stream Processing Framework
-
web-sys-stream-utils
Stream-related utilities for web-sys
-
webtransport-proto
WebTransport core protocol
-
tokio-io-rewind
rewind tokio::io::AsyncRead and tokio::io::AsyncWrite streams
-
le-stream
De-/serialize objects from/to little endian byte streams
-
utf8-io
Traits and types for UTF-8 I/O
-
fire-stream
A more or less simple communication protocol library
-
rsflow
High-performance Rust flow processing engine
-
mpeg2ts
MPEG2-TS decoding/encoding library
-
simple-stream
Building blocks for streaming chunks of data over io::Read and io::Write impls
-
webex
Interface to Webex Teams REST and WebSocket APIs
-
libre-url2audio-lib
simple-to-use lib for playing audio streams
-
arkflow
High-performance Rust flow processing engine
-
ruverta
Verilog: Very Simple Verilog Builder
-
selium-log
open-source implementation of a log-based message queue
-
buffer-unordered-weighted
Stream::buffer_unordered where each future can have a different weight
-
s2n-netbench
An efficiency, performance, and correctness analysis tool for transport protocols
-
fluvio-smartengine
The official Fluvio SmartEngine
-
rs-mongo-stream
Wrapper on mongo to easier the way to handle mongo stream
-
binator
Parser Combinator
-
sdf-http
SDF HTTP WASM client library
-
duplex
trait: interactive streams
-
iggy_stream_wrapper
A small wrapper to improve ergonomics around Iggy streams
-
gibbon
WIP implementation of Facebook's gorilla database in rust
-
p2panda-stream
Stream-based methods to conveniently handle p2panda operations
-
macroex
An extractor based low level macro parsing crate that provides high level parsing support through derive macros
-
rust-tls-duplex-stream
Full Duplex stream Wrapper around rust-tls
-
libframing
Length-prefixed framing for byte streams
-
always_send
Wrapper to check
Sendonly on construction, sorustcisn’t confused later -
rusoto_kinesisvideo
AWS SDK for Rust - Amazon Kinesis Video Streams @ 2017-09-30
-
callbag
spec for reactive/iterable programming
-
creek-encode-wav
WAV file encoding for creek
-
async-gcode
An async gcode parser for no_std targets
-
llm_stream
A very simple Rust library to simplify streaming api interaction with LLMs, free from complex async operations and redundant dependencies
-
ts-analyzer
analyzing packets in MPEG/Transport Stream files
-
streamline
Reversible futures::Stream-based state machines
-
rs-tool
A command-line tool to perform reservoir sampling on a file or a stream
-
peekread
Allows peeking ahead in Read streams
-
fibers_rpc
RPC library built on top of fibers crate
-
rocket-multipart
multipart/mixedResponder implementation -
embedded-lnd
that provides a high-level, safe interface for interacting with an embedded LND node
-
sentry-uapi
Sentry kernel user API implementation
-
quick_stream
Quick Stream is a Rust-based solution designed to efficiently handle data upsert operations with a focus on performance and scalability. Utilizing asynchronous programming and a dynamic sender-receiver model…
-
fsbex
extracting audio from FMOD sound banks
-
lightws
Lightweight websocket implement for stream transmission
-
stream-download-opendal
OpenDAL adapter for stream-download
-
stream-wave-parser
The
stream-wave-parseris a crate that treats a stream from WAVE file -
uwl
A management stream for bytes and characters
-
tablestream
A streaming table formatter for the console
-
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
-
datagen_gnss
Data generator in json format for test meeasurement systems
-
linurgy
Manipulate the output of multiple newlines. Replace/Insert/Append newlines with text. Input and output from stdio/files/buffers
-
responder
Quickly create API:s using this simple and lightweight framework
-
stream-reconnect
Stream-wrapping traits/structs that automatically recover from potential disconnections/interruptions
-
futuristic
Extensions to the futures crate
-
throttle-stream
throttle stream
-
roux-stream
A streaming API for the roux Reddit client
Try searching with DuckDuckGo.