Struct StreamActor 

pub struct StreamActor { /* private fields */ }

An actor that forwards the items of a stream to its parent as events named item_event, one per turn, and completes when the stream ends.

Implementations

impl StreamActor

pub fn new( address: Address, item_event: impl Into<String>, stream: ActorStream, ) -> Self

An actor at address forwarding stream.

pub fn invokable<F>(item_event: &str, f: F) -> ActorFactory

where F: Fn(Value) -> ActorStream + Send + Sync + 'static,

The factory of an invokable stream: f opens the stream from the invoke’s parameters.

Trait Implementations

impl Actor for StreamActor

fn address(&self) -> &Address

The actor’s address.

fn turn(&mut self, input: ActorInput) -> Turn

Handles one input.

impl Debug for StreamActor

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

Formats the value using the given formatter.