Struct signalo_filters::source::Take

pub struct Take<S> { /* fields omitted */ }

A source that returns only up to a specified number of values.

Example:

use signalo_filters::source::Increment;

let increment: Increment<_> = Increment::new(0, 1);
// ╭───╮  ╭───╮  ╭───╮  ╭───╮  ╭───╮
// │ 0 │─▶│ 1 │─▶│ 2 │─▶│ 3 │─▶│ 4 │─▶ ...
// ╰───╯  ╰───╯  ╰───╯  ╰───╯  ╰───╯

use signalo_filters::source::Take;

let take: Take<_> = Take::new(increment, 3);
// ╭───╮  ╭───╮  ╭───╮
// │ 0 │─▶│ 1 │─▶│ 2 │
// ╰───╯  ╰───╯  ╰───╯

Methods

impl<S> Take<S>

pub fn new(inner: S, count: usize) -> Self

Creates a new Take source for a given value.

Trait Implementations

impl<S: Clone> Clone for Take<S>

fn clone(&self) -> Take<S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S: Debug> Debug for Take<S>

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

Formats the value using the given formatter.

impl<S, T> Source for Take<S> where     S: Source<Output = T>,

type Output = T

The source's output type.

fn source(&mut self) -> Option<Self::Output>

Produces the next value in the stream of values.