Enum libp2p_request_response::handler::Event

pub enum Event<TCodec>where
    TCodec: Codec,{
    Request {
        request_id: RequestId,
        request: TCodec::Request,
        sender: Sender<TCodec::Response>,
    },
    Response {
        request_id: RequestId,
        response: TCodec::Response,
    },
    ResponseSent(RequestId),
    ResponseOmission(RequestId),
    OutboundTimeout(RequestId),
    OutboundUnsupportedProtocols(RequestId),
    InboundTimeout(RequestId),
    InboundUnsupportedProtocols(RequestId),
}

Expand description

The events emitted by the Handler.

Variants§

Request

A request has been received.

Fields

§request_id: RequestId

§request: TCodec::Request

§sender: Sender<TCodec::Response>

Response

A response has been received.

Fields

§request_id: RequestId

§response: TCodec::Response

ResponseSent(RequestId)

A response to an inbound request has been sent.

ResponseOmission(RequestId)

A response to an inbound request was omitted as a result of dropping the response sender of an inbound Request.

OutboundTimeout(RequestId)

An outbound request timed out while sending the request or waiting for the response.

OutboundUnsupportedProtocols(RequestId)

An outbound request failed to negotiate a mutually supported protocol.

InboundTimeout(RequestId)

An inbound request timed out while waiting for the request or sending the response.

InboundUnsupportedProtocols(RequestId)

An inbound request failed to negotiate a mutually supported protocol.

Trait Implementations§

impl<TCodec: Codec> Debug for Event<TCodec>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

impl<TCodec> Freeze for Event<TCodec>
where <TCodec as Codec>::Request: Freeze, <TCodec as Codec>::Response: Freeze,

impl<TCodec> !RefUnwindSafe for Event<TCodec>

impl<TCodec> Send for Event<TCodec>

impl<TCodec> Sync for Event<TCodec>
where <TCodec as Codec>::Request: Sync, <TCodec as Codec>::Response: Sync,

impl<TCodec> Unpin for Event<TCodec>
where <TCodec as Codec>::Request: Unpin, <TCodec as Codec>::Response: Unpin,

impl<TCodec> !UnwindSafe for Event<TCodec>

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Same for T

type Output = T

Should always be Self

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more