Struct Outputs

pub struct Outputs { /* private fields */ }

Outputs let you manage output connections during a node implementation

Implementations

impl Outputs

pub fn new( senders: Arc<Mutex<HashMap<Uuid, Vec<MessageSender>>>>, clock: Arc<HLC>, source: NodeLayout, ) -> Self

Creates a new instance of Outputs

pub async fn raw(&mut self, output: impl Into<String>) -> Result<RawOutput>

Creates a new raw Output, this raw output has no type information so you have to manually transform it

pub async fn with<T: ArrowMessage>( &mut self, output: impl Into<String>, ) -> Result<Output<T>>

Creates a new typed Output, this output has type information so you don’t have to manually transform it