Trait queen::node::Connector

pub trait Connector: Send + 'static {
    fn connect(
        &self, 
        slot_id: MessageId, 
        root: bool, 
        attr: Message, 
        capacity: Option<usize>, 
        timeout: Option<Duration>
    ) -> Result<Wire<Message>>;
    fn running(&self) -> bool;
}

Required methods

fn connect(
    &self,
    slot_id: MessageId,
    root: bool,
    attr: Message,
    capacity: Option<usize>,
    timeout: Option<Duration>
) -> Result<Wire<Message>>

fn running(&self) -> bool

Implementors

impl Connector for Socket