Struct NodeHandlerWrapper 

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

Wraps around an implementation of ProtocolsHandler, and implements NodeHandler.

Trait Implementations

impl<TProtoHandler> ConnectionHandler for NodeHandlerWrapper<TProtoHandler>

where TProtoHandler: ProtocolsHandler,

type InEvent = <TProtoHandler as ProtocolsHandler>::InEvent

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

type OutEvent = <TProtoHandler as ProtocolsHandler>::OutEvent

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

type Error = NodeHandlerWrapperError<<TProtoHandler as ProtocolsHandler>::Error>

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

type Substream = SubstreamRef<Arc<StreamMuxerBox>>

The type of the substream containing the data.

type OutboundOpenInfo = (u64, <TProtoHandler as ProtocolsHandler>::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.