Ext: MutableVecExt::feed and feed_cloned added

CHANGELOG.md

@@ -4,6 +4,12 @@ All notable changes to this project will be documented in this file. The
 format is based on [Keep a Changelog], and this project aims to follow
 [Semantic Versioning].
 
+## [0.5.1] - 2025-01-11
+
+### Added
+
+- `feed` and `feed_cloned` added to `MutableVecExt`
+
 ## [0.4.0] - 2024-05-07
 
 ### Changed

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "futures-signals-ext"
-version = "0.5.0"
+version = "0.5.1"
 authors = ["martin.kolarik@smartcontrol.cz"]
 description = "Extension to futures-signals: MutableOption with combinators, spawning, predicate driven selections from SignalVec."
 edition = "2024"

src/ext.rs

@@ -15,7 +15,7 @@ use std::{
     task::{Context, Poll},
 };
 
-use crate::MutableVecEntry;
+use crate::{MutableVecEntry, SignalVecSpawn};
 
 pub trait MutableExt<A> {
     fn inspect(&self, f: impl FnOnce(&A));
@@ -203,6 +203,14 @@ pub trait MutableVecExt<A> {
         F: FnMut(&A) -> K,
         K: Eq + Hash;
 
+    fn feed(&self, source: impl SignalVec<Item = A> + 'static)
+    where
+        A: Copy + 'static;
+
+    fn feed_cloned(&self, source: impl SignalVec<Item = A> + 'static)
+    where
+        A: Clone + 'static;
+
     fn signal_vec_filter<P>(&self, p: P) -> Filter<MutableSignalVec<A>, P>
     where
         A: Copy,
@@ -508,6 +516,26 @@ impl<A> MutableVecExt<A> for MutableVec<A> {
         extended
     }
 
+    fn feed(&self, source: impl SignalVec<Item = A> + 'static)
+    where
+        A: Copy + 'static,
+    {
+        let this = self.clone();
+        source.spawn_local(move |diff| {
+            MutableVecLockMut::apply_vec_diff(&mut this.lock_mut(), diff);
+        });
+    }
+
+    fn feed_cloned(&self, source: impl SignalVec<Item = A> + 'static)
+    where
+        A: Clone + 'static,
+    {
+        let this = self.clone();
+        source.spawn_local(move |diff| {
+            MutableVecLockMut::apply_vec_diff(&mut this.lock_mut(), diff);
+        });
+    }
+
     fn signal_vec_filter<P>(&self, p: P) -> Filter<MutableSignalVec<A>, P>
     where
         A: Copy,