#async #streams

streem

Simple utilities for creating and consuming streams

3 unstable releases

0.2.0 Sep 11, 2023
0.1.1 Sep 9, 2023
0.1.0 Sep 9, 2023

#991 in Asynchronous

Download history 51/week @ 2023-10-20 46/week @ 2023-10-27 46/week @ 2023-11-03 132/week @ 2023-11-10 44/week @ 2023-11-17 129/week @ 2023-11-24 43/week @ 2023-12-01 292/week @ 2023-12-08 148/week @ 2023-12-15 306/week @ 2023-12-22 136/week @ 2023-12-29 180/week @ 2024-01-05 240/week @ 2024-01-12 316/week @ 2024-01-19 249/week @ 2024-01-26 324/week @ 2024-02-02

1,162 downloads per month
Used in 4 crates (3 directly)

GPL-3.0 license

19KB
262 lines

Streem

A simple library for creating and consuming async streams

Usage

Add to your Cargo.toml

$ cargo add streem

Use in your application

use streem::IntoStreamer;

fn from_iter<I>(iter: impl IntoIterator<Item = I>) -> impl futures_core::Stream<Item = I>
where
    I: 'static,
{
    streem::from_fn(|yielder| async move {
        for i in iter {
            yielder.yield_(i).await;
        }
    })
}

fn main() {
    futures_executor::block_on(async {
        let stream = std::pin::pin!(from_iter(0..10));

        let mut streamer = stream.into_streamer();

        while let Some(item) = streamer.next().await {
            println!("Yielded {item}");
        }
    })
}

Contributing

Feel free to open issues for anything you find an issue with. Please note that any contributed code will be licensed under the GPLv3.

License

Copyright © 2023 asonix

Streem is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

Streem is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. This file is part of Streem.

You should have received a copy of the GNU General Public License along with Streem. If not, see http://www.gnu.org/licenses/.

Dependencies

~68KB