#async-io #async-stream #async #concurrency #byte #shared-data #io

streamcatcher

A thread-safe, shared (asynchronous), almost-lockless stream buffer

5 releases (2 stable)

1.0.1 Dec 27, 2021
1.0.0 Aug 31, 2021
0.1.1 Aug 31, 2021
0.1.0 Sep 27, 2020
0.0.1 Aug 17, 2020

#724 in Asynchronous

Download history 837/week @ 2024-06-14 876/week @ 2024-06-21 622/week @ 2024-06-28 704/week @ 2024-07-05 949/week @ 2024-07-12 841/week @ 2024-07-19 919/week @ 2024-07-26 818/week @ 2024-08-02 1314/week @ 2024-08-09 927/week @ 2024-08-16 840/week @ 2024-08-23 924/week @ 2024-08-30 914/week @ 2024-09-06 731/week @ 2024-09-13 777/week @ 2024-09-20 728/week @ 2024-09-27

3,264 downloads per month
Used in 2 crates

MIT/Apache

56KB
1K SLoC

docs-badge crates.io version crates.io downloads license build badge

Streamcatcher

A Rust thread-safe, shared (asynchronous) stream buffer designed to lock only on accessing and storing new data.

Streamcatcher is designed to allow seeking on otherwise one-way streams (e.g., command output) whose output needs to be accessed by many threads without constant reallocations, contention over safe read-only data, or unnecessary stalling. Only threads who read in new data ever need to lock the data structure, and do not prevent earlier reads from occurring.

Features

  • Lockless access to pre-read data and finished streams.
  • Transparent caching of newly read data.
  • Allows seeking on read-only bytestreams.
  • Piecewise allocation to reduce copying and support unknown input lengths.
  • Optional acceleration of reads on stream completion by copying to a single backing store.
  • (Stateful) bytestream transformations.
  • Async support with the "async" feature, and runtimes via ["async-std-compat", "smol-compat", "tokio-compat"].

The main algorithm is outlined in this blog post, with rope reference tracking moved to occur only in the core.

License

Licensed under either of

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

Detailed guidelines are given in the CONTRIBUTING file.

Dependencies

~0.6–34MB
~465K SLoC