Struct futuresdr::blocks::ChannelSource

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

Push samples through a channel into a stream connection.

Outputs

out: Samples pushed into the channel

Usage

use futuresdr::futures::channel::mpsc;
use futuresdr::blocks::ChannelSource;
use futuresdr::runtime::Flowgraph;

let mut fg = Flowgraph::new();
let (mut tx, rx) = mpsc::channel(10);

let cs = fg.add_block(ChannelSource::<u32>::new(rx));
// start flowgraph
tx.try_send(vec![0, 1, 2].into_boxed_slice());

Implementations

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

pub fn new(receiver: Receiver<Box<[T]>>) -> Block