pub enum RequestResponseEvent<TRequest, TResponse, TChannelResponse = TResponse> {
Message {
peer: PeerId,
message: RequestResponseMessage<TRequest, TResponse, TChannelResponse>,
},
OutboundFailure {
peer: PeerId,
request_id: RequestId,
error: OutboundFailure,
},
InboundFailure {
peer: PeerId,
request_id: RequestId,
error: InboundFailure,
},
ResponseSent {
peer: PeerId,
request_id: RequestId,
},
}
Expand description
The events emitted by a RequestResponse
protocol.
Variants
Message
Fields
peer: PeerId
The peer who sent the message.
message: RequestResponseMessage<TRequest, TResponse, TChannelResponse>
The incoming message.
An incoming message (request or response).
OutboundFailure
Fields
peer: PeerId
The peer to whom the request was sent.
request_id: RequestId
The (local) ID of the failed request.
error: OutboundFailure
The error that occurred.
An outbound request failed.
InboundFailure
Fields
peer: PeerId
The peer from whom the request was received.
request_id: RequestId
The ID of the failed inbound request.
error: InboundFailure
The error that occurred.
An inbound request failed.
ResponseSent
Fields
peer: PeerId
The peer to whom the response was sent.
request_id: RequestId
The ID of the inbound request whose response was sent.
A response to an inbound request has been sent.
When this event is received, the response has been flushed on the underlying transport connection.
Trait Implementations
Auto Trait Implementations
impl<TRequest, TResponse, TChannelResponse = TResponse> !RefUnwindSafe for RequestResponseEvent<TRequest, TResponse, TChannelResponse>
impl<TRequest, TResponse, TChannelResponse> Send for RequestResponseEvent<TRequest, TResponse, TChannelResponse> where
TChannelResponse: Send,
TRequest: Send,
TResponse: Send,
impl<TRequest, TResponse, TChannelResponse> Sync for RequestResponseEvent<TRequest, TResponse, TChannelResponse> where
TChannelResponse: Send,
TRequest: Sync,
TResponse: Sync,
impl<TRequest, TResponse, TChannelResponse> Unpin for RequestResponseEvent<TRequest, TResponse, TChannelResponse> where
TRequest: Unpin,
TResponse: Unpin,
impl<TRequest, TResponse, TChannelResponse = TResponse> !UnwindSafe for RequestResponseEvent<TRequest, TResponse, TChannelResponse>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more