[−][src]Struct libp2p::floodsub::protocol::FloodsubConfig
Implementation of ConnectionUpgrade for the floodsub protocol.
Methods
impl FloodsubConfig[src]
pub fn new() -> FloodsubConfig[src]
Builds a new FloodsubConfig.
Trait Implementations
impl<TSocket> InboundUpgrade<TSocket> for FloodsubConfig where
TSocket: AsyncRead + AsyncWrite, [src]
TSocket: AsyncRead + AsyncWrite,
type Output = FloodsubRpc
Output after the upgrade has been successfully negotiated and the handshake performed.
type Error = FloodsubDecodeError
Possible error during the handshake.
type Future = ReadOneThen<Negotiated<TSocket>, (), fn(Vec<u8>, ()) -> Result<FloodsubRpc, FloodsubDecodeError>>
Future that performs the handshake with the remote.
fn upgrade_inbound(
self,
socket: Negotiated<TSocket>,
<FloodsubConfig as UpgradeInfo>::Info
) -> <FloodsubConfig as InboundUpgrade<TSocket>>::Future[src]
self,
socket: Negotiated<TSocket>,
<FloodsubConfig as UpgradeInfo>::Info
) -> <FloodsubConfig as InboundUpgrade<TSocket>>::Future
impl Default for FloodsubConfig[src]
fn default() -> FloodsubConfig[src]
impl Debug for FloodsubConfig[src]
impl UpgradeInfo for FloodsubConfig[src]
type Info = &'static [u8]
Opaque type representing a negotiable protocol.
type InfoIter = Once<<FloodsubConfig as UpgradeInfo>::Info>
Iterator returned by protocol_info.
fn protocol_info(&self) -> <FloodsubConfig as UpgradeInfo>::InfoIter[src]
impl Clone for FloodsubConfig[src]
fn clone(&self) -> FloodsubConfig[src]
fn clone_from(&mut self, source: &Self)1.0.0[src]
Performs copy-assignment from source. Read more
Auto Trait Implementations
impl Sync for FloodsubConfig
impl Send for FloodsubConfig
impl Unpin for FloodsubConfig
impl RefUnwindSafe for FloodsubConfig
impl UnwindSafe for FloodsubConfig
Blanket Implementations
impl<T> ToOwned for T where
T: Clone, [src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T[src]
fn clone_into(&self, target: &mut T)[src]
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
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>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
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>[src]
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T> Clear for T where
T: InitializableFromZeroed + ?Sized,
T: InitializableFromZeroed + ?Sized,
fn clear(&mut self)
impl<T> InitializableFromZeroed for T where
T: Default,
T: Default,
unsafe fn initialize(place: *mut T)
impl<C, U> InboundUpgradeExt<C> for U where
U: InboundUpgrade<C>, [src]
U: InboundUpgrade<C>,
fn map_inbound<F, T>(self, f: F) -> MapInboundUpgrade<Self, F> where
F: FnOnce(Self::Output) -> T, [src]
F: FnOnce(Self::Output) -> T,
Returns a new object that wraps around Self and applies a closure to the Output.
fn map_inbound_err<F, T>(self, f: F) -> MapInboundUpgradeErr<Self, F> where
F: FnOnce(Self::Error) -> T, [src]
F: FnOnce(Self::Error) -> T,
Returns a new object that wraps around Self and applies a closure to the Error.