1
2
3
4
5
6
7
8
9
10
11
12
13
14

use super::subscriber::*;
use futures::*;

///
/// Trait implemented by sinks that act as a publisher
/// 
pub trait PublisherSink<Message> : Sink<SinkItem=Message, SinkError=()> {
    ///
    /// Creates a subscription to this publisher
    /// 
    /// Any future messages sent here will also be sent to this subscriber.
    /// 
    fn subscribe(&mut self) -> Subscriber<Message>;
}