Searched refs:clone_for_subscriber (Results 1 – 3 of 3) sorted by relevance
100 subscriber.on_subscribe(self.subscription.clone_for_subscriber()); in subscribe()
66 self.subscriber.as_mut().unwrap().on_subscribe(self.subscription.clone_for_subscriber()); in subscribe()
38 pub fn clone_for_subscriber(&self) -> Box<dyn BufferSubscription> { in clone_for_subscriber() method