Struct futuresdr::blocks::Delay

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

Delays samples.

Inputs

in: Stream to delay

Outputs

out: Delayed stream

Usage

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

let mut fg = Flowgraph::new();

let sink = fg.add_block(NullSink::<Complex<f32>>::new(42));

Implementations

impl<T: Copy + Send + 'static> Delay<T>

pub fn new(n: isize) -> Block

Creates a new Dealy block which will delay samples by the specified samples.

Trait Implementations

impl<T: Copy + Send + 'static> Kernel for Delay<T>

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

Processes stream data

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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Initialize kernel

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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

De-initialize kernel