Skip to main content

StreamCompat

dfir_pipes::pull

Struct StreamCompat 

Source 
pub struct StreamCompat<Pul> { /* private fields */ }
Expand description

Adapter that wraps a Pull to implement the Stream trait.

Implementations§

Source§

impl<Pul> StreamCompat<Pul>

Source

pub fn into_inner(self) -> Pul

Returns the wrapped Pull.

Source

pub fn as_pin_mut(self: Pin<&mut Self>) -> Pin<&mut Pul>

Returns a pinned mutable reference to the wrapped Pull.

Source

pub fn as_pin_ref(self: Pin<&Self>) -> Pin<&Pul>

Returns a pinned reference to the wrapped Pull.

Trait Implementations§

Source§

impl<Pul> AsMut<Pul> for StreamCompat<Pul>

Source§

fn as_mut(&mut self) -> &mut Pul

Converts this type into a mutable reference of the (usually inferred) input type.
Source§

impl<Pul> AsRef<Pul> for StreamCompat<Pul>

Source§

fn as_ref(&self) -> &Pul

Converts this type into a shared reference of the (usually inferred) input type.
Source§

impl<Pul> Stream for StreamCompat<Pul>
where Pul: Pull, for<'ctx> Pul::Ctx<'ctx>: Context<'ctx>,

Source§

type Item = <Pul as Pull>::Item

Values yielded by the stream.
Source§

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. Read more
Source§

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

Returns the bounds on the remaining length of the stream. Read more
Source§

impl<'__pin, Pul> Unpin for StreamCompat<Pul>
where PinnedFieldsOf<__Origin<'__pin, Pul>>: Unpin,

Auto Trait Implementations§

§

impl<Pul> Freeze for StreamCompat<Pul>
where Pul: Freeze,

§

impl<Pul> RefUnwindSafe for StreamCompat<Pul>
where Pul: RefUnwindSafe,

§

impl<Pul> Send for StreamCompat<Pul>
where Pul: Send,

§

impl<Pul> Sync for StreamCompat<Pul>
where Pul: Sync,

§

impl<Pul> UnsafeUnpin for StreamCompat<Pul>
where Pul: UnsafeUnpin,

§

impl<Pul> UnwindSafe for StreamCompat<Pul>
where Pul: 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> 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, 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.
§

impl<S, T, E> TryStream for S
where S: Stream<Item = Result<T, E>> + ?Sized,

§

type Ok = T

The type of successful values yielded by this future
§

type Error = E

The type of failures yielded by this future
§

fn try_poll_next( self: Pin<&mut S>, cx: &mut Context<'_>, ) -> Poll<Option<Result<<S as TryStream>::Ok, <S as TryStream>::Error>>>

Poll this TryStream as if it were a Stream. Read more