Struct RactorActorRef 

pub struct RactorActorRef<A: Actor> { /* private fields */ }

A dactor ActorRef backed by a ractor ActorRef.

Messages are delivered through ractor’s mailbox as type-erased dispatch envelopes, enabling multiple Handler<M> impls per actor.

When configured with MailboxConfig::Bounded, a bounded mpsc channel sits in front of the ractor actor, providing backpressure control at the dactor level while ractor’s internal mailbox remains unbounded.

Trait Implementations

impl<A: Actor + 'static> ActorRef<A> for RactorActorRef<A>

fn id(&self) -> ActorId

The actor’s unique identity.

fn name(&self) -> String

The actor’s name (as given to spawn).

fn is_alive(&self) -> bool

Check if the actor is still alive.

fn pending_messages(&self) -> usize

Approximate number of messages pending in the actor’s mailbox.

fn stop(&self)

Gracefully stop the actor. Closes the mailbox and triggers on_stop.

fn tell<M>(&self, msg: M) -> Result<(), ActorSendError>

where A: Handler<M>, M: Message<Reply = ()>,

Fire-and-forget: deliver a message to the actor. The message must have Reply = () (no reply expected).

fn ask<M>( &self, msg: M, cancel: Option<CancellationToken>, ) -> Result<AskReply<M::Reply>, ActorSendError>

where A: Handler<M>, M: Message,

Request-reply: send a message and await the reply.

fn expand<M, OutputItem>( &self, msg: M, buffer: usize, batch_config: Option<BatchConfig>, cancel: Option<CancellationToken>, ) -> Result<BoxStream<OutputItem>, ActorSendError>

where A: ExpandHandler<M, OutputItem>, M: Send + 'static, OutputItem: Send + 'static,

Request-stream: send a request and receive a stream of responses. buffer controls the channel capacity (backpressure).

fn reduce<InputItem, Reply>( &self, input: BoxStream<InputItem>, buffer: usize, batch_config: Option<BatchConfig>, cancel: Option<CancellationToken>, ) -> Result<AskReply<Reply>, ActorSendError>

where A: ReduceHandler<InputItem, Reply>, InputItem: Send + 'static, Reply: Send + 'static,

Client-streaming (feed): stream items to the actor and receive a reply.

fn transform<InputItem, OutputItem>( &self, input: BoxStream<InputItem>, buffer: usize, batch_config: Option<BatchConfig>, cancel: Option<CancellationToken>, ) -> Result<BoxStream<OutputItem>, ActorSendError>

where A: TransformHandler<InputItem, OutputItem>, InputItem: Send + 'static, OutputItem: Send + 'static,

Transform: stream items to the actor and receive a stream of outputs.

impl<A: Actor> Clone for RactorActorRef<A>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Actor> Debug for RactorActorRef<A>

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

Formats the value using the given formatter.