Struct ActorSource 

pub struct ActorSource;

Collection of actor-backed source constructors.

Implementations

impl ActorSource

pub fn actor_ref<T>() -> Source<T, ActorRef<ActorSourceMessage<T>>>

where T: Send + 'static,

Materializes a typed actor ref that feeds this source.

Mailbox risk

This source uses Ractor’s regular actor mailbox. It is not backpressured: a fast sender can enqueue messages faster than the stream consumes them, and the actor mailbox and this source’s internal buffer can grow without bound. Prefer ActorSource::actor_ref_with_backpressure when the producer may outpace downstream demand.

pub fn typed<T>() -> Source<T, ActorRef<ActorSourceMessage<T>>>

where T: Send + 'static,

Alias for ActorSource::actor_ref using Datum’s explicit protocol enum.

pub fn actor_ref_with_backpressure<T, AckMsg>( ack_to: ActorRef<AckMsg>, ack_message: AckMsg, ) -> Source<T, ActorRef<ActorSourceMessage<T>>>

where T: Send + 'static, AckMsg: Message + Clone + Sync,

Materializes a typed actor ref that accepts one element per ack.

The source sends ack_message to ack_to at startup and after each emitted element. Sending another Element before the ack arrives at the producer violates the protocol and fails the stream.