summaryrefslogtreecommitdiffstats
path: root/core/src/subscription
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/subscription')
-rw-r--r--core/src/subscription/tracker.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/core/src/subscription/tracker.rs b/core/src/subscription/tracker.rs
index 826f60c0..a942b619 100644
--- a/core/src/subscription/tracker.rs
+++ b/core/src/subscription/tracker.rs
@@ -28,14 +28,14 @@ where
}
}
- pub fn update<Message, S>(
+ pub fn update<Message, Receiver>(
&mut self,
subscription: Subscription<Hasher, Event, Message>,
- sink: S,
+ receiver: Receiver,
) -> Vec<BoxFuture<'static, ()>>
where
Message: 'static + Send,
- S: 'static
+ Receiver: 'static
+ Sink<Message, Error = core::convert::Infallible>
+ Unpin
+ Send
@@ -72,7 +72,7 @@ where
let future = futures::future::select(
cancelled,
- stream.map(Ok).forward(sink.clone()),
+ stream.map(Ok).forward(receiver.clone()),
)
.map(|_| ());