Struct EdgeConnectionInstance 

pub struct EdgeConnectionInstance {
    pub config: ConnectionConfig,
    pub outbound: UnboundedSender<EdgePayload>,
    pub alive: Arc<AtomicBool>,
    pub peer_id: NodeId,
    pub finish_signal: Arc<Notify>,
}

Fields

config: ConnectionConfig

outbound: UnboundedSender<EdgePayload>

alive: Arc<AtomicBool>

peer_id: NodeId

finish_signal: Arc<Notify>

Implementations

impl EdgeConnectionInstance

pub fn is_alive(&self) -> bool

pub fn get_connection_ref(self: &Arc<Self>) -> EdgeConnectionRef

pub fn send_payload( &self, packet: EdgePayload, ) -> Result<(), EdgeConnectionError>

pub fn push_message( &self, endpoint: &EndpointAddr, message: Message, ) -> Result<(), EdgeConnectionError>

pub async fn init<C: EdgeNodeConnection>( config: ConnectionConfig, connection: C, ) -> Result<Self, EdgeConnectionError>

Trait Implementations

impl Debug for EdgeConnectionInstance

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

Formats the value using the given formatter.