Struct futuresdr::blocks::Combine

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

Apply a function to combine two streams into one.

Inputs

in0: Input A

in1: Input B

Outputs

out: Combined output

Usage

use futuresdr::blocks::Combine;
use futuresdr::runtime::Flowgraph;

let mut fg = Flowgraph::new();

let adder = fg.add_block(Combine::new(|a: &f32, b: &f32| {
    a + b
}));

Implementations

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

pub fn new(f: F) -> Block