Struct h2::proto::streams::store::Queue

pub(super) struct Queue<N> {
    indices: Option<Indices>,
    _p: PhantomData<N>,
}

Fields

indices: Option<Indices>

_p: PhantomData<N>

Implementations

impl<N> Queue<N>

where N: Next,

pub fn new() -> Self

pub fn take(&mut self) -> Self

pub fn push(&mut self, stream: &mut Ptr<'_>) -> bool

Queue the stream.

If the stream is already contained by the list, return false.

pub fn push_front(&mut self, stream: &mut Ptr<'_>) -> bool

Queue the stream

If the stream is already contained by the list, return false.

pub fn pop<'a, R>(&mut self, store: &'a mut R) -> Option<Ptr<'a>>

where R: Resolve,

pub fn is_empty(&self) -> bool

pub fn pop_if<'a, R, F>(&mut self, store: &'a mut R, f: F) -> Option<Ptr<'a>>

where R: Resolve, F: Fn(&Stream) -> bool,

Trait Implementations

impl<N: Debug> Debug for Queue<N>

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

Formats the value using the given formatter.