-
future
具有零分配、可组合性和迭代器接口的流
-
async-stream
使用 async & await 语法表示法的异步流
-
futures-util
futures-rs 库的通用工具和扩展特质
-
bollard
异步 Docker 守护进程 API
-
futures-concurrency
异步 Rust 的结构化并发操作
-
ws_stream_wasm
用于在 WASM 中使用 websockets 的便利库
-
quiche
🥧 QUIC 传输协议和 HTTP/3 的美味实现
-
yamux
在可靠、有序连接上的多路复用器
-
gloo-timers
用于处理 JavaScript 定时器的便利包
-
tokio-stream
与
Stream
和tokio
一起工作 -
async-h1
异步 HTTP 1.1 解析器
-
remoc
🦑 远程多路复用对象、通道、可观察集合和 RPC,使远程交互无缝。提供多种远程通道和基于 TCP、TLS 或其他任何传输的 RPC。
-
minidump
minidump 格式的解析器
-
hypercore
安全、分布式、只增日志
-
tentacle
多路复用 p2p 网络框架的最小实现
-
futures-async-stream
Rust 和 futures crate 的异步流
-
sval
流式、结构化值序列化
-
twitch-hls-client
观看/录制 Twitch 流的最小 CLI 客户端
-
reqwest-eventsource
使用 reqwest 构建 Eventsource 的辅助工具
-
io-extras
文件/套接字句柄/描述符工具
-
aws-sdk-ivs
AWS SDK for Amazon Interactive Video Service
-
futures-buffered
注重性能和低内存使用的future并发原语
-
scanner-rust
使用UTF-8或ASCII解析原始类型和字符串的文本扫描器
-
stream-download
将流媒体内容传输到本地文件支持的缓存
-
lzma-sys
liblzma的原始绑定,其中包含LZMA和xz流编码/解码的实现。在xz2crate中提供了高级Rust绑定
-
axum-streams
Axum的HTTP体流支持:json/csv/protobuf/arrow/txt
-
iggy
使用Rust编写的持久消息流平台,支持QUIC、TCP和HTTP传输协议,每秒可处理数百万条消息
-
fluvio
Fluvio的官方Rust驱动程序
-
pharos
生成futures 0.3事件流的观察者模式
-
wasm-streams
使用 WebAssembly 在 Web 流和 Rust 流之间建立桥梁
-
cros-codecs
为 Linux 提供硬件加速编解码器
-
aws-sdk-dynamodbstreams
Amazon DynamoDB Streams 的 AWS SDK
-
async-walkdir
Rust 的异步目录遍历
-
sea-streamer
🌊 Rust 的流处理工具包
-
eventsource-stream
从字节流构建 Eventsource 的基本构建块
-
async-fn-stream
async-stream
的轻量级实现,不使用宏 -
ws_stream_tungstenite
通过 Tungstenite WebSockets 提供异步读写
-
supports-hyperlinks
检测终端是否支持渲染超链接
-
libp2p-mplex
libp2p 的 Mplex 多路复用协议
-
creek
实时安全的音频文件到/从磁盘的磁盘流
-
tls-listener
将连接的流入流包装在TLS中
-
supports-unicode
检测终端是否支持Unicode
-
mpart-async
Rust的异步(Futures-Base)多部分请求
-
aws-sdk-chimesdkmediapipelines
Amazon Chime SDK Media Pipelines的AWS SDK
-
rabbitmq-stream-client
RabbitMQ Stream的客户端
-
udp-stream
UdpSocket与TcpStream相同
-
gst-plugin-ndi
GStreamer NewTek NDI插件
-
socketpair
跨平台socketpair功能
-
iroh-quinn-proto
QUIC传输协议的状态机
-
uwheel
用于流和查询的嵌入式聚合管理系统
-
stream_throttle
流组合器,限制产生项目的速率
-
reqwest-streams
为 reqwest 提供 HTTP 身体流支持:JSON/CSV/Protobuf 等
-
callysto
流处理框架
-
cjseq
创建/处理/修改 CityJSONSeq
-
interruptible
当被中断时停止 future 生产者或流产生值
-
stream-vbyte
在 Stream VByte 编码中高效压缩和解压缩数字
-
ufotofu
用于懒加载消费和产生序列的抽象
-
reqwest-websocket
使用 reqwest 的 WebSocket 连接
-
base64-stream
使用标准 Base64 编码对大量数据进行编码/解码
-
sgxs
使用 SGX 流格式进行工作
-
jppe
字节流结构化序列化和反序列化库
-
s3m
S3 存储桶中的数据流 CLI
-
gix-archive
从工作树流中生成存档
-
selium
一个极具开发者友好性的、可组合的消息平台,零构建时间配置
-
asciinema
终端会话记录器
-
gst-plugin-togglerecord
GStreamer 切换记录插件
-
deno_web
Web API 收集
-
seekable-stream-cipher
可寻址流密码和加密/解密
-
futures_ringbuf
用于测试和示例的模拟类型,实现了 AsyncRead/AsyncWrite
-
basic-text
基本文本字符串和 I/O 流
-
debounced
构建延迟的
Future
和延迟的Stream
,等待给定的时间段后输出最新的项 -
stopper
异步流和未来的停止机制
-
ofilter
快速线程安全的Bloom过滤器
-
mapped_futures
基于FuturesUnordered的一系列futures,支持通过键插入、删除和修改futures
-
channels
通过通用读/写流进行双向通道式通信
-
scoped-stream-sink
轻松创建流和接收器的简单方法
-
trivet
解析库
-
rs-tool
一个命令行工具,用于在文件或流上执行蓄水池抽样
-
indicator
用于流聚合的抽象,我们称之为
Indicator
s -
ipstack
为Tun设备异步轻量级用户空间TCP/IP堆栈实现
-
snocat
流网络覆盖连接仲裁隧道
-
rustyo
使用mpv播放公开可用的互联网广播电台的广播
-
srt_whep
SRT到WHEP(WebRTC)
-
srt-tokio
Rust中的SRT实现
-
streamdeck
Elgato Stream Deck驱动程序和命令行界面
-
fun_run
运行Rust命令的有趣方式
-
selium-log
基于日志的消息队列的开源实现
-
streamtools
额外的流组合器
-
test-assembler
用于构建复杂二进制流的类型集
-
elgato-streamdeck
Elgato Stream Deck的HidApi驱动程序
-
futures-macro
futures-rs过程宏实现
-
layered-io
扩展Read和Write的I/O特性
-
encoding_rs_io
encoding_rs的流式转码
-
collate
支持排序和二分查找的特性和数据结构
-
lending-stream
Stream的贷款版本
-
tailsrv
一个高性能的文件流服务器
-
bzip2-sys
将libbzip2的bzip2压缩和解压缩功能绑定成Reader/Writer流
-
postage
一个异步通道库
-
rrtk
Rust机器人工具包
-
tiktoklive
库。使用它来实时接收TikTok LIVE的直播流事件,如评论和礼物,无需凭证。
-
streamunordered
一个高效的异步流多路复用器
-
fluvio-smartmodule
由Fluvio SmartModule使用
-
xstream-util
一个命令行工具,用于将流分割到子进程中
-
tbon
TinyChain二进制对象表示法(TinyChain Binary Object Notation)是一种紧凑且通用的、适合流处理的二进制序列化格式
-
有序流
相对于外部事件的有序流
-
changes-stream2
couchdb follower
-
bevy_streamdeck
Bevy的Elgato Stream Deck插件
-
krossbar-rpc
Krossbar RPC库
-
destream
异步流(反)序列化
-
wasm-ws
用于在 WASM 中使用 websockets 的便利库
-
pipebuf
高效的字节流管道缓冲区
-
drop-stream
包装另一个流的流,该流在它被丢弃时调用一个闭包
-
utf8-io
UTF-8 I/O的特性和类型
-
destream_json
解码和编码JSON流
-
future-queue
管理一个队列的适配器,其中每个future可以有不同的权重
-
rw-stream-sink
Stream/Sink与AsyncRead/AsyncWrite之间的适配器
-
sillad
在futures-io生态系统内讨论类似TCP的拨号器和监听器的框架
-
deepseek-api-client
Deepseek的非官方API客户端
-
same-content
确定来自不同来源的数据是否相同
-
mozilla/neqo-http3
Neqo,使用Rust编写的QUIC实现
-
futures-ticker
异步的周期性时间事件
-
tokio-io-rewind
回滚tokio::io::AsyncRead和tokio::io::AsyncWrite流
-
icy-metadata
解析Icecast元数据
-
uactor
最快的、最模块化的actor系统,不需要为不需要的功能付费
-
zzz
具有合理默认值的快速进度条
-
multichannel_audio
在Rust中播放和录制多声道音频
-
anthropic-rs
Anthropic Rust SDK
-
async-shared-timeout
可以重置和共享的异步超时
-
picomux
一种协议,用于通过单个流复用多个AsyncRead/Write流,受smux和http2的启发
-
uni-stream
适用于TCP和UDP流量以及自定义DNS解析服务的通用流
-
ruchei
处理多个流的工作
-
oval
为nom、winnow等设计的流抽象
-
tokio-dl-stream-to-disk
一个用于从URL下载并将其直接流式传输到磁盘的微型库
-
fire-stream
一个相对简单的通信协议库
-
async-hash
用于异步数据类型SHA256散列的特性和辅助函数
-
tokio-stream_wasi
与
Stream
和tokio
一起工作 -
aes-gcm-stream
AES GCM流加密和解密库,支持AES128/192/256位密钥
-
renoir
Rust中的操作员网络
-
mft
Windows主文件表(MFT)格式的快速(且安全)解析器
-
noodles-bgzf
阻塞gzip格式(BGZF)读取器和写入器
-
rust-box
Rust编程的奇偶工具集
-
stdin-to-cloudwatch
将stdin中的日志发送到AWS CloudWatch Logs
-
libp2p-stream
libp2p的通用流协议
-
re_log_encoding
用于编码和传输Rerun日志消息的辅助工具
-
gomander-engiffen
将一系列图片编码为GIF图像。包括可安装的命令行bin以及库。从https://github.com/TooManyBees/engiffen分叉而来
-
futures-batch
一个将元素分块并在超时或缓冲区满后刷新它们的适配器。(以前称为tokio-batch。)
-
sval_dynamic
sval::Stream和sval::Value的对象安全版本
-
twitchalerts
当检测到直播者直播时触发事件处理器,更多功能即将添加
-
futures-finally
在未来的完成或流完成后执行一个未来,无论其值或结果如何
-
stream-rate-limiter
为Tokio流提供速率限制器
-
async-utf8-decoder
将AsyncRead转换为增量UTF8字符串流
-
tokio-tls-upgrade
使用PEM格式的证书和密钥将TCP流升级为TLS流
-
stdecor
带有装饰的stdout/stderr运行命令
-
futures-http
基于futures流的基础http框架
-
发酵
好类型的衰减;正向衰减
-
ts-analyzer
分析MPEG/传输流文件中的数据包
-
blockwise_reader
读取前几个字节并解析大文件或流
-
respite
用于RESP流的异步读取器
-
sea-streamer-socket
🌊 SeaStreamer后端无关的Socket API
-
fe2o3-amqp-ws
AMQP1.0的WebSocket绑定流
-
snapup
用于处理带有后续更新流的快照的抽象
-
sea-streamer-file
🌊 SeaStreamer 文件后端
-
stream-extractor
TCP流提取器是一个小工具,可以读取PCAP文件,搜索其中的TCP流,并将每个流写入单独的新PCAP文件
-
sea-streamer-stdio
🌊 SeaStreamer 标准I/O后端
-
async-time-mock-async-std
用于异步运行时(与async-std兼容)的可模拟时间
-
async-rx
用于异步响应式编程的函数
-
comfy-print
println!和朋友们的不崩溃版本。异步实现。
-
splaycast
流特定的广播通道
-
archiv
读取和写入压缩、长度前缀的流或文件
-
sea-streamer-redis
🌊 SeaStreamer Redis后端
-
selium-server
Seleum的服务端二进制文件,这是一个对开发者极为友好、可组合的消息平台,配置无构建时间
-
bgp-rs
解析边界网关协议(BGP)格式化的流
-
rabbitmq-stream-protocol
AMQP 1.0消息编解码器
-
webrtc-audio-processing
WebRTC音频处理模块的包装器
-
flood-rs
位和字节流
-
json-stream-parser
一个能够解析流式传输的不完整JSON字符串的JSON解析器
-
merkle-tree-stream
基于传入数据的流生成梅克尔树
-
merge-streams
将多个流合并为一个
-
sval_nested
sval的递归变体
-
grader
基于流的CLI,通过给定的shell命令对二进制排序文本文件进行排序
-
lafere
一个相对简单的通信协议库
-
openaction
为OpenAction API创建插件
-
nature
开发支持平台,它将数据定义与代码分离,因此将数据与业务系统解耦
-
futures-stream-ext
为futures(-core) crate提供的异步流扩展
-
reydenx
Reyden-X API。Reyden-X是一个用于在集成观众和观看管理系统中推广外部网站直播的自动化服务。
-
rocket-multipart
multipart/mixed
响应者实现 -
ianaio-timers
用于处理JavaScript定时器的IanaIO crate
-
rerun_c
Rerun C SDK
-
actix-contrib-rest
基于Actix Web框架的REST和webapp项目的实用类型和函数
-
stream-unpack
用于流解包存档的小型库
-
stream-reconnect
自动从潜在的断开连接/中断中恢复的流包装特质/结构体
-
simple-stream
用于在io::Read和io::Write impls上流式传输数据块的构建块
-
iof
以指定格式从控制台或文件中读取和写入数据
-
debounced-wasm
debounced crate 的分支,支持 wasm
-
aurora-streams
使用 Tokio 消息传递通道管理发布/订阅通道
-
libre-url2audio-lib
用于播放音频流的简单库
-
rlink
高性能流处理框架
-
comfy-print-sync
println! 和朋友的非恐慌版本。同步实现。
-
stream_assert
用于简化基于
Stream
的 API 测试的宏 -
squinn-proto
QUIC传输协议的状态机
-
sea-streamer-kafka
🌊 SeaStreamer Kafka / Redpanda 后端
-
buffer-unordered-weighted
每个 future 都可以有不同的权重的 Stream::buffer_unordered
-
fopencookie
std::io 和 libc::FILE 之间的接口
-
orcrs
Rust 的 Apache ORC 文件读取器
-
preflate-rs
Rust版本的Preflate压缩库
-
kalosm-streams
为Kalosm预训练模型提供的一系列流
-
time-key-stream-set
一个基于时间键的流集合
-
tokio-process-stream
将tokio::process包装为tokio::stream
-
uwheel-stats
uwheel的剖析工具
-
futures-boring
基于BoringSSL构建的Futures SSL流
-
wasmrs
wasmRS RSocket协议的基础主机和客户端实现
-
creek-decode-symphonia
creek的音频文件解码器
-
debounce
用于去重事件的流数据结构和辅助工具:移除时间上紧密发生的重复事件
-
uflow
基于UDP的有序、混合可靠性、拥塞控制的数据传输
-
dlwp
DLWP库
-
sea-streamer-types
🌊 SeaStreamer 特性和类型
-
streamline
可逆的未来::基于流的州机
-
swimos_multi_reader
SwimOS 流聚合器
-
tokio-socketcan
使用 tokio 的异步 Linux SocketCAN 套接字
-
rabbitmq_http_client
RabbitMQ HTTP API 客户端
-
fluvio-smartengine
官方 Fluvio SmartEngine
-
kvarn-quinn
临时 Kvarn 分支:多才多艺的 QUIC 传输协议实现
-
crab-dlna
一个最小的 UPnP/DLNA 媒体流传输器
-
cstream
libc::FILE
streams ‘c streams’ -
task-stream
一个全局任务执行器,在
no_std
中运行 -
music-player-playback
音乐播放器的播放逻辑
-
skrillax-codec
为 Silkroad Online 网络数据包设计的帧编码器
-
lightws
轻量级的用于流传输的 WebSocket 实现
-
mockstream
用于在测试中模拟真实流的流(Read+Write traits)实现
-
tokio-par-stream
由 tokio 驱动的并行流
-
juliet
一种安全的流多路复用协议
-
sm4-gcm
SM4-GCM 库
-
stream-more
Rust 的流工具
-
event_iterator
异步借用迭代器
-
bufstream-fresh
bufstream crate 的分支。为每个读写半部分分别缓存的流式缓冲 I/O。
-
callbag
响应式/可迭代编程规范
-
datagen_gnss
用于测试测量系统的 json 格式数据生成器
-
menemen
流式 HTTP 请求库
-
json-walker
JSON 流解析器和反序列化器。在此包中,您决定必须解析 JSON 的哪些部分
-
futures-io-preview
为 futures-rs 库提供
AsyncRead
和AsyncWrite
特性 -
音乐播放器插件
音乐播放器的插件
-
peekread
允许在读取流中预览
-
linurgy
操作多个新行的输出。用文本替换/插入/追加新行。从stdio/files/buffers输入和输出
-
qstdin
查询stdin的接口
-
humphrey_ws
Humphrey网络服务器的WebSocket支持
-
scan2
一些从底层流获取下一个项目的小助手
-
futuristic
对futurescrate的扩展
尝试使用 DuckDuckGo 进行搜索。搜索 DuckDuckGo.