me/iced
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Update sipper and relax Send requirements

Browse source
This commit is contained in:
Héctor Ramón Jiménez 2025-02-09 21:05:42 +01:00
parent c8981d0096
commit 7ba2e39133
No known key found for this signature in database
GPG key ID: 7CC46565708259A7
3 changed files with 9 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

5
Cargo.lock generated
View file

@ -5230,11 +5230,12 @@ checksum = "56199f7ddabf13fe5074ce809e7d3f42b42ae711800501b5b16ea82ad029c39d"
[[package]] [[package]]
name = "sipper" name = "sipper"
version = "0.0.4" version = "0.0.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d936de9741a68cb9452b683ffcc1fce44be7a79446ac5918319a42738da2d165" checksum = "273c7573677e3835339763d44dd6ee0683b92108d04b311108809e9819f4bc13"
dependencies = [ dependencies = [
"futures", "futures",
"pin-project-lite",
] ]
[[package]] [[package]]

2
Cargo.toml
View file

@ -172,7 +172,7 @@ raw-window-handle = "0.6"
resvg = "0.42" resvg = "0.42"
rustc-hash = "2.0" rustc-hash = "2.0"
sha2 = "0.10" sha2 = "0.10"
sipper = "0.0.4" sipper = "0.0.5"
smol = "1.0" smol = "1.0"
smol_str = "0.2" smol_str = "0.2"
softbuffer = "0.4" softbuffer = "0.4"

13
runtime/src/task.rs
View file

@ -63,18 +63,15 @@ impl<T> Task<T> {
/// progress with the first closure and the output with the second one. /// progress with the first closure and the output with the second one.
pub fn sip<S, Output, Progress>( pub fn sip<S, Output, Progress>(
sipper: S, sipper: S,
on_progress: impl Fn(Progress) -> T + Send + 'static, on_progress: impl Fn(Progress) -> T + MaybeSend + 'static,
on_output: impl FnOnce(Output) -> T + Send + 'static, on_output: impl FnOnce(Output) -> T + MaybeSend + 'static,
) -> Self ) -> Self
where where
S: Sipper<Output, Progress> + Send + 'static, S: Sipper<Output, Progress> + MaybeSend + 'static,
S::Future: Send + 'static, T: MaybeSend + 'static,
Output: Send,
Progress: Send,
T: Send + 'static,
{ {
Self::stream(stream(sipper::sipper(move |sender| async move { Self::stream(stream(sipper::sipper(move |sender| async move {
on_output(sipper.map(on_progress).run(sender).await) on_output(sipper.with(on_progress).run(sender).await)
}))) })))
} }