Struct futuresdr::blocks::MessageSourceBuilder

pub struct MessageSourceBuilder { /* private fields */ }

Available on non-WebAssembly only.

Repeats a fixed message on an interval

Inputs

No inputs.

Outputs

Message: out: Message output

Usage

use std::time;
use futuresdr::blocks::MessageSourceBuilder;
use futuresdr::runtime::{Flowgraph, Pmt};

let mut fg = Flowgraph::new();

// Repeat the message "foo" every 100ms twenty times
let msg_source = fg.add_block(
    MessageSourceBuilder::new(
        Pmt::String("foo".to_string()),
        time::Duration::from_millis(100),
    )
    .n_messages(20)
    .build()
);

Implementations

impl MessageSourceBuilder

pub fn new(message: Pmt, duration: Duration) -> MessageSourceBuilder

Create MessageSource builder

pub fn n_messages(self, n: usize) -> MessageSourceBuilder

Number of message to send

pub fn build(self) -> Block

Build Message Source block