iridis-node 0.4.0

iridis is a framework that lets you define and build dataflow applications with ease.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

//! This module contains implementations for this primitive.

use crate::prelude::*;

/// Typed Input to receive data from the dataflow
#[derive(Debug)]
pub struct Input<T: ArrowMessage> {
    pub raw: RawInput,
    _phantom: std::marker::PhantomData<T>,
}

impl<T: ArrowMessage> Input<T> {
    /// Create a new typed Input from a MessageReceiver, NodeID, and InputID
    pub fn new(rx: MessageReceiver, source: NodeID, layout: InputID) -> Self {
        Self {
            raw: RawInput::new(rx, source, layout),
            _phantom: std::marker::PhantomData,
        }
    }

    /// Receive a message from the channel and converting it from Arrow format, asyncronously
    pub async fn recv(&mut self) -> Result<TypedDataflowMessage<T>> {
        self.raw
            .recv()
            .await?
            .try_into()
            .wrap_err(report_failed_conversion_from_arrow::<T>(
                &self.raw.source,
                &self.raw.layout,
            ))
    }
}