Struct libp2p::floodsub::FloodsubRpc [−][src]
pub struct FloodsubRpc {
pub messages: Vec<FloodsubMessage, Global>,
pub subscriptions: Vec<FloodsubSubscription, Global>,
}
Expand description
An RPC received by the floodsub system.
Fields
messages: Vec<FloodsubMessage, Global>
List of messages that were part of this RPC query.
subscriptions: Vec<FloodsubSubscription, Global>
List of subscriptions.
Trait Implementations
impl<TSocket> OutboundUpgrade<TSocket> for FloodsubRpc where
TSocket: 'static + AsyncWrite + AsyncRead + Send + Unpin,
impl<TSocket> OutboundUpgrade<TSocket> for FloodsubRpc where
TSocket: 'static + AsyncWrite + AsyncRead + Send + Unpin,
Output after the upgrade has been successfully negotiated and the handshake performed.
type Future = Pin<Box<dyn Future<Output = Result<<FloodsubRpc as OutboundUpgrade<TSocket>>::Output, <FloodsubRpc as OutboundUpgrade<TSocket>>::Error>> + Send + 'static, Global>>
type Future = Pin<Box<dyn Future<Output = Result<<FloodsubRpc as OutboundUpgrade<TSocket>>::Output, <FloodsubRpc as OutboundUpgrade<TSocket>>::Error>> + Send + 'static, Global>>
Future that performs the handshake with the remote.
pub fn upgrade_outbound(
self,
socket: TSocket,
<FloodsubRpc as UpgradeInfo>::Info
) -> <FloodsubRpc as OutboundUpgrade<TSocket>>::Future
pub fn upgrade_outbound(
self,
socket: TSocket,
<FloodsubRpc as UpgradeInfo>::Info
) -> <FloodsubRpc as OutboundUpgrade<TSocket>>::Future
After we have determined that the remote supports one of the protocols we support, this method is called to start the handshake. Read more
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
type Info = &'static [u8]
type Info = &'static [u8]
Opaque type representing a negotiable protocol.
type InfoIter = Once<<FloodsubRpc as UpgradeInfo>::Info>
type InfoIter = Once<<FloodsubRpc as UpgradeInfo>::Info>
Iterator returned by protocol_info
.
Returns the list of protocols that are supported. Used during the negotiation process.
Auto Trait Implementations
impl RefUnwindSafe for FloodsubRpc
impl Send for FloodsubRpc
impl Sync for FloodsubRpc
impl Unpin for FloodsubRpc
impl UnwindSafe for FloodsubRpc
Blanket Implementations
Mutably borrows from an owned value. Read more
fn map_outbound<F, T>(self, f: F) -> MapOutboundUpgrade<Self, F> where
F: FnOnce(Self::Output) -> T,
fn map_outbound<F, T>(self, f: F) -> MapOutboundUpgrade<Self, F> where
F: FnOnce(Self::Output) -> T,
Returns a new object that wraps around Self
and applies a closure to the Output
.
fn map_outbound_err<F, T>(self, f: F) -> MapOutboundUpgradeErr<Self, F> where
F: FnOnce(Self::Error) -> T,
fn map_outbound_err<F, T>(self, f: F) -> MapOutboundUpgradeErr<Self, F> where
F: FnOnce(Self::Error) -> T,
Returns a new object that wraps around Self
and applies a closure to the Error
.