Trait libp2p_core::connection::ConnectionHandler[−][src]

pub trait ConnectionHandler {
    type InEvent;
    type OutEvent;
    type Error;
    type Substream;
    type OutboundOpenInfo;
    fn inject_substream(
        &mut self, 
        substream: Self::Substream, 
        endpoint: SubstreamEndpoint<Self::OutboundOpenInfo>
    );

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

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

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

The interface of a connection handler.

Each handler is responsible for a single connection.

Associated Types

type InEvent[src]

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

See also EstablishedConnection::notify_handler and ConnectionHandler::inject_event.

type OutEvent[src]

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

See also NetworkEvent::ConnectionEvent.

type Error[src]

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

type Substream[src]

The type of the substream containing the data.

type OutboundOpenInfo[src]

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.

Loading content...

Required methods

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

Sends a new substream to the handler.

The handler is responsible for upgrading the substream to whatever protocol it wants.

Panic

Implementations are allowed to panic in the case of dialing if the user_data in endpoint doesn't correspond to what was returned earlier when polling, or is used multiple times.

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

Notifies the handler of an event.

fn inject_address_change(&mut self, new_address: &Multiaddr)[src]

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>>[src]

Polls the handler for events.

Returning an error will close the connection to the remote.

Loading content...

Implementors

Loading content...