Enum BatchResult 

pub enum BatchResult<C = GenerationContinuation> {
    Succeeded {
        custom_id: String,
        output: Box<GenerateResponse<C>>,
    },
    Failed {
        custom_id: String,
        error: RemoteFailure,
    },
    Cancelled {
        custom_id: String,
    },
    Expired {
        custom_id: String,
    },
}

One terminal batch row.

Variants

Succeeded

A row completed successfully.

Fields

custom_id: String

Caller-provided row correlation identifier.

output: Box<GenerateResponse<C>>

Normalized generation output.

Failed

A row failed.

Fields

custom_id: String

Caller-provided row correlation identifier.

error: RemoteFailure

Provider-authored row failure with explicitly accessed native evidence.

Cancelled

A row was cancelled.

Fields

custom_id: String

Caller-provided row correlation identifier.

Expired

A row expired before completion.

Fields

custom_id: String

Caller-provided row correlation identifier.

Implementations

impl<C> BatchResult<C>

pub fn try_map_continuation<D>( self, map: impl FnMut(C) -> Result<D, KitError>, ) -> Result<BatchResult<D>, KitError>

Maps continuation state carried by a successful row.

Errors

Returns the mapping error for a successful row continuation. Failure, cancellation, and expiration rows retain their exact correlation and evidence.

Examples

use providers_kit::batch::BatchResult;
let row: BatchResult<()> = BatchResult::Cancelled { custom_id: "row-1".into() };
let mapped: BatchResult<String> = row.try_map_continuation(|()| Ok("state".into()))?;
assert!(matches!(mapped, BatchResult::Cancelled { custom_id } if custom_id == "row-1"));

Trait Implementations

impl<C: Clone> Clone for BatchResult<C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for BatchResult<C>

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

Formats the value using the given formatter.

impl<'de, C> Deserialize<'de> for BatchResult<C>

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<C: PartialEq> PartialEq for BatchResult<C>

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<C> Serialize for BatchResult<C>

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<C: PartialEq> StructuralPartialEq for BatchResult<C>