Enum riker::protocol::IOMsg

pub enum IOMsg<Msg: Message> {
    Manage(IoType, BoxActorProd<Msg>),
    Bind(IoType, IoAddress, ActorRef<Msg>),
    Bound(IoAddress),
    Unbind,
    Unbound(IoAddress),
    Connect(IoType, IoAddress),
    Connected(IoAddress, IoAddress),
    Register(ActorRef<Msg>),
    Close,
    Closed,
    Ready,
    Write(Bytes),
    Send(IoType),
    TryRead,
    Received(Bytes),
    Flush,
    Failed(ErrorKind),
}

Variants

Manage(IoType, BoxActorProd<Msg>)

Register a connection manager for the given IoType

Bind(IoType, IoAddress, ActorRef<Msg>)

Bind on an IO type, e.g. TCP Socket

Bound(IoAddress)

Received when an IO type is bound, e.g. TCP Socket

Unbind

Unbind an IO type, e.g. TCP Socket

Unbound(IoAddress)

Received when an IO type is unbound

Connect(IoType, IoAddress)

Connect to an IoAddress, e.g. TCP/IP Address

Connected(IoAddress, IoAddress)

Received when an IO type is connected, e.g. TCP/IP Address

Register(ActorRef<Msg>)

Register given actor to receive data on a connected IoAddress

Close

Close the IO resource, e.g. disconnect from TCP/IP Address

Closed

Received when an IO resource is closed

Ready

IO resource is ready to read or write

Write(Bytes)

Write given bytes to IO resource

Send(IoType)

Currently not used

TryRead

???

Received(Bytes)

Received when IO resource reads bytes

Flush

Flush any cached data

Failed(ErrorKind)

Received when an IO operation failed, e.g. Bind and Connect

Trait Implementations

impl<Msg: Clone + Message> Clone for IOMsg<Msg>

fn clone(&self) -> IOMsg<Msg>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Msg: Message> Into<ActorMsg<Msg>> for IOMsg<Msg>

fn into(self) -> ActorMsg<Msg>

Performs the conversion.

impl<Msg: Debug + Message> Debug for IOMsg<Msg>

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.