Struct UnitsOfWork 

pub struct UnitsOfWork(/* private fields */);

A collection of units of work grouped by flow

Each inner vector represents one flow’s units, ordered by version. The flow’s units must be processed sequentially to maintain version ordering. Different flows (outer vector) can be processed in parallel.

Implementations

impl UnitsOfWork

pub fn new(flow_units: Vec<Vec<UnitOfWork>>) -> Self

Create a new UnitsOfWork from a vector of flow units

pub fn empty() -> Self

Create an empty UnitsOfWork

pub fn is_empty(&self) -> bool

Check if there are no units of work

pub fn flow_count(&self) -> usize

Get the number of flows

pub fn total_units(&self) -> usize

Get the total number of units across all flows

pub fn as_inner(&self) -> &Vec<Vec<UnitOfWork>>

Get a reference to the inner vector

pub fn into_inner(self) -> Vec<Vec<UnitOfWork>>

Consume self and return the inner vector

Trait Implementations

impl Clone for UnitsOfWork

fn clone(&self) -> UnitsOfWork

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UnitsOfWork

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

Formats the value using the given formatter.

impl From<Vec<Vec<UnitOfWork>>> for UnitsOfWork

fn from(flow_units: Vec<Vec<UnitOfWork>>) -> Self

Converts to this type from the input type.

impl IntoIterator for UnitsOfWork

type Item = Vec<UnitOfWork>

The type of the elements being iterated over.

type IntoIter = IntoIter<Vec<UnitOfWork>>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.