shared_stream
is a crate for easily cloneable streams.
Add this to your Cargo.toml
:
[dependencies]
shared_stream = "0.2"
Now, you can use shared_stream:
use shared_stream::Share;
let shared = stream::iter(1..=3).shared();
This crate is published under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.