helpers for creating and consuming streams
Go to file
2023-09-10 20:38:05 -04:00
examples Rename to streem 2023-09-09 16:31:37 -04:00
src clippy 2023-09-10 20:38:05 -04:00
.gitignore initial commit 2023-09-09 15:51:10 -04:00
Cargo.toml Move putting item in side-channel to Giver poll 2023-09-10 20:34:58 -04:00
flake.lock initial commit 2023-09-09 15:51:10 -04:00
flake.nix Rename to streem 2023-09-09 16:31:37 -04:00
LICENSE Add docs, license, enforce Unpin when creating Streamer 2023-09-09 16:25:25 -04:00 Fix name in readme 2023-09-09 16:52:11 -04:00


A simple library for creating and consuming async streams


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>
    I: 'static,
    streem::from_fn(|yielder| async move {
        for i in iter {

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) = {
            println!("Yielded {item}");


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


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