Struct ReActActor 

pub struct ReActActor;

ReAct Actor

Implementations

impl ReActActor

pub fn new() -> Self

创建新的 ReAct Actor

Trait Implementations

impl Actor for ReActActor

type Msg = ReActMessage

The message type for this actor

type State = ReActActorState

The type of state this actor manages internally

type Arguments = (Arc<LLMAgent>, ReActConfig, Vec<Arc<dyn ReActTool>>)

Initialization arguments

fn pre_start( &self, _myself: ActorRef<Self::Msg>, args: Self::Arguments, ) -> impl Future<Output = Result<Self::State, ActorProcessingErr>> + Send

Invoked when an actor is being started by the system.

fn handle( &self, myself: ActorRef<Self::Msg>, message: Self::Msg, state: &mut Self::State, ) -> impl Future<Output = Result<(), ActorProcessingErr>> + Send

Handle the incoming message from the event processing loop. Unhandled panickes will be captured and sent to the supervisor(s)

fn post_start( &self, myself: ActorRef<Self::Msg>, state: &mut Self::State, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

Invoked after an actor has started.

fn post_stop( &self, myself: ActorRef<Self::Msg>, state: &mut Self::State, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

Invoked after an actor has been stopped to perform final cleanup. In the event the actor is terminated with Signal::Kill or has self-panicked, post_stop won’t be called.

fn handle_supervisor_evt( &self, myself: ActorRef<Self::Msg>, message: SupervisionEvent, state: &mut Self::State, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

Handle the incoming supervision event. Unhandled panics will be captured and sent the the supervisor(s). The default supervision behavior is to exit the supervisor on any child exit. To override this behavior, implement this function.

fn spawn( name: Option<String>, handler: Self, startup_args: Self::Arguments, ) -> impl Future<Output = Result<(ActorRef<Self::Msg>, JoinHandle<()>), SpawnErr>> + Send

Spawn an actor of this type, which is unsupervised, automatically starting

fn spawn_linked( name: Option<String>, handler: Self, startup_args: Self::Arguments, supervisor: ActorCell, ) -> impl Future<Output = Result<(ActorRef<Self::Msg>, JoinHandle<()>), SpawnErr>> + Send

Spawn an actor of this type with a supervisor, automatically starting the actor

impl Default for ReActActor

fn default() -> Self

Returns the “default value” for a type.