1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22

/*
use super::subscriber::*;
use super::publisher_sink::*;

use futures::executor::Spawn;

pub trait PubSubSpawn<Message: Clone> {
    ///
    /// Creates a new subscriber for this publisher
    /// 
    fn subscribe(&mut self) -> Subscriber<Message>;
}

///
/// For convenience, makes it possible to subscribe() to spawned publishers without having to call get_mut()
/// 
impl<Message: Clone, S: PublisherSink<Message>> PubSubSpawn<Message> for Spawn<S> {
    fn subscribe(&mut self) -> Subscriber<Message> {
        self.get_mut().subscribe()
    }
}
*/