[][src]Function futures_async_combinators::stream::skip

pub fn skip<St>(stream: St, n: u64) -> impl Stream<Item = St::Item> where
    St: Stream

Creates a new stream which skips n items of the underlying stream.

Once n items have been skipped from this stream then it will always return the remaining items on this stream.

Examples

use futures_async_combinators::stream::{iter, skip, collect};

let stream = iter(1..=10);
let stream = skip(stream, 5);

let result: Vec<_> = collect(stream).await;
assert_eq!(vec![6, 7, 8, 9, 10], result);