Struct futuresdr::blocks::ApplyNM

pub struct ApplyNM<A, B, const N: usize, const M: usize> where
    A: 'static,
    B: 'static, { /* private fields */ }

Applies a function on N samples in the input stream, and creates M samples in the output stream. Handy for interleaved samples for example. See examples/audio/play_stereo.rs

Inputs

in: Input

Outputs

out: Output after function applied

Usage

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

let mut fg = Flowgraph::new();

// Convert mono stream to stereo interleaved stream
let mono_to_stereo = fg.add_block(ApplyNM::<f32, f32, 1, 2>::new(move |v: &[f32], d: &mut [f32]| {
    d[0] =  v[0] * 0.5; // gain left
    d[1] =  v[0] * 0.9; // gain right
}));
// Note that the closure can also hold state
// Additionally, the closure can change the type of the sample

Implementations

impl<A, B, const N: usize, const M: usize> ApplyNM<A, B, N, M> where
    A: 'static,
    B: 'static, 

pub fn new(f: impl FnMut(&[A], &mut [B]) + Send + 'static) -> Block

Trait Implementations

impl<A, B, const N: usize, const M: usize> Kernel for ApplyNM<A, B, N, M> where
    A: 'static,
    B: 'static, 

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,