Struct libp2p_core::nodes::raw_swarm::IncomingConnectionEvent
source · pub struct IncomingConnectionEvent<'a, TTrans: 'a, TInEvent: 'a, TOutEvent: 'a, THandler: 'a, THandlerErr: 'a>where
TTrans: Transport,{ /* private fields */ }Expand description
A new connection arrived on a listener.
Implementations
sourceimpl<'a, TTrans, TInEvent, TOutEvent, TMuxer, THandler, THandlerErr> IncomingConnectionEvent<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr>where
TTrans: Transport<Output = (PeerId, TMuxer)>,
TTrans::ListenerUpgrade: Send + 'static,
THandler: NodeHandler<Substream = Substream<TMuxer>, InEvent = TInEvent, OutEvent = TOutEvent, Error = THandlerErr> + Send + 'static,
THandler::OutboundOpenInfo: Send + 'static,
THandlerErr: Error + Send + 'static,
TMuxer: StreamMuxer + Send + Sync + 'static,
TMuxer::OutboundSubstream: Send,
TMuxer::Substream: Send,
TInEvent: Send + 'static,
TOutEvent: Send + 'static,
impl<'a, TTrans, TInEvent, TOutEvent, TMuxer, THandler, THandlerErr> IncomingConnectionEvent<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr>where
TTrans: Transport<Output = (PeerId, TMuxer)>,
TTrans::ListenerUpgrade: Send + 'static,
THandler: NodeHandler<Substream = Substream<TMuxer>, InEvent = TInEvent, OutEvent = TOutEvent, Error = THandlerErr> + Send + 'static,
THandler::OutboundOpenInfo: Send + 'static,
THandlerErr: Error + Send + 'static,
TMuxer: StreamMuxer + Send + Sync + 'static,
TMuxer::OutboundSubstream: Send,
TMuxer::Substream: Send,
TInEvent: Send + 'static,
TOutEvent: Send + 'static,
sourcepub fn accept(self, handler: THandler)
pub fn accept(self, handler: THandler)
Starts processing the incoming connection and sets the handler to use for it.
sourcepub fn accept_with_builder<TBuilder>(self, builder: TBuilder)where
TBuilder: FnOnce(&ConnectedPoint) -> THandler,
pub fn accept_with_builder<TBuilder>(self, builder: TBuilder)where
TBuilder: FnOnce(&ConnectedPoint) -> THandler,
Same as accept, but accepts a closure that turns a ConnectedPoint into a handler.
sourceimpl<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr> IncomingConnectionEvent<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr>where
TTrans: Transport,
impl<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr> IncomingConnectionEvent<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr>where
TTrans: Transport,
sourcepub fn listen_addr(&self) -> &Multiaddr
pub fn listen_addr(&self) -> &Multiaddr
Address of the listener that received the connection.
sourcepub fn send_back_addr(&self) -> &Multiaddr
pub fn send_back_addr(&self) -> &Multiaddr
Address used to send back data to the dialer.
sourcepub fn to_connected_point(&self) -> ConnectedPoint
pub fn to_connected_point(&self) -> ConnectedPoint
Builds the ConnectedPoint corresponding to the incoming connection.
Auto Trait Implementations
impl<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr> !RefUnwindSafe for IncomingConnectionEvent<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr>
impl<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr> Send for IncomingConnectionEvent<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr>where
THandler: Send,
THandlerErr: Send,
TInEvent: Send,
TOutEvent: Send,
<TTrans as Transport>::ListenerUpgrade: Send,
impl<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr> !Sync for IncomingConnectionEvent<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr>
impl<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr> Unpin for IncomingConnectionEvent<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr>where
<TTrans as Transport>::ListenerUpgrade: Unpin,
impl<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr> !UnwindSafe for IncomingConnectionEvent<'a, TTrans, TInEvent, TOutEvent, THandler, THandlerErr>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more