Struct futuresdr::blocks::Apply

pub struct Apply<F, A, B>where
    F: FnMut(&A) -> B + Send + 'static,
    A: Send + 'static,
    B: Send + 'static,{ /* private fields */ }

Apply a function to each sample.

Stream Inputs

in: Input

Stream Outputs

out: Output, corresponding to input with function applied

Usage

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

let mut fg = Flowgraph::new();

// Double each sample
let doubler = fg.add_block(Apply::new(|i: &f32| i * 2.0));

// Note that the closure can also hold state
let mut last_value = 0.0;
let moving_average = fg.add_block(Apply::new(move |i: &f32| {
    let new_value = (last_value + i) / 2.0;
    last_value = *i;
    new_value
}));

// Additionally, the closure can change the type of the sample
let to_complex = fg.add_block(Apply::new(|i: &f32| {
    Complex {
        re: 0.0,
        im: *i,
    }
}));

Implementations

impl<F, A, B> Apply<F, A, B>where F: FnMut(&A) -> B + Send + 'static, A: Send + 'static, B: Send + 'static,

pub fn new(f: F) -> Block

Create Apply block

Parameter

• f: Function to apply on each sample

pub fn new_typed(f: F) -> TypedBlock<Self>

Create typed Apply block

Parameter

• f: Function to apply on each sample