[−][src]Struct futures_util::stream::Skip

#[must_use = "streams do nothing unless polled"]
pub struct Skip<St> { /* fields omitted */ }

Stream for the skip method.

Methods

`impl<St: Stream> Skip<St>`[src]

`pub fn get_ref(&self) -> &St`[src]

Acquires a reference to the underlying stream that this combinator is pulling from.

`pub fn get_mut(&mut self) -> &mut St`[src]

Acquires a mutable reference to the underlying stream that this combinator is pulling from.

Note that care must be taken to avoid tampering with the state of the stream which may otherwise confuse this combinator.

ⓘImportant traits for Pin
Important traits for Pin
`impl Future for Pin where P: Unpin + DerefMut, ::Target: Future, type Output = <::Target as Future>::Output;`
`pub fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut St>`[src]

Acquires a pinned mutable reference to the underlying stream that this combinator is pulling from.

Note that care must be taken to avoid tampering with the state of the stream which may otherwise confuse this combinator.

`pub fn into_inner(self) -> St`[src]

Consumes this combinator, returning the underlying stream.

Note that this may discard intermediate state of this combinator, so care should be taken to avoid losing resources when this is called.

Trait Implementations

`impl<St: Debug> Debug for Skip<St>`[src]

`fn fmt(&self, f: &mut Formatter) -> Result`[src]

`impl<St: Unpin> Unpin for Skip<St>`[src]

`impl<St: Stream> Stream for Skip<St>`[src]

`type Item = St::Item`

Values yielded by the stream.

`fn poll_next(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<St::Item>>`[src]

`fn size_hint(&self) -> (usize, Option<usize>)`[src]

`impl<St: FusedStream> FusedStream for Skip<St>`[src]

`fn is_terminated(&self) -> bool`[src]

`impl<S, Item> Sink<Item> for Skip<S> where S: Stream + Sink<Item>,` [src]

`type Error = S::Error`

The type of value produced by the sink when an error occurs.

`fn poll_ready( self: Pin<&mut Self>, cx: &mut Context ) -> Poll<Result<(), Self::Error>>`[src]

`fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error>`[src]

`fn poll_flush( self: Pin<&mut Self>, cx: &mut Context ) -> Poll<Result<(), Self::Error>>`[src]

`fn poll_close( self: Pin<&mut Self>, cx: &mut Context ) -> Poll<Result<(), Self::Error>>`[src]

Auto Trait Implementations

`impl<St> Send for Skip<St> where St: Send,`

`impl<St> Sync for Skip<St> where St: Sync,`

Blanket Implementations

`impl<T, Item> SinkExt<Item> for T where T: Sink<Item> + ?Sized,` [src]

`fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F> where F: FnMut(U) -> Fut, Fut: Future<Output = Result<Item, E>>, E: From<Self::Error>, Self: Sized,` [src]

`fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where F: FnMut(U) -> St, St: Stream<Item = Result<Item, Self::Error>>, Self: Sized,` [src]

`fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where F: FnOnce(Self::Error) -> E, Self: Sized,` [src]

`fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where Self: Sized, Self::Error: Into<E>,` [src]

ⓘImportant traits for Close<'_, Si, Item>
Important traits for Close<'_, Si, Item>
`impl<'_, Si: Sink<Item> + Unpin + ?Sized, Item> Future for Close<'_, Si, Item> type Output = Result<(), Si::Error>;`
`fn close(&mut self) -> Close<Self, Item> where Self: Unpin,` [src]

`fn fanout<Si>(self, other: Si) -> Fanout<Self, Si> where Self: Sized, Item: Clone, Si: Sink<Item, Error = Self::Error>,` [src]

ⓘImportant traits for Flush<'_, Si, Item>
Important traits for Flush<'_, Si, Item>
`impl<'_, Si: Sink<Item> + Unpin + ?Sized, Item> Future for Flush<'_, Si, Item> type Output = Result<(), Si::Error>;`
`fn flush(&mut self) -> Flush<Self, Item> where Self: Unpin,` [src]

ⓘImportant traits for Send<'_, Si, Item>
Important traits for Send<'_, Si, Item>
`impl<'_, Si: Sink<Item> + Unpin + ?Sized, Item> Future for Send<'_, Si, Item> type Output = Result<(), Si::Error>;`
`fn send(&mut self, item: Item) -> Send<Self, Item> where Self: Unpin,` [src]

ⓘImportant traits for SendAll<'_, Si, St>
Important traits for SendAll<'_, Si, St>
`impl<'_, Si: ?Sized, St: ?Sized, Ok, Error> Future for SendAll<'_, Si, St> where Si: Sink<Ok, Error = Error> + Unpin, St: Stream<Item = Result<Ok, Error>> + Unpin, type Output = Result<(), Error>;`
`fn send_all<'a, St: ?Sized>( &'a mut self, stream: &'a mut St ) -> SendAll<'a, Self, St> where St: TryStream<Ok = Item, Error = Self::Error> + Stream + Unpin, Self: Unpin,` [src]

ⓘImportant traits for Either<A, B>
Important traits for Either<A, B>
`impl<A, B> Future for Either<A, B> where A: Future, B: Future<Output = A::Output>, type Output = A::Output;`
`fn left_sink<Si2>(self) -> Either<Self, Si2> where Si2: Sink<Item, Error = Self::Error>, Self: Sized,` [src]

ⓘImportant traits for Either<A, B>
Important traits for Either<A, B>
`impl<A, B> Future for Either<A, B> where A: Future, B: Future<Output = A::Output>, type Output = A::Output;`
`fn right_sink<Si1>(self) -> Either<Si1, Self> where Si1: Sink<Item, Error = Self::Error>, Self: Sized,` [src]

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

`fn from(t: T) -> T`[src]

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

`type Error = Infallible`

The type returned in the event of a conversion error.

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

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

`fn into(self) -> U`[src]

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

`type Error = >::Error`

The type returned in the event of a conversion error.

`fn try_into(self) -> Result<U, >::Error>`[src]

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

`fn borrow(&self) -> &T`[src]

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

`fn borrow_mut(&mut self) -> &mut T`[src]

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

`fn type_id(&self) -> TypeId`[src]

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

`type Ok = T`

The type of successful values yielded by this future

`type Error = E`

The type of failures yielded by this future

[−][src]Struct futures_util::stream::Skip

Methods

impl<St: Stream> Skip<St>[src]

pub fn get_ref(&self) -> &St[src]

pub fn get_mut(&mut self) -> &mut St[src]

ⓘImportant traits for Pin<P>Important traits for Pin<P>impl<P> Future for Pin<P> where P: Unpin + DerefMut, <P as Deref>::Target: Future, type Output = <<P as Deref>::Target as Future>::Output;pub fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut St>[src]

Important traits for Pin<P>

pub fn into_inner(self) -> St[src]

Trait Implementations

impl<St: Debug> Debug for Skip<St>[src]

fn fmt(&self, f: &mut Formatter) -> Result[src]

impl<St: Unpin> Unpin for Skip<St>[src]

impl<St: Stream> Stream for Skip<St>[src]

type Item = St::Item

fn poll_next(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<St::Item>>[src]

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

impl<St: FusedStream> FusedStream for Skip<St>[src]

fn is_terminated(&self) -> bool[src]

impl<S, Item> Sink<Item> for Skip<S> where S: Stream + Sink<Item>, [src]

type Error = S::Error

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<(), Self::Error>>[src]

fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error>[src]

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<(), Self::Error>>[src]

fn poll_close( self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<(), Self::Error>>[src]

Auto Trait Implementations

impl<St> Send for Skip<St> where St: Send,

impl<St> Sync for Skip<St> where St: Sync,

Blanket Implementations

impl<T, Item> SinkExt<Item> for T where T: Sink<Item> + ?Sized, [src]

fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F> where F: FnMut(U) -> Fut, Fut: Future<Output = Result<Item, E>>, E: From<Self::Error>, Self: Sized, [src]

fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where F: FnMut(U) -> St, St: Stream<Item = Result<Item, Self::Error>>, Self: Sized, [src]

fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where F: FnOnce(Self::Error) -> E, Self: Sized, [src]

fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where Self: Sized, Self::Error: Into<E>, [src]

ⓘImportant traits for Close<'_, Si, Item>Important traits for Close<'_, Si, Item>impl<'_, Si: Sink<Item> + Unpin + ?Sized, Item> Future for Close<'_, Si, Item> type Output = Result<(), Si::Error>;fn close(&mut self) -> Close<Self, Item> where Self: Unpin, [src]

Important traits for Close<'_, Si, Item>

fn fanout<Si>(self, other: Si) -> Fanout<Self, Si> where Self: Sized, Item: Clone, Si: Sink<Item, Error = Self::Error>, [src]

ⓘImportant traits for Flush<'_, Si, Item>Important traits for Flush<'_, Si, Item>impl<'_, Si: Sink<Item> + Unpin + ?Sized, Item> Future for Flush<'_, Si, Item> type Output = Result<(), Si::Error>;fn flush(&mut self) -> Flush<Self, Item> where Self: Unpin, [src]

Important traits for Flush<'_, Si, Item>

ⓘImportant traits for Send<'_, Si, Item>Important traits for Send<'_, Si, Item>impl<'_, Si: Sink<Item> + Unpin + ?Sized, Item> Future for Send<'_, Si, Item> type Output = Result<(), Si::Error>;fn send(&mut self, item: Item) -> Send<Self, Item> where Self: Unpin, [src]

Important traits for Send<'_, Si, Item>

Important traits for SendAll<'_, Si, St>

ⓘImportant traits for Either<A, B>Important traits for Either<A, B>impl<A, B> Future for Either<A, B> where A: Future, B: Future<Output = A::Output>, type Output = A::Output;fn left_sink<Si2>(self) -> Either<Self, Si2> where Si2: Sink<Item, Error = Self::Error>, Self: Sized, [src]

Important traits for Either<A, B>

ⓘImportant traits for Either<A, B>Important traits for Either<A, B>impl<A, B> Future for Either<A, B> where A: Future, B: Future<Output = A::Output>, type Output = A::Output;fn right_sink<Si1>(self) -> Either<Si1, Self> where Si1: Sink<Item, Error = Self::Error>, Self: Sized, [src]

Important traits for Either<A, B>

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

fn from(t: T) -> T[src]

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

type Error = Infallible

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

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

fn into(self) -> U[src]

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

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

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

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

fn borrow(&self) -> &T[src]

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

fn borrow_mut(&mut self) -> &mut T[src]

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

fn type_id(&self) -> TypeId[src]

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

type Ok = T

type Error = E

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