Crate clone_stream 

Clone streams with clone-stream

Turn any Stream into a cloneable stream where each clone receives all items independently.

The CloneStream struct implements Clone + Stream, allowing you to create multiple independent consumers of the same data. The ForkStream trait provides the entry point for converting regular streams.

Quick Start

use clone_stream::ForkStream;
use futures::{StreamExt, stream};

let stream = stream::iter(vec![1, 2, 3]).fork();
let mut clone1 = stream.clone();
let mut clone2 = stream.clone();
// Both clones receive all items independently

Modules

clean_log

ring_queue

Structs

CloneStream

A stream that implements Clone and returns cloned items from a base stream.

ForkConfig

Enums

CloneStreamError

Errors that can occur when working with cloned streams

Traits

ForkStream

Extension trait to make any Stream cloneable.

Type Aliases

Result