Struct libp2p::floodsub::FloodsubRpc
source · [−]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
sourceimpl Clone for FloodsubRpc
impl Clone for FloodsubRpc
sourcefn clone(&self) -> FloodsubRpc
fn clone(&self) -> FloodsubRpc
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
sourceimpl Debug for FloodsubRpc
impl Debug for FloodsubRpc
sourceimpl Hash for FloodsubRpc
impl Hash for FloodsubRpc
sourceimpl<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,
type Output = ()
type Output = ()
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.
sourcefn upgrade_outbound(
self,
socket: TSocket,
<FloodsubRpc as UpgradeInfo>::Info
) -> <FloodsubRpc as OutboundUpgrade<TSocket>>::Future
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
sourceimpl PartialEq<FloodsubRpc> for FloodsubRpc
impl PartialEq<FloodsubRpc> for FloodsubRpc
sourcefn eq(&self, other: &FloodsubRpc) -> bool
fn eq(&self, other: &FloodsubRpc) -> bool
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
sourcefn ne(&self, other: &FloodsubRpc) -> bool
fn ne(&self, other: &FloodsubRpc) -> bool
This method tests for !=
.
sourceimpl UpgradeInfo for FloodsubRpc
impl UpgradeInfo for FloodsubRpc
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
.
sourcefn protocol_info(&self) -> <FloodsubRpc as UpgradeInfo>::InfoIter
fn protocol_info(&self) -> <FloodsubRpc as UpgradeInfo>::InfoIter
Returns the list of protocols that are supported. Used during the negotiation process.
impl Eq for FloodsubRpc
impl StructuralEq for FloodsubRpc
impl StructuralPartialEq for FloodsubRpc
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
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<C, U> OutboundUpgradeExt<C> for U where
U: OutboundUpgrade<C>,
impl<C, U> OutboundUpgradeExt<C> for U where
U: OutboundUpgrade<C>,
sourcefn 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
.
sourcefn 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
.
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more