Struct ActorMaterializer 

pub struct ActorMaterializer;

Implementations

impl ActorMaterializer

pub fn new() -> Self

pub async fn run_collect<T: Send + 'static>(&self, source: Source<T>) -> Vec<T>

Convenience: run a source into a collecting sink and return the result.

pub async fn run<M: Send + 'static>(&self, graph: RunnableGraph<M>) -> M

Run an arbitrary RunnableGraph.

pub async fn run_with<T, F, Fut, Out>( &self, source: Source<T>, terminator: F, ) -> Out

where T: Send + 'static, F: FnOnce(Source<T>) -> Fut, Fut: Future<Output = Out>,

Run a source against an arbitrary async terminator.

Trait Implementations

impl Clone for ActorMaterializer

fn clone(&self) -> ActorMaterializer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ActorMaterializer

fn default() -> ActorMaterializer

Returns the “default value” for a type.