Struct libp2p::core::connection::EstablishedConnection

pub struct EstablishedConnection<'a, TInEvent, TConnInfo> { /* fields omitted */ }

An established connection in a [Pool].

Implementations

impl<'_, TInEvent, TConnInfo> EstablishedConnection<'_, TInEvent, TConnInfo>

pub fn connected(&self) -> &Connected<TConnInfo>

pub fn endpoint(&self) -> &ConnectedPoint

Returns information about the connected endpoint.

pub fn info(&self) -> &TConnInfo

Returns connection information obtained from the transport.

impl<'a, TInEvent, TConnInfo> EstablishedConnection<'a, TInEvent, TConnInfo> where
    TConnInfo: ConnectionInfo, 

pub fn id(&self) -> ConnectionId

Returns the local connection ID.

pub fn peer_id(&self) -> &<TConnInfo as ConnectionInfo>::PeerId

Returns the identity of the connected peer.

pub fn notify_handler(&mut self, event: TInEvent) -> Result<(), TInEvent>

(Asynchronously) sends an event to the connection handler.

If the handler is not ready to receive the event, either because it is busy or the connection is about to close, the given event is returned with an Err.

If execution of this method is preceded by successful execution of poll_ready_notify_handler without another intervening execution of notify_handler, it only fails if the connection is now about to close.

pub fn poll_ready_notify_handler(
    &mut self,
    cx: &mut Context<'_>
) -> Poll<Result<(), ()>>

Checks if notify_handler is ready to accept an event.

Returns Ok(()) if the handler is ready to receive an event via notify_handler.

Returns Err(()) if the background task associated with the connection is terminating and the connection is about to close.

pub fn start_close(self)

Initiates a graceful close of the connection.

Has no effect if the connection is already closing.

Trait Implementations

impl<'_, TInEvent, TConnInfo> Debug for EstablishedConnection<'_, TInEvent, TConnInfo> where
    TInEvent: Debug,
    TConnInfo: Debug, 

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

Formats the value using the given formatter.