diff options
Diffstat (limited to 'core/src/subscription')
-rw-r--r-- | core/src/subscription/tracker.rs | 8 |
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(|_| ()); |