Struct libp2p_rs::floodsub::control::Control [−][src]
Implementations
impl Control[src]
pub fn close(&mut self)[src]
Closes the floodsub main loop.
pub async fn publish(
&'_ mut self,
topic: Topic,
data: impl Into<Vec<u8, Global>>
) -> Result<(), FloodsubError>[src]
&'_ mut self,
topic: Topic,
data: impl Into<Vec<u8, Global>>
) -> Result<(), FloodsubError>
Publish publishes data to a given topic.
pub async fn subscribe(
&'_ mut self,
topic: Topic
) -> Result<Subscription, FloodsubError>[src]
&'_ mut self,
topic: Topic
) -> Result<Subscription, FloodsubError>
Subscribe to messages on a given topic.
pub async fn ls(&'_ mut self) -> Result<Vec<Topic, Global>, FloodsubError>[src]
List subscribed topics by name.
pub async fn get_peers(
&'_ mut self,
topic: Topic
) -> Result<Vec<PeerId, Global>, FloodsubError>[src]
&'_ mut self,
topic: Topic
) -> Result<Vec<PeerId, Global>, FloodsubError>
List peers we are currently pubsubbing with.
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Control
impl Send for Control
impl Sync for Control
impl Unpin for Control
impl !UnwindSafe for Control
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &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> Pointable for T
pub const ALIGN: usize
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize
pub unsafe fn deref<'a>(ptr: usize) -> &'a T
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T
pub unsafe fn drop(ptr: usize)
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T> ToOwned for T where
T: Clone, [src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T[src]
pub fn clone_into(&self, target: &mut T)[src]
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.
pub 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.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,