[][src]Struct sc_network::gossip::QueuedSender

pub struct QueuedSender<M> { /* fields omitted */ }

Notifications sender for a specific combination of network service, peer, and protocol.

Implementations

impl<M> QueuedSender<M>[src]

pub fn new<B, H, F>(
    service: Arc<NetworkService<B, H>>,
    peer_id: PeerId,
    protocol: Cow<'static, str>,
    queue_size_limit: usize,
    messages_encode: F
) -> (Self, impl Future<Output = ()> + Send + 'static) where
    M: Send + 'static,
    B: BlockT + 'static,
    H: ExHashT,
    F: Fn(M) -> Vec<u8> + Send + 'static, 
[src]

Returns a new QueuedSender containing a queue of message for this specific combination of peer and protocol.

In addition to the QueuedSender, also returns a Future whose role is to drive the messages sending forward.

pub async fn lock_queue<'a>(&'a mut self) -> QueueGuard<'a, M>[src]

Locks the queue of messages towards this peer.

The returned Future is expected to be ready quite quickly.

pub async fn queue_or_discard(&mut self, message: M) where
    M: Send + 'static, 
[src]

Pushes a message to the queue, or discards it if the queue is full.

The returned Future is expected to be ready quite quickly.

Trait Implementations

impl<M> Debug for QueuedSender<M>[src]

Auto Trait Implementations

impl<M> !RefUnwindSafe for QueuedSender<M>[src]

impl<M> Send for QueuedSender<M> where
    M: Send
[src]

impl<M> Sync for QueuedSender<M> where
    M: Send
[src]

impl<M> Unpin for QueuedSender<M>[src]

impl<M> !UnwindSafe for QueuedSender<M>[src]

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> CheckedConversion for T[src]

impl<T> From<T> for T[src]

impl<T> Instrument for T[src]

impl<T> Instrument for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, Outer> IsWrappedBy<Outer> for T where
    T: From<Outer>,
    Outer: AsRef<T> + AsMut<T> + From<T>, 
[src]

pub fn from_ref(outer: &Outer) -> &T[src]

Get a reference to the inner from the outer.

pub fn from_mut(outer: &mut Outer) -> &mut T[src]

Get a mutable reference to the inner from the outer.

impl<T> MaybeDebug for T where
    T: Debug

impl<T> MaybeDebug for T where
    T: Debug

impl<T> Pointable for T

type Init = T

The type for initializers.

impl<T> Same<T> for T

type Output = T

Should always be Self

impl<T> SaturatedConversion for T[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<S, T> UncheckedInto<T> for S where
    T: UncheckedFrom<S>, 
[src]

impl<T, S> UniqueSaturatedInto<T> for S where
    T: Bounded,
    S: TryInto<T>, 
[src]

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 

impl<T> WithSubscriber for T[src]