Struct carrier::endpoint::Endpoint

pub struct Endpoint { /* fields omitted */ }

Methods

impl Endpoint

pub fn new(
    poll: Poll,
    token: Token,
    noise: Transport,
    identity: Identity,
    socket: UdpSocket,
    addr: SocketAddr,
    secret: Secret
) -> Self

pub fn broker(&self) -> RoutingKey

pub fn publish(&mut self, shadow: Address)

pub fn connect(&mut self, target: Identity) -> Result<(), Error>

pub fn reject(&mut self, q: ConnectRequest)

pub fn accept_outgoing<F: 'static + StreamFactory>(
    &mut self,
    q: ConnectResponse,
    sf: F
) -> Result<RoutingKey, Error>

pub fn accept_incomming<F: 'static + StreamFactory>(
    &mut self,
    q: ConnectRequest,
    sf: F
)

pub fn open<F>(&mut self, route: RoutingKey, headers: Headers, f: F) where
    F: FnOnce(Poll, Stream) -> Task<()>, 

pub fn stream<M: Into<Vec<u8>>>(&mut self, route: RoutingKey, stream: u32, m: M)

Trait Implementations

impl Future<Result<Event, Error>> for Endpoint

fn poll(&mut self) -> FutureResult<Result<Event, Error>>