Struct libp2p::core::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> NodeHandler for NodeHandlerWrapper<TProtoHandler> where
    TProtoHandler: ProtocolsHandler,
    <<TProtoHandler as ProtocolsHandler>::OutboundProtocol as OutboundUpgrade<<TProtoHandler as ProtocolsHandler>::Substream>>::Error: Debug, 

type InEvent = <TProtoHandler as ProtocolsHandler>::InEvent

Custom event that can be received from the outside.

type OutEvent = <TProtoHandler as ProtocolsHandler>::OutEvent

Custom event that can be produced by the handler and that will be returned by the swarm.

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

Error that can happen during the processing of the node.

type Substream = <TProtoHandler as ProtocolsHandler>::Substream

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 NodeHandlerEndpoint, and will be passed back in inject_substream or inject_outbound_closed.

fn inject_substream(
    &mut self,
    substream: <NodeHandlerWrapper<TProtoHandler> as NodeHandler>::Substream,
    endpoint: NodeHandlerEndpoint<<NodeHandlerWrapper<TProtoHandler> as NodeHandler>::OutboundOpenInfo>
)

Sends a new substream to the handler.

fn inject_event(
    &mut self,
    event: <NodeHandlerWrapper<TProtoHandler> as NodeHandler>::InEvent
)

Injects an event coming from the outside into the handler.

fn poll(
    &mut self
) -> Result<Async<NodeHandlerEvent<<NodeHandlerWrapper<TProtoHandler> as NodeHandler>::OutboundOpenInfo, <NodeHandlerWrapper<TProtoHandler> as NodeHandler>::OutEvent>>, <NodeHandlerWrapper<TProtoHandler> as NodeHandler>::Error>

Should behave like Stream::poll().