Skip to main content

PullStep

Enum PullStep 

Source
pub enum PullStep<Item, Meta, CanPend: Toggle, CanEnd: Toggle> {
    Ready(Item, Meta),
    Pending(CanPend),
    Ended(CanEnd),
}
Expand description

The result of polling a Pull.

PullStep represents the three possible outcomes when pulling from a stream:

  • Ready(item, meta): An item is available along with associated metadata.
  • Pending(can_pend): No item is available yet, but more may come (async).
  • Ended(can_end): The stream has terminated and will produce no more items.

The CanPend and CanEnd type parameters use Toggle to statically encode which variants are possible. When a variant is impossible (e.g., CanPend = No), its payload type becomes No, making it a compile error to construct.

Variants§

§

Ready(Item, Meta)

An item is ready with associated metadata.

§

Pending(CanPend)

The pull is not ready yet (only possible when CanPend = Yes).

§

Ended(CanEnd)

The pull has ended (only possible when CanEnd = Yes).

Implementations§

Source§

impl<Item, Meta, CanPend: Toggle, CanEnd: Toggle> PullStep<Item, Meta, CanPend, CanEnd>

Source

pub fn ended() -> Self

Creates a new PullStep::Ended, or panics if CanEnd = No.

Source

pub fn pending() -> Self

Creates a new PullStep::Pending, or panics if CanPend = No.

Source

pub const fn is_ready(&self) -> bool

Returns true if the step is a PullStep::Ready.

Source

pub const fn is_pending(&self) -> bool

Returns true if the step is a PullStep::Pending.

Source

pub const fn is_ended(&self) -> bool

Returns true if the step is a PullStep::Ended.

Source

pub fn try_convert_into<NewPend: Toggle, NewEnd: Toggle>( self, ) -> Option<PullStep<Item, Meta, NewPend, NewEnd>>

Tries to convert the CanPend and CanEnd type parameters, returning None if the conversion is invalid.

Source

pub fn convert_into<NewPend: Toggle, NewEnd: Toggle>( self, ) -> PullStep<Item, Meta, NewPend, NewEnd>

Converts the CanPend and CanEnd type parameters, panicking if the conversion is invalid.

Source

pub fn into_poll(self) -> Poll<Option<(Item, Meta)>>

Converts this PullStep into a Poll<Option<(Item, Meta)>>.

Trait Implementations§

Source§

impl<Item: Clone, Meta: Clone, CanPend: Clone + Toggle, CanEnd: Clone + Toggle> Clone for PullStep<Item, Meta, CanPend, CanEnd>

Source§

fn clone(&self) -> PullStep<Item, Meta, CanPend, CanEnd>

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl<Item: Debug, Meta: Debug, CanPend: Debug + Toggle, CanEnd: Debug + Toggle> Debug for PullStep<Item, Meta, CanPend, CanEnd>

Source§

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

Formats the value using the given formatter. Read more
Source§

impl<Item: Hash, Meta: Hash, CanPend: Hash + Toggle, CanEnd: Hash + Toggle> Hash for PullStep<Item, Meta, CanPend, CanEnd>

Source§

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher. Read more
1.3.0 · Source§

fn hash_slice<H>(data: &[Self], state: &mut H)
where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher. Read more
Source§

impl<Item: Ord, Meta: Ord, CanPend: Ord + Toggle, CanEnd: Ord + Toggle> Ord for PullStep<Item, Meta, CanPend, CanEnd>

Source§

fn cmp(&self, other: &PullStep<Item, Meta, CanPend, CanEnd>) -> Ordering

This method returns an Ordering between self and other. Read more
1.21.0 · Source§

fn max(self, other: Self) -> Self
where Self: Sized,

Compares and returns the maximum of two values. Read more
1.21.0 · Source§

fn min(self, other: Self) -> Self
where Self: Sized,

Compares and returns the minimum of two values. Read more
1.50.0 · Source§

fn clamp(self, min: Self, max: Self) -> Self
where Self: Sized,

Restrict a value to a certain interval. Read more
Source§

impl<Item: PartialEq, Meta: PartialEq, CanPend: PartialEq + Toggle, CanEnd: PartialEq + Toggle> PartialEq for PullStep<Item, Meta, CanPend, CanEnd>

Source§

fn eq(&self, other: &PullStep<Item, Meta, CanPend, CanEnd>) -> bool

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
Source§

impl<Item: PartialOrd, Meta: PartialOrd, CanPend: PartialOrd + Toggle, CanEnd: PartialOrd + Toggle> PartialOrd for PullStep<Item, Meta, CanPend, CanEnd>

Source§

fn partial_cmp( &self, other: &PullStep<Item, Meta, CanPend, CanEnd>, ) -> Option<Ordering>

This method returns an ordering between self and other values if one exists. Read more
1.0.0 · Source§

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator. Read more
1.0.0 · Source§

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator. Read more
1.0.0 · Source§

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator. Read more
1.0.0 · Source§

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator. Read more
Source§

impl<Item: Copy, Meta: Copy, CanPend: Copy + Toggle, CanEnd: Copy + Toggle> Copy for PullStep<Item, Meta, CanPend, CanEnd>

Source§

impl<Item: Eq, Meta: Eq, CanPend: Eq + Toggle, CanEnd: Eq + Toggle> Eq for PullStep<Item, Meta, CanPend, CanEnd>

Source§

impl<Item, Meta, CanPend: Toggle, CanEnd: Toggle> StructuralPartialEq for PullStep<Item, Meta, CanPend, CanEnd>

Auto Trait Implementations§

§

impl<Item, Meta, CanPend, CanEnd> Freeze for PullStep<Item, Meta, CanPend, CanEnd>
where Item: Freeze, Meta: Freeze, CanPend: Freeze, CanEnd: Freeze,

§

impl<Item, Meta, CanPend, CanEnd> RefUnwindSafe for PullStep<Item, Meta, CanPend, CanEnd>
where Item: RefUnwindSafe, Meta: RefUnwindSafe, CanPend: RefUnwindSafe, CanEnd: RefUnwindSafe,

§

impl<Item, Meta, CanPend, CanEnd> Send for PullStep<Item, Meta, CanPend, CanEnd>
where Item: Send, Meta: Send, CanPend: Send, CanEnd: Send,

§

impl<Item, Meta, CanPend, CanEnd> Sync for PullStep<Item, Meta, CanPend, CanEnd>
where Item: Sync, Meta: Sync, CanPend: Sync, CanEnd: Sync,

§

impl<Item, Meta, CanPend, CanEnd> Unpin for PullStep<Item, Meta, CanPend, CanEnd>
where Item: Unpin, Meta: Unpin, CanPend: Unpin, CanEnd: Unpin,

§

impl<Item, Meta, CanPend, CanEnd> UnsafeUnpin for PullStep<Item, Meta, CanPend, CanEnd>
where Item: UnsafeUnpin, Meta: UnsafeUnpin, CanPend: UnsafeUnpin, CanEnd: UnsafeUnpin,

§

impl<Item, Meta, CanPend, CanEnd> UnwindSafe for PullStep<Item, Meta, CanPend, CanEnd>
where Item: UnwindSafe, Meta: UnwindSafe, CanPend: UnwindSafe, CanEnd: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

§

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

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

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.