Struct futuresdr::blocks::Head

pub struct Head<T: Send + 'static> { /* private fields */ }

Stops the graph after the given number of samples

Inputs

in: Input

Outputs

out: Output

Usage

use futuresdr::blocks::Head;
use futuresdr::runtime::Flowgraph;
use num_complex::Complex;

let mut fg = Flowgraph::new();

let head = fg.add_block(Head::<Complex<f32>>::new(1_000_000));

Implementations

impl<T: Send + 'static> Head<T>

pub fn new(n_items: u64) -> Block

Trait Implementations

impl<T: Send + 'static> Kernel for Head<T>

fn work<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
    &'life0 mut self,
    io: &'life1 mut WorkIo,
    sio: &'life2 mut StreamIo,
    _mio: &'life3 mut MessageIo<Self>,
    _meta: &'life4 mut BlockMeta
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    'life3: 'async_trait,
    'life4: 'async_trait,
    Self: 'async_trait, 

fn init<'life0, 'life1, 'life2, 'life3, 'async_trait>(
    &'life0 mut self,
    _s: &'life1 mut StreamIo,
    _m: &'life2 mut MessageIo<Self>,
    _b: &'life3 mut BlockMeta
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    'life3: 'async_trait,
    Self: 'async_trait, 

fn deinit<'life0, 'life1, 'life2, 'life3, 'async_trait>(
    &'life0 mut self,
    _s: &'life1 mut StreamIo,
    _m: &'life2 mut MessageIo<Self>,
    _b: &'life3 mut BlockMeta
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    'life3: 'async_trait,
    Self: 'async_trait,