Struct RunJobResult 

pub struct RunJobResult<T: Actor> {
    pub job_id: String,
    pub result_subscriber_rx: Option<Receiver<Result<<T as Actor>::Result, ActorError>>>,
}

Handle returned by run_job.

job_id is stable for the life of the job — pass it to abort_job / stop_job / resume_job. result_subscriber_rx is Some only when run_job was called with subscribe = true; each iteration’s outcome is pushed onto it. When the job ends (max_iter reached, aborted, or single-shot completion) the channel is closed, so recv() returning None is the natural termination signal.

Fields

job_id: String

Identifier you pass to abort_job / stop_job / resume_job. Defaults to a fresh UUID v4 unless an explicit id was supplied.

result_subscriber_rx: Option<Receiver<Result<<T as Actor>::Result, ActorError>>>

Per-iteration result stream. None when the job was submitted with subscribe = false (fire-and-forget).

Trait Implementations

impl<T: Debug + Actor> Debug for RunJobResult<T>

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

Formats the value using the given formatter.