Struct futuresdr::runtime::message_io::MessageIoBuilder

pub struct MessageIoBuilder<T> { /* private fields */ }

Message IO builder

Implementations

impl<T: Send> MessageIoBuilder<T>

pub fn new() -> MessageIoBuilder<T>

Create Message IO builder

pub fn add_input( self, name: &str, c: impl for<'a> Fn(&'a mut T, &'a mut WorkIo, &'a mut MessageIo<T>, &'a mut BlockMeta, Pmt) -> Pin<Box<dyn Future<Output = Result<Pmt>> + Send + 'a>> + Send + Sync + 'static ) -> MessageIoBuilder<T>

Add input port

Use the message_handler macro to define the handler function

pub fn add_output(self, name: &str) -> MessageIoBuilder<T>

Add output port

pub fn build(self) -> MessageIo<T>

Build Message IO

Trait Implementations

impl<T: Send> Default for MessageIoBuilder<T>

fn default() -> Self

Returns the “default value” for a type.