Add vec cache shortcut

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "renoir"
 description = "Reactive Network of Operators In Rust"
-version = "0.2.0"
+version = "0.3.0"
 edition = "2021"
 authors = [
     "Luca De Martini <[email protected]>",

src/operator/mod.rs

@@ -8,7 +8,7 @@ use std::fmt::Display;
 use std::hash::Hash;
 use std::ops::{AddAssign, Div};
 
-use cache::{CacheRegistry, CacheSink, CachedStream, Cacher};
+use cache::{CacheRegistry, CacheSink, CachedStream, Cacher, VecCacher};
 use flume::{unbounded, Receiver};
 #[cfg(feature = "tokio")]
 use futures::Future;
@@ -2120,6 +2120,14 @@ where
         CachedStream::new(rt_config, replication, output)
     }
 
+    /// Collect the output of the stream to a [StreamCache] that can later be resumed to
+    /// create a [Stream] with its content. Returns the cache and consumes the stream.
+    ///
+    /// **See [Stream::collect_cache]**
+    pub fn collect_cache_vec(self) -> CachedStream<I, VecCacher<I>> {
+        self.collect_cache(())
+    }
+
     /// Collect the output of the stream to a [StreamCache] that can later be resumed to
     /// create a [Stream] with its content. Returns the cache and a copy of the current stream.
     ///
@@ -2168,6 +2176,19 @@ where
             splits.pop().unwrap(),
         )
     }
+
+    /// Collect the output of the stream to a [StreamCache] that can later be resumed to
+    /// create a [Stream] with its content. Returns the cache and a copy of the current stream.
+    ///
+    /// **See [Stream::cache]**
+    pub fn cache_vec(
+        self,
+    ) -> (
+        CachedStream<I, VecCacher<I>>,
+        Stream<impl Operator<Out = Op::Out>>,
+    ) {
+        self.cache(())
+    }
 }
 
 impl<Op> Stream<Op>