Struct Connection

pub struct Connection {
    pub(crate) direction: ConnDirection,
    conn: Conn<NetMsg, Error>,
    disconnect_signal: Sender<Result<()>>,
    protocol_events: Arc<EventEmitter<ProtocolID>>,
    pub(crate) remote_endpoint: Endpoint,
    listeners: HashMap<ProtocolID, EventListener<ProtocolID, ProtocolEvent>>,
}

Fields

direction: ConnDirection

conn: Conn<NetMsg, Error>

disconnect_signal: Sender<Result<()>>

protocol_events: Arc<EventEmitter<ProtocolID>>

EventEmitter responsible for sending events to the registered protocols.

remote_endpoint: Endpoint

listeners: HashMap<ProtocolID, EventListener<ProtocolID, ProtocolEvent>>

Implementations

impl Connection

pub fn new( conn: Conn<NetMsg, Error>, signal: Sender<Result<()>>, direction: ConnDirection, remote_endpoint: Endpoint, ) -> Self

pub async fn send<T: Encode>( &self, protocol_id: ProtocolID, msg: T, ) -> Result<()>

pub async fn recv<P: Protocol>(&self) -> Result<ProtocolEvent>

pub async fn register_protocol(&mut self, protocol_id: String)

Registers a listener for the given Protocol P.

pub async fn emit_msg( &self, id: &ProtocolID, event: &ProtocolEvent, ) -> Result<()>

pub async fn recv_inner(&self) -> Result<NetMsg>

pub async fn send_inner(&self, msg: NetMsg) -> Result<()>

pub async fn disconnect(&self, res: Result<()>) -> Result<()>