Struct litep2p::substream::SubstreamSet

pub struct SubstreamSet<K, S>
where
    K: SubstreamSetKey,
    S: Stream<Item = Result<BytesMut, SubstreamError>> + Unpin,
{ /* private fields */ }

Substream set.

Implementations

impl<K, S> SubstreamSet<K, S>

where K: SubstreamSetKey, S: Stream<Item = Result<BytesMut, SubstreamError>> + Unpin,

pub fn new() -> Self

Create new SubstreamSet.

pub fn insert(&mut self, key: K, substream: S)

Add new substream to the set.

pub fn remove(&mut self, key: &K) -> Option<S>

Remove substream from the set.

pub fn len(&self) -> usize

Get size of SubstreamSet.

pub fn is_empty(&self) -> bool

Check if SubstreamSet is empty.

Trait Implementations

impl<K, S> Debug for SubstreamSet<K, S>

where K: SubstreamSetKey + Debug, S: Stream<Item = Result<BytesMut, SubstreamError>> + Unpin + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<K, S> Default for SubstreamSet<K, S>

where K: SubstreamSetKey + Default, S: Stream<Item = Result<BytesMut, SubstreamError>> + Unpin + Default,

fn default() -> SubstreamSet<K, S>

Returns the “default value” for a type.

impl<K, S> Stream for SubstreamSet<K, S>

where K: SubstreamSetKey, S: Stream<Item = Result<BytesMut, SubstreamError>> + Unpin,

type Item = (K, <S as Stream>::Item)

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.