cleslie/suck
1
0
Fork 0
mirror of https://github.com/callumio/suck.git synced 2025-12-19 20:39:21 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Relax T: Clone bound to only apply to static values
Some checks failed
CI / Run tests (push) Has been cancelled
Details
CI / Lint (push) Has been cancelled
Details
Release-plz / Release-plz release (push) Has been cancelled
Details
Release-plz / Release-plz PR (push) Has been cancelled
Details

Browse source
This commit is contained in:
Roman Moisieiev 2025-10-09 11:02:20 +01:00 • committed by Callum Leslie
parent 7c8fc42f27
commit 4c13facc96
2 changed files with 17 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

20
src/channel.rs
View file

@ -63,13 +63,19 @@ where
impl<T, SR, ST> Sourcer<T, SR, ST>
where
T: Clone + Send + 'static,
T: Send + 'static,
SR: ChannelReceiver<Request>,
ST: ChannelSender<Response<T>>,
{
/// Set a fixed value
pub fn set_static(&self, value: T) -> Result<(), Error> {
self.state.swap(Arc::new(ValueSource::Static(value)));
pub fn set_static(&self, val: T) -> Result<(), Error>
where
T: Clone,
{
self.state.swap(Arc::new(ValueSource::Static {
val,
clone: T::clone,
}));
Ok(())
}
@ -130,7 +136,13 @@ where
let state = self.state.load();
match &**state {
ValueSource::Static(value) => Ok(Response::Value(value.clone())),
ValueSource::Static { val, clone } => {
let value = self.execute_closure_safely(&mut || clone(val));
match value {
Ok(v) => Ok(Response::Value(v)),
Err(_) => Ok(Response::NoSource), // Closure execution failed
}
}
ValueSource::Dynamic(closure) => {
let value = self.execute_closure_safely(&mut || closure());
match value {