Struct SharedDataLayout

pub struct SharedDataLayout {
    pub data: Arc<Mutex<DataLayout>>,
    pub debug: Arc<Mutex<DebugLayout>>,
}

Represents a shared Data only layout. It is used to construct a DataflowLayout easily.

Fields

data: Arc<Mutex<DataLayout>>

debug: Arc<Mutex<DebugLayout>>

Implementations

impl SharedDataLayout

pub async fn node<T>( &self, label: impl Into<String>, layout_builder: impl AsyncFnOnce(&mut NodeLayout) -> T, ) -> (NodeID, T)

Creates a new Node with the given label. Provide an async closure to add primitives to the node (such as Inputs, Queries etc…)

pub async fn finish( self, flows: impl AsyncFnOnce(&mut FlowLayout) -> Result<(), Report>, ) -> Result<Arc<DataflowLayout>, Report>

Creates a DataflowLayout from the current SharedDataLayout and the given flows function. The flows function is an async closure that takes a FlowLayout that can be used to connect the primitives together.

Trait Implementations

impl Clone for SharedDataLayout

fn clone(&self) -> SharedDataLayout

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SharedDataLayout

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

Formats the value using the given formatter.