pub struct RequestResponse<TCodec>where
TCodec: RequestResponseCodec,{ /* private fields */ }
Expand description
A request/response protocol for some message codec.
Implementations§
Source§impl<TCodec> RequestResponse<TCodec>where
TCodec: RequestResponseCodec + Clone,
impl<TCodec> RequestResponse<TCodec>where
TCodec: RequestResponseCodec + Clone,
Sourcepub fn new<I>(codec: TCodec, protocols: I, cfg: RequestResponseConfig) -> Self
pub fn new<I>(codec: TCodec, protocols: I, cfg: RequestResponseConfig) -> Self
Creates a new RequestResponse
behaviour for the given
protocols, codec and configuration.
Sourcepub fn throttled<I>(
c: TCodec,
protos: I,
cfg: RequestResponseConfig,
) -> Throttled<TCodec>where
I: IntoIterator<Item = (TCodec::Protocol, ProtocolSupport)>,
TCodec: Send,
TCodec::Protocol: Sync,
pub fn throttled<I>(
c: TCodec,
protos: I,
cfg: RequestResponseConfig,
) -> Throttled<TCodec>where
I: IntoIterator<Item = (TCodec::Protocol, ProtocolSupport)>,
TCodec: Send,
TCodec::Protocol: Sync,
Creates a RequestResponse
which limits requests per peer.
The behaviour is wrapped in Throttled
and detects the limits
per peer at runtime which are then enforced.
Sourcepub fn send_request(
&mut self,
peer: &PeerId,
request: TCodec::Request,
) -> RequestId
pub fn send_request( &mut self, peer: &PeerId, request: TCodec::Request, ) -> RequestId
Initiates sending a request.
If the targeted peer is currently not connected, a dialing attempt is initiated and the request is sent as soon as a connection is established.
Note: In order for such a dialing attempt to succeed, the
RequestResonse
protocol must either be embedded in anotherNetworkBehaviour
that provides peer and address discovery, or known addresses of peers must be managed viaRequestResponse::add_address
andRequestResponse::remove_address
.
Sourcepub fn send_response(
&mut self,
ch: ResponseChannel<TCodec::Response>,
rs: TCodec::Response,
) -> Result<(), TCodec::Response>
pub fn send_response( &mut self, ch: ResponseChannel<TCodec::Response>, rs: TCodec::Response, ) -> Result<(), TCodec::Response>
Initiates sending a response to an inbound request.
If the ResponseChannel
is already closed due to a timeout or the
connection being closed, the response is returned as an Err
for
further handling. Once the response has been successfully sent on the
corresponding connection, RequestResponseEvent::ResponseSent
is
emitted. In all other cases RequestResponseEvent::InboundFailure
will be or has been emitted.
The provided ResponseChannel
is obtained from an inbound
RequestResponseMessage::Request
.
Sourcepub fn add_address(&mut self, peer: &PeerId, address: Multiaddr)
pub fn add_address(&mut self, peer: &PeerId, address: Multiaddr)
Adds a known address for a peer that can be used for
dialing attempts by the Swarm
, i.e. is returned
by NetworkBehaviour::addresses_of_peer
.
Addresses added in this way are only removed by remove_address
.
Sourcepub fn remove_address(&mut self, peer: &PeerId, address: &Multiaddr)
pub fn remove_address(&mut self, peer: &PeerId, address: &Multiaddr)
Removes an address of a peer previously added via add_address
.
Sourcepub fn is_connected(&self, peer: &PeerId) -> bool
pub fn is_connected(&self, peer: &PeerId) -> bool
Checks whether a peer is currently connected.
Sourcepub fn is_pending_outbound(&self, peer: &PeerId, request_id: &RequestId) -> bool
pub fn is_pending_outbound(&self, peer: &PeerId, request_id: &RequestId) -> bool
Checks whether an outbound request to the peer with the provided
PeerId
initiated by RequestResponse::send_request
is still
pending, i.e. waiting for a response.
Sourcepub fn is_pending_inbound(&self, peer: &PeerId, request_id: &RequestId) -> bool
pub fn is_pending_inbound(&self, peer: &PeerId, request_id: &RequestId) -> bool
Checks whether an inbound request from the peer with the provided
PeerId
is still pending, i.e. waiting for a response by the local
node through RequestResponse::send_response
.
Trait Implementations§
Source§impl<TCodec> NetworkBehaviour for RequestResponse<TCodec>
impl<TCodec> NetworkBehaviour for RequestResponse<TCodec>
Source§type ProtocolsHandler = RequestResponseHandler<TCodec>
type ProtocolsHandler = RequestResponseHandler<TCodec>
Source§type OutEvent = RequestResponseEvent<<TCodec as RequestResponseCodec>::Request, <TCodec as RequestResponseCodec>::Response>
type OutEvent = RequestResponseEvent<<TCodec as RequestResponseCodec>::Request, <TCodec as RequestResponseCodec>::Response>
NetworkBehaviour
and that the swarm will report back.Source§fn new_handler(&mut self) -> Self::ProtocolsHandler
fn new_handler(&mut self) -> Self::ProtocolsHandler
ProtocolsHandler
for a connection with a peer. Read moreSource§fn addresses_of_peer(&mut self, peer: &PeerId) -> Vec<Multiaddr>
fn addresses_of_peer(&mut self, peer: &PeerId) -> Vec<Multiaddr>
Source§fn inject_connected(&mut self, peer: &PeerId)
fn inject_connected(&mut self, peer: &PeerId)
Source§fn inject_connection_established(
&mut self,
peer: &PeerId,
conn: &ConnectionId,
endpoint: &ConnectedPoint,
)
fn inject_connection_established( &mut self, peer: &PeerId, conn: &ConnectionId, endpoint: &ConnectedPoint, )
Source§fn inject_connection_closed(
&mut self,
peer_id: &PeerId,
conn: &ConnectionId,
_: &ConnectedPoint,
)
fn inject_connection_closed( &mut self, peer_id: &PeerId, conn: &ConnectionId, _: &ConnectedPoint, )
Source§fn inject_disconnected(&mut self, peer: &PeerId)
fn inject_disconnected(&mut self, peer: &PeerId)
Source§fn inject_dial_failure(&mut self, peer: &PeerId)
fn inject_dial_failure(&mut self, peer: &PeerId)
Source§fn inject_event(
&mut self,
peer: PeerId,
connection: ConnectionId,
event: RequestResponseHandlerEvent<TCodec>,
)
fn inject_event( &mut self, peer: PeerId, connection: ConnectionId, event: RequestResponseHandlerEvent<TCodec>, )
peer_id
.
for the behaviour. Read moreSource§fn poll(
&mut self,
_: &mut Context<'_>,
_: &mut impl PollParameters,
) -> Poll<NetworkBehaviourAction<RequestProtocol<TCodec>, RequestResponseEvent<TCodec::Request, TCodec::Response>>>
fn poll( &mut self, _: &mut Context<'_>, _: &mut impl PollParameters, ) -> Poll<NetworkBehaviourAction<RequestProtocol<TCodec>, RequestResponseEvent<TCodec::Request, TCodec::Response>>>
Source§fn inject_address_change(
&mut self,
_: &PeerId,
_: &ConnectionId,
_old: &ConnectedPoint,
_new: &ConnectedPoint,
)
fn inject_address_change( &mut self, _: &PeerId, _: &ConnectionId, _old: &ConnectedPoint, _new: &ConnectedPoint, )
ConnectedPoint
of an existing connection has changed.Source§fn inject_addr_reach_failure(
&mut self,
_peer_id: Option<&PeerId>,
_addr: &Multiaddr,
_error: &dyn Error,
)
fn inject_addr_reach_failure( &mut self, _peer_id: Option<&PeerId>, _addr: &Multiaddr, _error: &dyn Error, )
Source§fn inject_new_listen_addr(&mut self, _addr: &Multiaddr)
fn inject_new_listen_addr(&mut self, _addr: &Multiaddr)
Source§fn inject_expired_listen_addr(&mut self, _addr: &Multiaddr)
fn inject_expired_listen_addr(&mut self, _addr: &Multiaddr)
Source§fn inject_new_external_addr(&mut self, _addr: &Multiaddr)
fn inject_new_external_addr(&mut self, _addr: &Multiaddr)
Source§fn inject_listener_error(
&mut self,
_id: ListenerId,
_err: &(dyn Error + 'static),
)
fn inject_listener_error( &mut self, _id: ListenerId, _err: &(dyn Error + 'static), )
Source§fn inject_listener_closed(
&mut self,
_id: ListenerId,
_reason: Result<(), &Error>,
)
fn inject_listener_closed( &mut self, _id: ListenerId, _reason: Result<(), &Error>, )
Auto Trait Implementations§
impl<TCodec> Freeze for RequestResponse<TCodec>
impl<TCodec> !RefUnwindSafe for RequestResponse<TCodec>
impl<TCodec> Send for RequestResponse<TCodec>where
TCodec: Send,
impl<TCodec> Sync for RequestResponse<TCodec>where
TCodec: Sync,
<TCodec as RequestResponseCodec>::Protocol: Sync,
<TCodec as RequestResponseCodec>::Request: Sync,
<TCodec as RequestResponseCodec>::Response: Sync,
impl<TCodec> Unpin for RequestResponse<TCodec>where
TCodec: Unpin,
<TCodec as RequestResponseCodec>::Protocol: Unpin,
<TCodec as RequestResponseCodec>::Request: Unpin,
<TCodec as RequestResponseCodec>::Response: Unpin,
impl<TCodec> !UnwindSafe for RequestResponse<TCodec>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more