Struct MessageSourceBuilder 

pub struct MessageSourceBuilder { /* private fields */ }

Repeats a fixed message on an interval

Message Inputs

No message inputs.

Message Outputs

out: Repeated 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(
    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) -> MessageSource

Build Message Source block