Lib.rs

› 关键字 #future #tokio #stream-processing #serialization #async-io #macro

#async-stream

  1. tokio-rustls

    使用 Rustls 为 Tokio 提供的异步 TLS/SSL 流

    v0.26.0 8.8M #tls-stream #async-tls #tokio #rustls #async-stream #server #run-time

  2. async-stream

    使用 async & await 语法实现的异步流

    v0.3.5 3.2M #async-await #stream #macro #notation #error #traits #elements

  3. want

    检测另一个 Future 需要结果的情况

    v0.3.1 6.2M #future #channel #async #async-stream

  4. stream-cancel

    中断异步流

    v0.8.2 124K #async-stream #future #async #tokio #asynchronous

  5. futures-async-stream

    Rust 和 futures crate 的异步流

    v0.2.12 10K #async-stream #stream #future #async #futures #macro

  6. sea-streamer

    🌊 Rust 的流处理工具包

    v0.5.0 2.2K #async-stream #stream-processing #stream #kafka #async-io #async #async-api

  7. async-fn-stream

    无宏的轻量级 async-stream 实现

    v0.2.2 12K #async-stream #stream #async

  8. reactive-mutiny

    具有高级和优化容器（通道）和流执行器的异步事件驱动库

    v1.1.26 1.0K #event-driven #microservices #async-stream #reactive #async #performance #producer-consumer

  9. async-bincode

    异步访问 bincode 编码的项流

    v0.7.2 4.8K #bincode #serialization #tokio #async-stream #asynchronous #async #codec

  10. stream_throttle

    流组合器，用于限制产生项目的时间率

    v0.5.1 42K #async-stream #stream #future #throttle #async #throttling #futures

  11. jmap-client

    Rust的JMAP客户端库

    v0.3.2 650 #jmap #email #mail #email-client #async-stream #emails

  12. futures_ringbuf

    实现AsyncRead/AsyncWrite的Mock类型，用于测试和示例

    v0.4.0 6.3K #async-io #testing #mocking #async-stream #future #async #stream

  13. stopper

    异步流和未来的停止机制

    v0.2.8 3.6K #graceful-shutdown #stream #async-stream #future #http-framework #concurrency #mechanism

  14. async-fuse

    用于融合异步计算的辅助工具

    v0.11.4 220 #async-stream #future #async #tokio

  15. mapped_futures

    基于FuturesUnordered的future集合，支持通过键插入、删除和修改future

    v0.1.12 1.4K #future #stream #async-stream #async #hash-map #futures-unordered #data-structures

  16. scoped-stream-sink

    轻松创建流和汇的简单方式

    v1.2.2 120 #sink #stream #async-stream #async

  17. pylon-cxx

    Basler相机的Pylon库的Rust封装

    v0.4.1 700 #camera #pylon #bindings #image #basler #cpp #async-stream

  18. async-signals

    使用异步Stream进行更简单、更安全的Unix信号处理

    v0.5.0 3.6K #async-stream #signal #unix

  19. streamunordered

    高效的异步流多路复用器

    v0.5.3 1.2K #stream #async-stream #poll #set #yield #multiplexer #manage

  20. wiring

    支持通道的异步二进制序列化框架

    v0.2.2 150 #binary-encoding #serialization #async #rpc #async-stream #networking #rpc-framework

  21. ordered-stream

    相对于外部事件的有序流

    v0.2.0 577K #stream #async-stream #event-stream #timestamp #async

  22. destream

    异步流（反）序列化

    v0.8.0 460 #deserialization #stream #serialization #streaming #async-stream #codec #serializer

  23. misanthropic

    Anthropic Messages API 的异步、易于使用的客户端

    v0.1.0 #async-client #messages #anthropic #async-stream #stream #client #client-key

  24. ruchei

    处理多个流

    v0.0.94 550 #stream #async-stream #async #streams

  25. async-tls

    使用 Rustls 的异步 TLS/SSL 流

    v0.13.0 50K #tls-stream #rustls #async-stream #async-io #tls-client #server #client-server

  26. r3bl_test_fixtures

    r3bl_* TUI 和 CLI 库的测试用例

    v0.0.2 #cli #async-stream #testing #cli-test #async #read-line #input-stream

  27. sea-streamer-socket

    🌊 SeaStreamer 后端无关的 Socket API

    v0.5.0 2.2K #stream-processing #async-stream #stream #kafka #async #data-stream #back-end

  28. taskmanager

    管理后台任务组

    v0.6.2 210 #background-task #group #async-stream #shutdown #manager #manage

  29. sea-streamer-file

    🌊 SeaStreamer 文件后端

    v0.5.2 2.1K #data-stream #stream #async-stream #stream-processing #async #data-file #file-format

  30. sea-streamer-stdio

    🌊 SeaStreamer 标准输入输出后端

    v0.5.0 2.2K #stream-processing #async-stream #stream #async #data-processing #processor

  31. sea-streamer-redis

    🌊 SeaStreamer Redis 后端

    v0.5.0 2.2K #redis #stream-processing #stream #async-stream #async #redis-cluster #consumer-group

  32. futures-stream-ext

    为 futures(-core) 库提供的异步流扩展

    v0.2.2 220 #async-stream #stream #async #extension #future #traits

  33. flo_stream

    Rust futures 的 Pubsub 及相关流

    v0.7.0 500 #pub-sub #future #async-stream #concurrency #futures #sender-receiver

  34. uid-mux

    基于用户提供的流 ID 的异步多路复用库

    v0.1.0 650 #async-stream #async #multiplex #future #futures

  35. msedge-tts

    MSEdge Read aloud 函数 API 的封装。您可以使用它使用微软提供的多种声音进行文本语音合成。

    v0.2.1 150 #tts #text-to-speech #async-read #convert-text #edge-tts #async-stream #async-client

  36. sea-streamer-kafka

    🌊 SeaStreamer Kafka / Redpanda 后端

    v0.5.0 2.2K #kafka #stream-processing #async-stream #stream #async #apache-kafka

  37. tokio-process-stream

    将 tokio::process 封装成 tokio::stream

    v0.4.0 1.9K #tokio #process #stream #async-stream

  38. sea-streamer-types

    🌊 SeaStreamer 特性 & 类型

    v0.5.0 2.3K #stream-processing #async-stream #stream #async

  39. marigold

    编程语言

    v0.1.16 #async-stream #data-stream #programming-language #data-analysis #dsl #within #programs

  40. pms5003

    空气质量传感器接口

    v0.1.1 #air-quality #sensor #interface #hardware #async-stream #data #measurement

  41. futures-enum

    #[derive(Future, Stream, Sink, AsyncRead, AsyncWrite, AsyncSeek, AsyncBufRead)] for enums

    v0.1.17 27K #future #enums #derive #async #async-stream #async-read-async-write #futures

  42. snowstorm

    基于 Noise 协议（snow）的简约加密协议

    v0.4.0 2.0K #async-stream #protocols #noise #encryption #minimalist #snow #tokio

  43. cj_ascii

    在 Rust 中处理 ASCII 字符串

    v0.2.0 #ascii-text #ascii #async-stream #string #stream #async #serialization

  44. asynciter

    异步迭代器

    v0.1.0 #iterator #async-stream #async #stream

  45. process-stream

    对 [tokio::process] 的轻量级封装，使其可流式传输

    v0.4.1 #process #stream #tokio #io-stream #async-stream #async-io

  46. futures-test-sink

    为 futures::sink 提供测试工具

    v0.1.1 280 #sink #mocking #async-stream #async #testing #test

  47. stream-future

    实现一个具有返回值的异步迭代器

    v0.5.0 120 #stream #async-stream #future #iterator #coroutine #yield #nightly

  48. par-dfs

    并行、串行和异步 dfs 和 bfs 遍历

    v0.0.7 #df #bfs #rayon #async #graph-traversal #tokio #async-stream

  49. transform-stream

    轻量级异步流包装器

    v0.3.0 6.2K #async-stream #async #wrapper #transform

  50. streamer

    处理流的便捷工具

    v0.1.2 #stream #async-stream #future #async #futures-util #futures

  51. combine-latest

    将两个流合并为一个新流，该流返回每个输入流的最新值元组

    v1.1.2 #input-stream #async-stream #output-stream #latest #combine #tuple #values

  52. egg-mode-extras

    为 egg-mode 提供速率限制流和其他辅助工具

    v0.4.0 #twitter #rate-limiting #stream #async-stream #helpers #user #mode

    53. 尝试使用 DuckDuckGo 进行搜索。[搜索 DuckDuckGo]

  53. vru-cancel

    取消 tokio 流

    v0.1.2 #async-stream #stream #tokio #async

  54. ruchei-extra

    带有额外数据的流/汇包装器，如 ruchei 所用

    v0.1.1 #stream #async-stream #async #streams

  55. transmog-async

    为 Transmog 提供异步流支持

    v0.1.1 #async-stream #serialization #stream #data-stream #async #transmog #values

  56. processmanager

    管理进程生命周期、优雅关闭和进程故障

    v0.1.0 #graceful-shutdown #process #signal #runnable #fault #async-trait #async-stream

  57. streem

    创建和消费流

    v0.2.0 210 #async-stream #stream #async #consuming #yield #future #yielder

  58. async-stream-packed

    异步流打包

    v0.2.2 #async-stream #client #tls-client #imap #smtp #upgrader #packed

  59. prosto

    使用zstd压缩prosto消息，可选tokio通道支持

    v0.6.4 #protobuf #zstd #stream #prost #async-stream #protocol-buffers #streams

  60. stream-window

    流的窗口

    v0.1.2 #async-stream #stream #tokio #async #window #sliding-window

  61. stream-map-any

    允许合并不同输出类型的异步流

    v0.2.2 #async-stream #future #output-stream #async #non-blocking #futures

  62. shared_stream

    易于克隆的流

    v0.2.1 260 #stream #async-stream #shared #async #streams

  63. tokio-snappy

    将rust-snappy包装成tokio中的异步流

    v0.2.0 #tokio #snappy #decompression #async #compression #decompress #async-stream

  64. xorstream

    使用（可选的异步）数据流与数据向量进行异或

    v2.0.2 #xor #stdio #iter #streaming #async-stream

  65. async-streamdata

    异步IO数据流解码工具

    v0.5.1 #data-stream #async-io #stream #async-stream #deserialize #async-await #deserialization

  66. rumq-client

    为您的连接设备提供高效且健壮的mqtt客户端

    v0.1.0-alpha.10 #mqtt-client #event-loop #robust #iot #async-stream #connected #tokio

  67. tokio-rev-lines

    异步流，按行读取文件或任何BufReader，以反向缓冲

    v0.2.1 #async-stream #tokio #line #reverse #stream #async #lines

  68. async-stream-http-tunnel-grader

    异步流HTTP隧道评分器

    v0.1.4 #tunnel #stream #http #grader #async-http1-lite-client #async-stream #package

  69. async-stream-tls-upgrader

    异步流TLS升级器

    v0.1.10 #tls #stream #upgrader #async-tls-client #async-native-tls-client #async-stream #tls-client

  70. jstream-ext

    为futures Stream traits添加了一些额外扩展

    v0.1.0 #stream #async-stream #future #async #futures #streams

  71. ar_pe_ce

    基于HTTP2的简单流式RPC

    v0.1.1 #rpc #http2 #stream #async-stream #async

  72. nats-connect

    在NATS.io上建立双向异步流

    v0.1.0 #stream #async-stream #nats #bidirectional #io #connection #topic

  73. json-array-stream

    通过异步流逐步读取JSON数组

    v0.1.0 #async-stream #json-array #stream #json #async

  74. futures-async-stream-macro

    futures-async-stream crate的详细说明

    v0.2.12 10K #async-stream #future #stream #async #macro #no-alloc #macros

  75. async-stdio

    用于在std::io上下文中使用异步读写流的适配器

    v0.3.0-alpha.4 #async-stream #io #context #adapter #read-write #io-read #error

  76. redis-streams-dump

    一个将Redis Streams内容转储到SeaStreamer文件的实用工具

    v0.3.0 #stream #redis #async-stream #stream-processing #output-stream #async

  77. repeating_future

    [RepeatingFuture] 是一个可以反复调用对象的异步函数的 [Future]

    v0.1.0 #future #stream #async-stream #async

  78. flood

    异步流的缺失部分

    v0.1.0 #async-stream #piece #progress #utilities