Struct libp2p_core::connection::EstablishedConnection [−][src]
An established connection in a pool.
Implementations
impl<TInEvent> EstablishedConnection<'_, TInEvent>[src]
pub fn connected(&self) -> &Connected[src]
pub fn endpoint(&self) -> &ConnectedPoint[src]
Returns information about the connected endpoint.
pub fn peer_id(&self) -> PeerId[src]
Returns the identity of the connected peer.
pub fn id(&self) -> ConnectionId[src]
Returns the local connection ID.
pub fn notify_handler(&mut self, event: TInEvent) -> Result<(), TInEvent>[src]
(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<(), ()>>[src]
&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)[src]
Initiates a graceful close of the connection.
Has no effect if the connection is already closing.
Trait Implementations
impl<TInEvent> Debug for EstablishedConnection<'_, TInEvent> where
TInEvent: Debug, [src]
TInEvent: Debug,
Auto Trait Implementations
impl<'a, TInEvent> !RefUnwindSafe for EstablishedConnection<'a, TInEvent>[src]
impl<'a, TInEvent> Send for EstablishedConnection<'a, TInEvent> where
TInEvent: Send, [src]
TInEvent: Send,
impl<'a, TInEvent> Sync for EstablishedConnection<'a, TInEvent> where
TInEvent: Send, [src]
TInEvent: Send,
impl<'a, TInEvent> Unpin for EstablishedConnection<'a, TInEvent>[src]
impl<'a, TInEvent> !UnwindSafe for EstablishedConnection<'a, TInEvent>[src]
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,