Struct Inputs

pub struct Inputs { /* private fields */ }

Inputs let you manage input connections during a node implementation

Implementations

impl Inputs

pub fn new( receivers: Arc<Mutex<HashMap<Uuid, MessageReceiver>>>, source: NodeLayout, ) -> Self

Creates a new Inputs instance.

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

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

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

Creates a new Input, this input has type information so it can be directly transformed

Trait Implementations

impl Debug for Inputs

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.