Struct BatchItem 

pub struct BatchItem<T> {
    pub index: usize,
    pub status: BatchItemStatus,
    pub result: Option<T>,
    pub error: Option<ErrorObject>,
}

Result of a single item in a batch operation.

Contains the status, optional result value, and optional error for each item processed in a map or parallel operation.

Examples

use durable_execution_sdk::concurrency::{BatchItem, BatchItemStatus};
use durable_execution_sdk::ErrorObject;

// Succeeded item
let success = BatchItem::succeeded(0, 42);
assert!(success.is_succeeded());
assert_eq!(success.get_result(), Some(&42));

// Failed item
let error = ErrorObject::new("TestError", "Something went wrong");
let failure = BatchItem::<i32>::failed(1, error);
assert!(failure.is_failed());
assert!(failure.get_error().is_some());

// Pending item
let pending = BatchItem::<i32>::pending(2);
assert_eq!(pending.status, BatchItemStatus::Pending);

Fields

index: usize

Index of this item in the original collection

status: BatchItemStatus

Status of this item

result: Option<T>

Result value if succeeded

error: Option<ErrorObject>

Error details if failed

Implementations

impl<T> BatchItem<T>

pub fn succeeded(index: usize, result: T) -> Self

Creates a new succeeded BatchItem.

pub fn failed(index: usize, error: ErrorObject) -> Self

Creates a new failed BatchItem.

pub fn cancelled(index: usize) -> Self

Creates a new cancelled BatchItem.

pub fn pending(index: usize) -> Self

Creates a new pending BatchItem.

pub fn suspended(index: usize) -> Self

Creates a new suspended BatchItem.

pub fn is_succeeded(&self) -> bool

Returns true if this item succeeded.

pub fn is_failed(&self) -> bool

Returns true if this item failed.

pub fn get_result(&self) -> Option<&T>

Returns a reference to the result if succeeded.

pub fn get_error(&self) -> Option<&ErrorObject>

Returns a reference to the error if failed.

Trait Implementations

impl<T: Clone> Clone for BatchItem<T>

fn clone(&self) -> BatchItem<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for BatchItem<T>

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

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for BatchItem<T>

where T: Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T> Serialize for BatchItem<T>

where T: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.