Struct carrier::endpoint::Endpoint

pub struct Endpoint { /* fields omitted */ }

Methods

impl Endpoint

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

pub fn handle(&self) -> Handle

pub fn broker(&self) -> RoutingKey

pub fn xsecret(&mut self) -> Secret

pub fn publish<F>(&mut self, shadow: Address, on_close: F) -> Result<u32, Error> where
    F: 'static + FnOnce(), 

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

pub fn disconnect(
    &mut self,
    route: RoutingKey,
    reason: DisconnectReason
) -> Result<(), Error>

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

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,
    max_fragments: Option<u32>,
    f: F
) -> Result<u32, Error> where
    F: FnOnce(Poll, Stream) -> Task<()>, 

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

Trait Implementations

impl Drop for Endpoint

fn drop(&mut self)

Executes the destructor for this type.

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

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