Struct RunnableGraph 

pub struct RunnableGraph<Mat> { /* private fields */ }

Implementations

impl<Mat: Send + 'static> RunnableGraph<Mat>

pub fn run(&self) -> StreamResult<Mat>

pub fn run_with_materializer( &self, materializer: &Materializer, ) -> StreamResult<Mat>

pub fn map_materialized_value<Next, F>(self, f: F) -> RunnableGraph<Next>

where Next: Send + 'static, F: Fn(Mat) -> Next + Send + Sync + 'static,

pub fn attributes(&self) -> &Attributes

pub fn with_attributes(self, attributes: Attributes) -> Self

pub fn add_attributes(self, attributes: Attributes) -> Self

pub fn named(self, name: impl Into<String>) -> Self

Trait Implementations

impl<Mat: Clone> Clone for RunnableGraph<Mat>

fn clone(&self) -> RunnableGraph<Mat>

Returns a duplicate of the value.

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

Performs copy-assignment from source.