diff --git a/runtime/src/task.rs b/runtime/src/task.rs index 989f0ed5..bfc36d75 100644 --- a/runtime/src/task.rs +++ b/runtime/src/task.rs @@ -61,13 +61,13 @@ impl Task { /// Creates a [`Task`] that runs the given [`Sipper`] to completion, mapping /// progress with the first closure and the output with the second one. - pub fn sip( + pub fn sip( sipper: S, - on_progress: impl Fn(Progress) -> T + MaybeSend + 'static, - on_output: impl FnOnce(Output) -> T + MaybeSend + 'static, + on_progress: impl Fn(S::Progress) -> T + MaybeSend + 'static, + on_output: impl FnOnce(::Output) -> T + MaybeSend + 'static, ) -> Self where - S: Sipper + MaybeSend + 'static, + S: sipper::Core + MaybeSend + 'static, T: MaybeSend + 'static, { Self::stream(stream(sipper::sipper(move |sender| async move {