Enum mqtt::transport::Tcp
[−]
[src]
pub enum Tcp {
Server(TcpListener),
Client(TcpStream),
Connection(TcpStream, State),
}Variants
Server(TcpListener)Client(TcpStream)Connection(TcpStream, State)
Methods
impl Tcp[src]
fn server(addr: &SocketAddr, scope: &mut EarlyScope) -> Response<Self, Void>[src]
fn from_listener(
listener: TcpListener,
addr: &SocketAddr,
scope: &mut EarlyScope
) -> Response<Self, Void>[src]
listener: TcpListener,
addr: &SocketAddr,
scope: &mut EarlyScope
) -> Response<Self, Void>
fn client(
addr: &SocketAddr,
scope: &mut EarlyScope
) -> Response<(Fsm, TcpClient), Void>[src]
addr: &SocketAddr,
scope: &mut EarlyScope
) -> Response<(Fsm, TcpClient), Void>
fn from_stream(
stream: TcpStream,
addr: &SocketAddr,
scope: &mut EarlyScope
) -> Response<(Fsm, TcpClient), Void>[src]
stream: TcpStream,
addr: &SocketAddr,
scope: &mut EarlyScope
) -> Response<(Fsm, TcpClient), Void>
Trait Implementations
impl Transport for Tcp[src]
fn close(&mut self) -> Result<(), Error>[src]
fn send_packet(&mut self, _: &Packet) -> Result<(), Error>[src]
impl Machine for Tcp[src]
type Seed = TcpStream
Seed is piece of data that is needed to initialize the machine Read more
type Context = TcpContext
Context type for the state machine Read more
fn create(
conn: TcpStream,
scope: &mut Scope<TcpContext>
) -> Response<Self, Void>[src]
conn: TcpStream,
scope: &mut Scope<TcpContext>
) -> Response<Self, Void>
Create a machine from some data Read more
fn ready(
self,
events: EventSet,
scope: &mut Scope<TcpContext>
) -> Response<Self, Self::Seed>[src]
self,
events: EventSet,
scope: &mut Scope<TcpContext>
) -> Response<Self, Self::Seed>
Socket readiness notification
fn spawned(self, _: &mut Scope<TcpContext>) -> Response<Self, Self::Seed>[src]
Called after spawn event Read more
fn timeout(self, _: &mut Scope<TcpContext>) -> Response<Self, Self::Seed>[src]
Timeout happened
fn wakeup(self, _: &mut Scope<TcpContext>) -> Response<Self, Self::Seed>[src]
Message received Read more
fn spawn_error(
self,
_scope: &mut Scope<Self::Context>,
error: SpawnError<Self::Seed>
) -> Response<Self, Self::Seed>[src]
self,
_scope: &mut Scope<Self::Context>,
error: SpawnError<Self::Seed>
) -> Response<Self, Self::Seed>
Called instead of spawned, if there is no slab space Read more