Struct tet_libp2p_swarm::protocols_handler::NodeHandlerWrapper

pub struct NodeHandlerWrapper<TProtoHandler> where
    TProtoHandler: ProtocolsHandler,  { /* fields omitted */ }

Wraps around an implementation of ProtocolsHandler, and implements NodeHandler.

Trait Implementations

impl<TProtoHandler> ConnectionHandler for NodeHandlerWrapper<TProtoHandler> where
    TProtoHandler: ProtocolsHandler, 

type InEvent = TProtoHandler::InEvent

The inbound type of events used to notify the handler through the Network.

type OutEvent = TProtoHandler::OutEvent

The outbound type of events that the handler emits to the Network through ConnectionHandler::poll.

type Error = NodeHandlerWrapperError<TProtoHandler::Error>

The type of errors that the handler can produce when polled by the Network.

type Substream = Substream<StreamMuxerBox>

The type of the substream containing the data.

type OutboundOpenInfo = (u64, TProtoHandler::OutboundOpenInfo, Duration)

Information about a substream. Can be sent to the handler through a SubstreamEndpoint, and will be passed back in inject_substream or inject_outbound_closed.

fn inject_substream(
    &mut self,
    substream: Self::Substream,
    endpoint: SubstreamEndpoint<Self::OutboundOpenInfo>
)

Sends a new substream to the handler.

fn inject_event(&mut self, event: Self::InEvent)

Notifies the handler of an event.

fn inject_address_change(&mut self, new_address: &Multiaddr)

Notifies the handler of a change in the address of the remote.

fn poll(
    &mut self,
    cx: &mut Context<'_>
) -> Poll<Result<ConnectionHandlerEvent<Self::OutboundOpenInfo, Self::OutEvent>, Self::Error>>

Polls the handler for events.