#stream

  1. futures

    streams featuring zero allocations, composability, and iterator-like interfaces

    v0.3.31 8.5M #asynchronous-programming #future #stream #async #zero-allocation #control-flow #composability
  2. async-stream

    Asynchronous streams using async & await notation

    v0.3.6 4.4M #async-await #stream #notation #macro #error #traits #elements
  3. futures-util

    Common utilities and extension traits for the futures-rs library

    v0.3.31 9.5M #future #stream #async-io #async-write #async-read #sink #utilities
  4. quiche

    πŸ₯§ Savoury implementation of the QUIC transport protocol and HTTP/3

    v0.22.0 28K #quic #http-3 #protocols #connection #stream #applications #data
  5. ws_stream_wasm

    A convenience library for using websockets in WASM

    v0.7.4 203K #websockets #wasm #async #stream #async-io #web-api #api-bindings
  6. yamux

    Multiplexer over reliable, ordered connections

    v0.13.4 370K #network-protocol #connection #reliable #protocols #ordered #networking #stream
  7. futures-concurrency

    Structured concurrency operations for async Rust

    v7.6.2 111K #async #concurrency #future #stream #structured #operations #multiple
  8. minidump

    A parser for the minidump format

    v0.22.2 29K #file-format #debugging #crash-reporting #stream #symbols #breakpad #analysis
  9. tokio-stream

    work with Stream and tokio

    v0.1.16 5.5M #stream #async-stream #tokio #async-io #io-stream #networking #utilities
  10. supports-unicode

    Detects whether a terminal supports unicode

    v3.0.0 487K #unicode #detect #npm #whether #terminal #package #stream
  11. async-h1

    Asynchronous HTTP 1.1 parser

    v2.3.4 100K #http-parser #async-http #parser #async #stream #http1 #http-1
  12. io-extras

    File/socket handle/descriptor utilities

    v0.18.3 320K #io #io-stream #stream #api
  13. ws_stream_tungstenite

    Provide AsyncRead/AsyncWrite over Tungstenite WebSockets

    v0.14.0 30K #websocket #async-io #websockets #async #websocket-server #stream #async-api
  14. supports-hyperlinks

    Detects whether a terminal supports rendering hyperlinks

    v3.1.0 434K #terminal #hyperlink #detect #rendering #whether #stream #families
  15. iggy

    persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second

    v0.6.50 900 #consumer-group #http-transport #quic #topic #stream #messaging #partition
  16. reqwest-eventsource

    Helper to build an Eventsource using reqwest

    v0.6.0 73K #event-source #server-sent-events #reqwest #sse #events #byte-stream #stream
  17. futures-async-stream

    Async stream for Rust and the futures crate

    v0.2.12 8.8K #async-stream #stream #future #async #futures #macro
  18. sval

    Streaming, structured value serialization

    v2.13.2 917K #serialization #text-format #streaming-json #value #stream #self-describing #serde
  19. fluvio

    The official Fluvio driver for Rust

    v0.24.0 1.7K #data-streaming #streaming #data-processing #queue #stream
  20. pdf-writer

    A step-by-step PDF writer

    v0.12.0 10K #pdf #writer #document #stream #content #builder-pattern #buffer
  21. stream-download

    streaming content to a local file-backed cache

    v0.13.1 1.3K #streaming-media #stream #media #http-request #audio-stream #local-storage #audio-streaming
  22. futures-buffered

    future concurrency primitives with emphasis on performance and low memory usage

    v0.2.9 102K #low-memory #future #concurrency #thread-safe #stream #processing #performance
  23. aws-sdk-ivs

    AWS SDK for Amazon Interactive Video Service

    v1.55.0 900 #amazon-web-services #key-pair #web-services #video-streaming #aws-sdk #stream #channel
  24. 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 xz2 crate

    v0.1.20 627K #lzma #xz #bindings #codec #liblzma #stream #xz2
  25. hypercore

    Secure, distributed, append-only log

    v0.14.0 200 #merkle #stream #feed #dat #log-entries #secure-storage #p2p
  26. axum-streams

    HTTP body streaming support for Axum: json/csv/protobuf/arrow/txt

    v0.19.0 6.9K #http-response #web-framework #http-body #json-stream #web #stream #http
  27. sea-streamer

    🌊 The stream processing toolkit for Rust

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

    Observer pattern which generates a futures 0.3 stream of events

    v0.5.3 231K #event-stream #stream #pub-sub #observer #future #broadcast #data-stream
  29. cros-codecs

    Hardware-accelerated codecs for Linux

    v0.0.5 1.7K #hardware-accelerated #codec #frame #decoding #stream #video-stream #decoded
  30. eventsource-stream

    A basic building block for building an Eventsource from a Stream of bytes

    v0.2.3 76K #event-source #server-sent-events #stream #event-stream #sse #events #parse
  31. scanner-rust

    text scanners which can parse primitive types and strings using UTF-8 or ASCII

    v2.0.17 150 #string-parser #data-stream #scanner #input-stream #text-parser #stream #stdin
  32. wasm-streams

    Bridging between web streams and Rust streams using WebAssembly

    v0.4.2 1.9M #stream #wasm #web-api #bridge #readable-stream #writable-stream #bridging
  33. aws-sdk-dynamodbstreams

    AWS SDK for Amazon DynamoDB Streams

    v1.49.0 3.0K #aws-sdk #dynamo-db #stream #stream-processing #records #operation #table
  34. async-fn-stream

    Lightweight implementation of async-stream without macros

    v0.2.2 38K #async-stream #stream #async
  35. gst-plugin-ndi

    GStreamer NewTek NDI Plugin

    v0.13.3 140 #audio-video #gstreamer #ndi #multimedia-video #plugin #source #stream
  36. libp2p-mplex

    Mplex multiplexing protocol for libp2p

    v0.42.0 32K #p2p #peer-to-peer #multiplexing #mplex #protocols #stream #decentralization
  37. rustyo

    radio that uses mpv to play radio streams from publically available internet radiostations

    v1.0.8 1.3K #radio #mpv #stream #internet #play #station #list
  38. reqwest-streams

    HTTP body streaming support for reqwest: JSON/CSV/Protobuf and others

    v0.8.2 2.4K #http-response #http-body #stream #web #http #streaming-json #http-request
  39. twitch-hls-client

    Minimal CLI client for watching/recording Twitch streams

    v1.3.12 #low-latency #twitch #stream #client #hls #command-line-tool #player
  40. udp-stream

    UdpSocket same as TcpStream

    v0.0.12 7.6K #udp #dtls #stream #udp-packet #data-stream #data-streaming #tokio
  41. aws-sdk-chimesdkmediapipelines

    AWS SDK for Amazon Chime SDK Media Pipelines

    v1.51.0 550 #aws-sdk #media #pipeline #amazon #stream #operation #chime
  42. async-walkdir

    Asynchronous directory traversal for Rust

    v2.0.0 38K #directory-traversal #async #async-io #directory #recursion #walk #stream
  43. creek

    Realtime-safe disk streaming to/from audio files

    v1.2.2 700 #audio-streaming #audio #disk #io #stream #codec
  44. reqwest-websocket

    WebSocket connections with reqwest

    v0.4.3 8.3K #websocket #reqwest #stream
  45. uwheel

    Embeddable Aggregate Management System for Streams and Queries

    v0.2.1 360 #aggregation #wheel #aggregate #stream #streaming #query #optimization
  46. rabbitmq-stream-client

    client for RabbitMQ Stream

    v0.7.0 1.0K #stream #stream-processing #messaging #amqp #iot #amqp-client #send-message
  47. jppe

    byte stream structured serialization and deserialization library

    v1.1.1 750 #byte-stream #serialization #packet-parser #byte #stream #parser #networking
  48. interruptible

    Stops a future producer or stream from producing values when interrupted

    v0.2.4 150 #stream #future #interrupt #producer #signal #ctrl-c #producing
  49. callysto

    Stream processing framework

    v0.1.11 #stream-processing #distributed-database #stream #microservices #distributed #database
  50. iroh-quinn-proto

    State machine for the QUIC transport protocol

    v0.12.0 12K #quic #state-machine #connection #protocols #stream #networking #low-level
  51. cjseq

    Create/process/modify CityJSONSeq

    v0.3.1 #processing #city-json #city-json-seq #convert #stream #dataset #modify
  52. base64-stream

    To encode/decode large data with the standard Base64 encoding

    v4.0.0 4.1K #base64 #data-encoding #data-stream #data-file #stream #reader-writer #codec
  53. debounced

    building delayed Futures and debounced Streams that wait a given duration before yielding the most recent item

    v0.2.0 7.6K #stream #future #delay #duration #debounce #recent #wait
  54. stream_throttle

    Stream combinator, to limit the rate at which items are produced

    v0.5.1 47K #async-stream #rate-limiting #stream #future #async #throttle #throttling
  55. gst-plugin-togglerecord

    GStreamer Toggle Record Plugin

    v0.13.3 200 #gstreamer #plugin #recording #input #live #toggle #stream
  56. elgato-streamdeck

    HidApi driver for Elgato Stream Decks

    v0.8.0 220 #stream #elgato #driver #devices #decks #hidapi #streamdeck
  57. channels

    Bidirectional channel-like communication over generic Read/Write streams

    v0.13.0 #io-stream #communication-channel #channel #data-stream #stream #async-io #async-channel
  58. seekable-stream-cipher

    Seekable stream cipher and encryption/decryption

    v0.2.3 260 #stream-cipher #stream #cipher #keccak #encryption #read-stream #ascon
  59. basic-text

    Basic Text strings and I/O streams

    v0.19.2 #io-stream #text-format #plain-text #string-literal #stream #basic #string-format
  60. av-bitstream

    bit writer/reader

    v0.2.1 650 #bit #byte #byte-reader #fixed-size #reader-writer #bitstream #stream
  61. ofilter

    fast thread-safe Bloom filter

    v0.4.3 #bloom-filter #filter #bloom #stream
  62. s3m

    CLI for streams of data in S3 buckets

    v0.10.0 #amazon-s3 #s3 #stream #upload #bucket #resume #database-server
  63. asciinema

    Terminal session recorder

    v3.0.0-rc.3 #terminal-session #recording #command-line-tool #recorder #http-server #stream #screen-recording
  64. stream-vbyte

    Compress and decompress numbers efficiently in the Stream VByte encoding

    v0.4.1 6.2K #compression #varint #numbers #simd #encoding #stream #stream-processing
  65. scoped-stream-sink

    Easy way to make streams and sinks

    v1.2.2 #sink #stream #async-stream #async
  66. gix-archive

    archive generation from of a worktree stream

    v0.17.0 12K #version-control #archive #git #stream #tar #worktree #generation
  67. srt-tokio

    SRT implementation in Rust

    v0.4.4 #video-streaming #srt #live-streaming #tokio #connection #stream #high
  68. sgxs

    working with the SGX stream format

    v0.8.0 850 #sgx-enclave #intel-sgx #sgx #enclave #file-format #stream #cross-platform
  69. futures-macro

    The futures-rs procedural macro implementations

    v0.3.31 9.2M #asynchronous-programming #proc-macro #future #stream #control-flow #combinator #procedural
  70. snocat

    Streaming Network Overlay Connection Arbitration Tunnel

    v0.8.0-alpha.5 119K #tunnel #connection #stream #quic #streaming #dynamic #overlay
  71. selium

    An extremely developer friendly, composable messaging platform with zero build time configuration

    v0.5.0 420 #messaging #streaming #stream #queue #build-time #message-queue #send-message
  72. mpart-async

    Asynchronous (Futures-Base) Multipart Requests for Rust

    v0.7.0 4.6K #multipart #requests #future #async-client #stream #client-server #hyper-client
  73. indicator

    Abstractions for stream aggregation, we call them Indicator s

    v0.4.4 #stream-processing #aggregation #stream #date-time
  74. collate

    Traits and a data structure to support collation and bisection

    v0.4.2 1.8K #collation #bisect #stream #bisection #order #structure #utilities
  75. mp4parse

    Parser for ISO base media file format (mp4)

    v0.17.0 4.8K #media-file #iso #file-format #mp4 #base #stream #aka
  76. bevy_streamdeck

    Elgato Stream Deck plugin for Bevy

    v0.5.0-rc.1 240 #bevy #bevy-plugin #deck #stream #streamdeck #elgato #input-event
  77. mapped_futures

    A collection of futures based on FuturesUnordered that supports insertion, removal and mutation of futures by key

    v0.1.13 650 #future #async-stream #stream #async #hash-map #futures-unordered #data-structures
  78. encoding_rs_io

    Streaming transcoding for encoding_rs

    v0.1.7 215K #io-read #io #transcoding #io-stream #encoding #read #stream
  79. layered-io

    I/O traits extending Read and Write

    v0.23.1 #read-write #io-write #io #io-stream #stream #api
  80. lending-stream

    A lending version of Stream

    v1.0.1 280 #lending #stream #projection #version #pin
  81. bzip2-sys

    Bindings to libbzip2 for bzip2 compression and decompression exposed as Reader/Writer streams

    v0.1.11+1.0.8 2.4M #bzip2 #bindings #stream #streaming #exposed #libbzip2 #reader-writer
  82. drop-stream

    A stream that wraps another stream with a closure that is called once it is dropped

    v0.3.2 2.5K #stream #data-transfer #closures #data-stream #drop #future #connection
  83. aurora-streams

    managing publish-subscribe channels using Tokio message passing channels

    v2.0.0-rc.2 200 #pub-sub #channel #message #tokio #communication #stream #messaging
  84. misanthropic

    An async, ergonomic, client for Anthropic's Messages API

    v0.5.0 900 #api-client #async-client #anthropic #async-stream #messages #async #stream
  85. trivet

    Parser Library

    v2.0.2 #low-level #recursion #parser #character #recursive-descent #stream #consume
  86. pipebuf

    Efficient byte-stream pipe buffer

    v0.3.2 600 #buffer #stream #queue #collection #stream-processing #data-stream #handler
  87. tiktoklive

    library. Use it to receive live stream events such as comments and gifts in realtime from TikTok LIVE No credentials are required.

    v0.0.19 #live #tiktok #stream #reverse-engineering #api-bindings #programming-language #api
  88. streamtools

    Additional stream combinators

    v0.7.5 1.6K #stream #combinator #tokio #utilities #testing #test-util #tokio-time
  89. redsumer

    Lightweight implementation of Redis Streams for Rust

    v0.5.1 120 #consumer-group #redis #stream #message #redis-streams #streaming #manage
  90. ordered-stream

    Streams that are ordered relative to external events

    v0.2.0 631K #async-stream #event-stream #stream #data-stream #async #timestamp #data-source
  91. picomux

    A protocol to multiplex multiple AsyncRead/Write streams over a single one, inspired by smux and http2

    v0.1.9 1.1K #network-communication #stream #http2 #networking #network-protocol #protocols #connection
  92. splaycast

    Stream-specific broadcast channel

    v0.4.5 1.0K #broadcast-channel #subscriber #stream #tokio #message #sync #high
  93. async-utf8-decoder

    Convert AsyncRead to incremental UTF8 string stream

    v1.0.0 160 #utf-8 #stream #async #decoder #io #future #string
  94. changes-stream2

    couchdb follower

    v0.2.19 #couch-db #stream #events #read-stream #parser #api #rustls
  95. streamdeck

    Elgato Stream Deck driver and command line interface

    v0.9.0 160 #usb-device #stream #deck #driver #elgato #devices #interface
  96. aes-gcm-stream

    AES GCM stream encrypt and decrypt library, supports AES128/192/256 bit keys

    v0.2.4 250 #aes-gcm #aes #gcm #stream #encryption-decryption #cryptography
  97. lightws

    Lightweight websocket implement for stream transmission

    v0.6.12 260 #stream #async #networking #heap-allocation #io-stream
  98. sillad

    A framework for talking about TCP-like dialers and listeners, within the futures-io ecosystem

    v0.2.5 650 #tcp-listener #networking #tcp-connection #framework #tcp-client #stream #network-communication
  99. tbon

    TinyChain Binary Object Notation is a compact and versatile stream-friendly binary serialization format

    v0.6.0 #binary-encoding #serialization #binary-format #binary #binary-data #deserialize #stream
  100. wasm-ws

    A convenience library for using websockets in WASM

    v0.2.1 1.5K #websocket #wasm #async-stream #async #stream #tokio
  101. fluvio-smartmodule

    Used by Fluvio SmartModule

    v0.8.0 3.2K #wasm-module #fluvio #stream #streaming #wasm #data-streaming
  102. futures_ringbuf

    Mock Type implementing AsyncRead/AsyncWrite for testing and examples

    v0.4.0 2.5K #async-io #async-stream #async-networking #testing #mocking #async #stream
  103. flood-rs

    Bit and octet streams

    v0.0.12 150 #network-communication #network-protocol #ipc #stream #file-format #data #deserialize
  104. rw-stream-sink

    Adaptator between Stream/Sink and AsyncRead/AsyncWrite

    v0.4.0 267K #async-io #stream #async-write #async-read #sink #read-stream #read-write
  105. fun_run

    The fun way to run your Rust Comand

    v0.2.0 340 #run-command #command-output #command-name #command #run #execute #stream
  106. destream

    async stream (de)serialization

    v0.8.0 160 #async-stream #deserialization #serialization #stream #streaming #streaming-json #codec
  107. data-stream

    serialization library based on streams

    v0.2.1 #serialization #binary-data #binary-serialization #stream #read-stream #data-model #read-write
  108. rust-tls-duplex-stream

    Full Duplex stream Wrapper around rust-tls

    v0.1.1 1.6K #duplex #stream #tls #background-thread
  109. async-hash

    Traits and helper functions for SHA256 hashing of async data types

    v0.5.4 #sha-256 #hash #stream #async #data-structures #asynchronous
  110. dynwave

    Dynamic audio player based on fixed samples stream

    v0.2.0 360 #stream #audio-samples #audio-stream #wave #cross-platform #audio
  111. ipstack

    Asynchronous lightweight userspace implementation of TCP/IP stack for Tun device

    v0.1.0 950 #stack #tun #devices #userspace #async #stream #udp
  112. jw_client

    API wrapper for the JW Player media management API. List or stream library into native Rust structs and download renditions.

    v1.0.0 700 #media #download #stream #player #api #api-client #management
  113. destream_json

    decoding & encoding a JSON stream

    v0.13.0 #json-stream #json #deserialize-json #codec #stream #serialization
  114. async-shared-timeout

    Async timeout that can be reset and shared

    v0.2.2 700 #timeout #tokio #sleep #shared #async #stream #reset
  115. binary-util

    A panic-free binary utility crate to read/write binary streams over the wire

    v0.3.4 #binary-data #read-write #stream #data-stream #varint #panic-free #reading
  116. same-content

    Determine whether data from different sources are the same

    v0.1.10 #file-reader #file-content #stream #reader #file #data-stream #data-file
  117. rs-tool

    A command-line tool to perform reservoir sampling on a file or a stream

    v0.1.1 #log-file #reservoir #log #stream #sample #statistics #input-file
  118. music-player-playback

    The playback logic for music player

    v0.1.13 #music-player #audio-playback #audio-player #audio-streaming #self-hosted #media-player #stream
  119. mozilla/neqo-http3

    Neqo, an implementation of QUIC written in Rust

    GitHub 0.7.0 #firefox #quic #ietf #mozilla #stream #server #http3
  120. stream-tungstenite

    A streaming implementation of the Tungstenite WebSocket protocol

    v0.4.0 600 #websocket #tungstenite #events #connection #event-listener #stream #error
  121. icy-metadata

    parsing Icecast metadata

    v0.2.0 120 #audio-stream #audio-metadata #stream #icecast #media #audio #http-request
  122. libp2p-stream

    Generic stream protocols for libp2p

    v0.2.0-alpha 3.5K #p2p #stream #peer-to-peer #protocols #control #applications #generic
  123. pdfrust

    PDF parser

    v0.5.0 490 #pdf #parser #font #page #content #stream #character
  124. future-queue

    Adapters to manage a queue of futures, where each future can have a different weight

    v0.3.0 54K #future #futures #stream #async #buffer-unordered
  125. tokio-io-rewind

    rewind tokio::io::AsyncRead and tokio::io::AsyncWrite streams

    v0.1.3 460 #tokio #read-stream #data-stream #async-io #stream #io #async-stream
  126. asynk-strim

    Lightweight stream generator library

    v0.1.2 340 #async-stream #stream #async #no-alloc #no-std
  127. dissonance

    An async-friendly Rust library for generating Noise-encrypted transport protocols

    v0.3.5 #generate #protocols #noise #stream #sockets #noise-encrypted #async-friendly
  128. tokio-dl-stream-to-disk

    A micro-library for downloading from a URL and streaming it directly to the disk

    v1.0.1 420 #download #tokio #streaming #disk #url #stream #async-download
  129. uactor

    The fastest and most modular actor system that doesn't force you to pay for what you don't need

    v0.12.1 #actor-system #actor #stream
  130. rust-box

    odd set of tools for Rust programming

    v0.12.1 440 #sink #stream #collection #events #task #collections
  131. event_iterator

    Asynchronous lending iterator

    v0.2.2 #lending-iterator #iterator #lending #async-stream #async #stream #gat
  132. ruchei

    working with many streams

    v0.0.95 300 #async-stream #stream #async
  133. utf8-io

    Traits and types for UTF-8 I/O

    v0.19.1 210 #utf-8 #read-write #io-stream #stream #error #traits #invalid
  134. sval_dynamic

    Object-safe versions of sval::Stream and sval::Value

    v2.13.2 910K #serialization #object-safe #value #sval #versions #stream #no-std
  135. fire-stream

    A more or less simple communication protocol library

    v0.4.3 #encryption #stream #plain-text #fire #how #directory #api
  136. snapup

    Abstractions for handling snapshots with streams of subsequent updates

    v0.1.8 1.3K #snapshot #update #stream #abstraction #subsequent
  137. yosemite

    Asynchronous SAMv3 library

    v0.2.0 130 #stream #async #i2p #synchronous #api #sa-mv3 #sync
  138. stdecor

    Run a command with a decorated stdout/stderr

    v0.1.12 #command-line #shell #run-command #subprocess #stream #prefix #pipe
  139. selium-log

    open-source implementation of a log-based message queue

    v0.1.0 #message-queue #messaging #selium #queue #streaming #stream #client-server
  140. futures-batch

    An adaptor that chunks up elements and flushes them after a timeout or when the buffer is full. (Formerly known as tokio-batch.)

    v0.6.1 17K #timeout #future #chunks #stream #adaptor #buffer #up
  141. llm_stream

    A very simple Rust library to simplify streaming api interaction with LLMs, free from complex async operations and redundant dependencies

    v0.3.1 #language-model #llm #api-bindings #stream #api #api-key #api-client
  142. sea-streamer-socket

    🌊 SeaStreamer backend-agnostic Socket API

    v0.5.1 2.1K #stream-processing #async-stream #stream #kafka #async #data-stream #data-streaming
  143. zzz

    Fast progress bar with sane defaults

    v0.3.1 #progress-bar #iterator #stream #low-overhead #tqdm
  144. oval

    A stream abstraction designed for use with nom, winnow, etc

    v2.0.0 10K #nom #parser #stream #data-stream #abstraction #winnow #buffer
  145. spring-stream

    rust microservice framework

    v0.2.1 #microservices #stream #framework #kafka #redis #data #command-line
  146. sval_nested

    A recursive variant of sval

    v2.13.2 137K #serialization #stream #recursion #sval #variant #api #no-std
  147. ts-analyzer

    analyzing packets in MPEG/Transport Stream files

    v0.2.1 210 #transport-stream #stream #video-stream #transport #mpeg #packet-parser #parser
  148. respite

    An async reader for RESP streams

    v0.3.3 600 #stream #resp #reader #async #protocols #frame #reading
  149. wasm-zip-stream

    A stream style zip compressing tool targeting wasm

    v0.1.0 #zip #stream #compression #wasm #zip-file
  150. sea-streamer-file

    🌊 SeaStreamer File Backend

    v0.5.2 2.0K #stream-processing #async-stream #data-stream #stream #binary-data #data-file #process-file
  151. serser

    serialization crate

    v0.1.0 #serialization #tokens #intermediate-representation #stream #framework #macro-derive #seq
  152. fermentation

    The good kind of decay; forward decay

    v0.6.0 290 #forward #decay #aggregation #stream #kind #paper #items
  153. rtmp

    rtmp library

    v0.6.5 #video-streaming #streaming #media-server #live-streaming #stream #streaming-media #audio-streaming
  154. fe2o3-amqp-ws

    WebSocket binding stream for AMQP1.0

    v0.13.0 3.3K #websocket #amqp #messaging #binding #amqp1 #stream #protocols
  155. tasmota-mqtt-client

    interacting with tasmota devices over MQTT

    v0.1.0 100 #devices #mqtt #mqtt-client #tasmota #ip #stream #tasmota-client
  156. 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.

    v0.1.6 270 #twitch #youtube #stream #trovo #vkplay #api-service #viewer
  157. bgp-rs

    parsing Border Gateway Protocol (BGP) formatted streams

    v0.6.0 #bgp #parser #protocols #gateway #border #message-parser #stream
  158. mostlybot

    twitch bot that I use for my stream on twitch

    v0.3.0 140 #twitch #bot #stream
  159. twitchalerts

    when it detect that a streamer is live which trigger the event handler, more features to be added

    v0.1.5 #event-handling #events #live #stream #streamer #alert #rate-limiting
  160. wasefire-protocol-tokio

    Wasefire protocol using std::io::Read and Write

    v0.1.0 #framework #protocols #wasefire #write #stream
  161. rocket-multipart

    multipart/mixed Responder implementation

    v0.2.1 #rocket #multipart #web-server #stream #response #responder #parser
  162. nimble-wrapped-step

    Nimble Wrapped Steps

    v0.0.17-dev 700 #game #step #networking #serialization #deserialize #wrapped #stream
  163. futures-stream-ext

    Asynchronous stream extensions for the futures(-core) crate

    v0.2.2 180 #async-stream #stream #async #extension #future #traits
  164. iof

    Read from and write data to console or file in simple formats

    v0.3.0 130 #input-output #input-stream #input #stream #formatted #read-write #oj
  165. nature

    development support platform, it separates data definition from code, so it decouple the data from business system

    v1.5.0 110 #data-management #platform #management #distributed #stream #data-stream #distributed-systems
  166. sea-streamer-stdio

    🌊 SeaStreamer Standard I/O Backend

    v0.5.0 2.3K #stream-processing #data-processing #async-stream #stream #async-io #async #back-end
  167. telemetry-server

    receiver of telemetry over HTTP POST/WS to sqlite3, Postgres, DuckDB or JSON files

    v0.1.0 #duck-db #postgresql #json #sqlite3 #server #storage #stream
  168. futures-ticker

    An asynchronous recurring time event

    v0.0.3 54K #recurring #future #timer #events #stream #ticker #async
  169. re_grpc_client

    gRCP client for the Rerun Data Platform gRPC prototocl

    v0.20.2 1.0K #rerun #grpc #platform #data #grpc-server #stream #client
  170. libre-url2audio-lib

    simple-to-use lib for playing audio streams

    v0.1.7 430 #audio-stream #stream #symphonia #player #audio-player #streams #audio
  171. h3i

    Low-level HTTP/3 debugging and testing

    v0.2.0 340 #http-3 #testing-debugging #quic #frame #header #low-level #stream
  172. stream-wave-parser

    The stream-wave-parser is a crate that treats a stream from WAVE file

    v0.1.2 150 #stream #wave #wav #data-stream #treat
  173. tokio-tls-upgrade

    Upgrade a TCP stream to a TLS stream using certificates and keys in PEM format

    v0.1.0 #tcp-stream #tls-stream #tls-server #tokio #tls #stream #tcp
  174. uwheel-stats

    profiling utility for uwheel

    v0.2.1 370 #profiling #aggregate #uwheel #stream #embeddable #utility #system
  175. swimos_multi_reader

    SwimOS Stream Aggregator

    v0.1.1 #swim-os #stream #stream-processing #distributed-systems #aggregator #applications #distributed-applications
  176. sea-streamer-redis

    🌊 SeaStreamer Redis Backend

    v0.5.0 2.1K #stream-processing #redis #stream #async-stream #async #async-api #async-client
  177. futures-finally

    that executes a future after the completion of a future or stream regardless of the value or outcome

    v0.1.0-alpha.2 #future #completion #stream #execute #async #another #finally
  178. stream_assert

    Macros to simplify testing of Stream based APIs

    v0.1.1 2.4K #testing #api-testing #stream #macro #assertions
  179. futures-http

    http frameworks base on futures stream

    v0.2.8 #http-framework #future #stream #base #futures-based
  180. pollable-map

    Utilites for storing futures and streams in as a pollable map

    v0.1.0-alpha.1 700 #stream #future #map #storing #pollable #utilites
  181. rlink

    High performance Stream Processing Framework

    v0.6.16 #stream-processing #stream #flink
  182. rabbitmq-stream-protocol

    AMQP 1.0 message codec

    v0.7.0 850 #rabbitmq #amqp #codec #message #stream #client #rabbitmq-client
  183. 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

    v0.9.1 #gif #image #stream #image-encoding
  184. simple-stream

    Building blocks for streaming chunks of data over io::Read and io::Write impls

    v0.11.0 180 #data-stream #stream #frame #data-streaming #frame-buffer #chunks #sockets
  185. omniqueue

    An abstraction layer over various queue backends

    v0.2.0 120 #queue #rabbitmq #abstraction-layer #sqs #back-end #redis #stream
  186. le-stream

    De-/serialize objects from/to little endian byte streams

    v0.4.3 220 #byte-stream #endian #stream #byte #little #serialization
  187. selium-server

    The server-side binary for Selium, an extremely developer friendly, composable messaging platform with zero build time configuration

    v0.5.0 #messaging #selium #build-time #streaming #stream #queue #client-server
  188. stream-reconnect

    Stream-wrapping traits/structs that automatically recover from potential disconnections/interruptions

    v0.4.0-beta.4 1.3K #stream #reconnect #retry #websocket #async-io #io
  189. squinn-proto

    State machine for the QUIC transport protocol

    v0.11.8 #quic #state-machine #connection #protocols #networking #stream #events
  190. buffer-unordered-weighted

    Stream::buffer_unordered where each future can have a different weight

    v0.1.2 3.1K #future #stream #futures #async #buffer-unordered #networking
  191. typed-websocket

    wrapper on top of websocket stream that enforces type

    v0.1.0 #websocket #stream #top #enforces #async #message #input-output
  192. kalosm-streams

    A set of streams for pretrained models in Kalosm

    v0.3.2 290 #artificial-intelligence #models #stream #kalosm #pre-trained #data-stream #local
  193. stdin-to-cloudwatch

    Send logs from stdin to AWS CloudWatch Logs

    v0.3.0 #stdin #logs #cloud-watch #aws #send #stream #group
  194. tokio-socketcan

    Asynchronous Linux SocketCAN sockets with tokio

    v0.3.1 5.8K #socket-can #tokio #linux #sockets #async #future #stream
  195. streamline

    Reversible futures::Stream-based state machines

    v0.0.7 #state-machine #stream #async-stream #future #futures #events
  196. 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

    v0.4.0 #tcp-stream #stream #pcap #tcp #tcp-udp #write-file #file-search
  197. tokio-stream_wasi

    work with Stream and tokio

    v0.1.11 #stream #async-stream #tokio #io-stream #async-io #networking #applications
  198. sea-streamer-kafka

    🌊 SeaStreamer Kafka / Redpanda Backend

    v0.5.0 2.0K #stream-processing #async-stream #kafka #stream #async #back-end #async-api
  199. unix_sock

    unix control socket abstraction

    v0.7.0 170 #unix-socket #socket-programming #control #abstraction #text #capability #stream
  200. sea-streamer-types

    🌊 SeaStreamer Traits & Types

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

    Combines skrillax-network crates to work nicely on top of a tokio tcp stream

    v0.2.0 160 #tcp-stream #stream #silkroad #tcp #tokio #read-stream #client-server
  202. tokio-process-stream

    that wraps a tokio::process into a tokio::stream

    v0.4.0 1.8K #tokio #process #stream #async-stream #data-streaming
  203. moosicbox_stream_utils

    MoosicBox stream utils package

    v0.1.0 150 #byte-stream #stream #byte #utilities #utility
  204. cstream

    libc::FILE streams β€˜c streams’

    v0.1.4 #file-io #stream #libc #ffi #no-alloc
  205. ianaio-timers

    IanaIO crate for working with JavaScript timers

    v0.1.1 #timer #future #web #callback #stream #wasm #set-timeout
  206. callbag

    spec for reactive/iterable programming

    v0.14.0 #reactive-programming #reactive #iterable #stream #observable #frp
  207. comfy-print

    Non-panicking versions of println! and friends. Async implementation.

    v0.3.0 #println #write #io #debug #error-message #io-stream #stream
  208. stream-rate-limiter

    A rate limiter for Tokio streams

    v0.4.0 430 #rate-limiting #stream #tokio #event-stream #element #delay #limiter
  209. one_liner_stats

    A small library that computes descriptive statistics (mean, median, mode, etc.) on the fly for numeric slices or streams

    v0.1.0 #mean #median #mode #compute #slice #stream #statistics
  210. async-time-mock-async-std

    Mockable time for use in async runtimes (async-std compatibility)

    v0.1.1 #async-std #mocking #testing #future #run-time #clock #stream
  211. nimble-protocol-header

    Nimble Protocol Header

    v0.0.14-dev 170 #network-protocol #time #protocols #nimble #stream #client-side #header
  212. merkle-tree-stream

    A stream that generates a merkle tree based on the incoming data

    v0.12.1 230 #merkle-tree #tree-hash #hash-tree #data-integrity #stream #data-stream #incoming
  213. fluvio-smartengine

    The official Fluvio SmartEngine

    v0.8.2 340 #data-streaming #streaming #stream #execution-engine #queue #api-bindings
  214. peekread

    Allows peeking ahead in Read streams

    v0.1.1 800 #read-stream #stream #read #peek
  215. creek-decode-symphonia

    Audio file decoding for creek

    v0.3.1 700 #audio-streaming #disk #io #stream #audio
  216. futures-io-preview

    The AsyncRead and AsyncWrite traits for the futures-rs library

    v0.3.0-alpha.19 9.0K #async-io #future #stream #traits #async-read #async-write #control-flow
  217. time-key-stream-set

    A time-keyed stream set

    v0.1.6 #stream #deduplication #key #timestamp #ordered #set #user-id
  218. futuristic

    Extensions to the futures crate

    v0.5.0 1.3K #sink #stream #future #async #asynchronous #futures #streams
  219. cj_ascii

    working with ASCII strings in Rust

    v0.2.0 #ascii #async-stream #string #stream #serialization #async
  220. wasmrs

    Base host and client implementations of the wasmRS RSocket protocol

    v0.17.0 130 #wasm-module #r-socket #protocols #stream #bidirectional #host #reactive
  221. plumbing

    An async abstraction to pipeline requests through a channel

    v1.0.0 #request-response #channel #stream #pipeline #requests #connection #tcp-connection
  222. dlwp

    The DLWP library

    v0.1.0-alpha #protocols #stream #dark-light #found #send #receive #darklight-driver
  223. scan2

    Some helpers to get the next items from an underlying stream

    v0.1.2 #stream #next #helper #items
  224. yaml-split

    iterator over individual YAML documents in a YAML file or stream

    v0.4.0 280 #yaml #document #file #stream #iterator #individual #serde-yaml
  225. preflate-rs

    Rust port of Preflate compression library

    v0.6.0 #cloud-storage #compression #deflate #binary-data #stream #decompression #reconstruction
  226. linurgy

    Manipulate the output of multiple newlines. Replace/Insert/Append newlines with text. Input and output from stdio/files/buffers

    v0.6.0 #text #newlines #text-input #text-editors #stream #line #crlf
  227. Try searching with DuckDuckGo.

  228. roux-stream

    A streaming API for the roux Reddit client

    v0.2.0 #reddit #stream #roux #api #api-bindings
  229. async-h1b

    hitdns fork of Asynchronous HTTP 1.1 parser

    v3.0.7 440 #http-parser #async-http #http #http1 #stream #async #parser
  230. lafere

    A more or less simple communication protocol library

    v0.1.0 #encryption #plain-text #how #stream
  231. jaesve

    A CLI utility for stream converting JSON objects to a series of CSV values

    v1.3.4 #json-stream #json #convert-json #csv #json-object #stream #convert
  232. crab-dlna

    A minimal UPnP/DLNA media streamer

    v0.2.1 #video #upnp #dlna #stream #networking #audio-video #audio-streaming
  233. task-stream

    a global task executor, run in no_std

    v0.3.7 #task #executor #async-executor #async-task #stream #spawn
  234. vlsm-tree

    Versioned Log Stream Merkle Tree

    v0.1.0 #merkle-tree #key-value-store #tree-structure #versioned #log #stream #authenticated
  235. menemen

    A streaming http request library

    v1.0.3 #http-client #http-request #http #request-response #streaming #stream #networking
  236. comfy-print-sync

    Non-panicking versions of println! and friends. Sync implementation.

    v0.1.1 #println #write #io-stream #debug #io #stream #error-message
  237. frappe

    Functional Reactive Programming library for Rust

    v0.4.7 #reactive-programming #functional-reactive-programming #reactive #event-stream #functional-programming #stream #frp
  238. tokio-par-stream

    parallel streams powered by tokio

    v0.1.1 #stream #tokio #parallel #powered
  239. humphrey_ws

    WebSocket support for the Humphrey web server

    v0.5.1 #websocket #web-server #humphrey #stream #messages #handshake #websocket-server
  240. subunit-rust

    A subunit v2 protocol implementation in Rust

    v0.2.0 #subunit #protocols #stream #natively #reading #interface #packet
  241. progress-streams

    Progress callbacks for types which implement Read/Write

    v1.1.0 2.6K #read-write #io-write #progress #io-read #callback #stream #read
  242. rabbitmq_http_client

    RabbitMQ HTTP API client

    v0.8.0 #http-client #rabbitmq #http-api #amqp-client #api-client #protocols #stream
  243. async-rx

    functions for async reactive programming

    v0.1.3 3.6K #reactive-programming #async #reactive #stream #batching #dedup #batch
  244. twitter-stream

    listening on Twitter Streaming API

    v0.13.0 #twitter #streaming #api-bindings #listening #stream #twitter-streaming-api #json
  245. fluvio_ws_stream_wasm

    A convenience library for using websockets in WASM

    v0.7.0 3.5K #websocket #stream #wasm #async #websockets #tokio #web-api
  246. kvarn-quinn

    Temporary Kvarn fork: Versatile QUIC transport protocol implementation

    v0.11.0-alpha1 #quic #client-server #protocols #quinn #stream #performance #udp-socket
  247. watermill

    Blazingly fast, generic, and serializable online statistics

    v0.1.1 1.8K #statistics #stream #quantile #online #stream-processing #update #serialization
  248. cudarse-npp

    High-level bindings to the CUDA NPP libraries

    v0.1.0 200 #npp #cuda #bindings #stream #ordered #calls