Struct HSingle 

pub struct HSingle<H>(pub H);

Single-element heterogeneous list (base case).

This is the minimal non-empty list, required because HNil doesn’t implement InstructionList.

Tuple Fields

0: H

Implementations

impl<H> HSingle<H>

pub fn new(head: H) -> Self

Create a new single-element list.

Trait Implementations

impl<H: Clone> Clone for HSingle<H>

fn clone(&self) -> HSingle<H>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<H: Debug> Debug for HSingle<H>

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

Formats the value using the given formatter.

impl<'de, H> Deserialize<'de> for HSingle<H>

where H: Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<S, Ctx, Err> InstructionList<Ctx, Err> for HSingle<StepWrapper<S, Ctx, Err>>

where S: Step<Ctx, Err>, Ctx: Send + Sync + 'static, Err: Send + Sync + Clone + 'static,

Implementation for single-element list (base case).

const LEN: usize = 1

Number of steps in this instruction list.

fn execute_all<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 mut Ctx, state: &'life2 mut ExecutionState, ) -> Pin<Box<dyn Future<Output = BlockResult<Err>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute all instructions in forward order.

fn compensate_all<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 mut Ctx, state: &'life2 mut ExecutionState, ) -> Pin<Box<dyn Future<Output = Result<CompensationOutcome, Err>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Compensate executed instructions in reverse order.

fn execute_at<'life0, 'life1, 'async_trait>( &'life0 self, index: usize, ctx: &'life1 mut Ctx, ) -> Pin<Box<dyn Future<Output = Result<StepOutcome, Err>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute a single step at the given index.

fn compensate_at<'life0, 'life1, 'async_trait>( &'life0 self, index: usize, ctx: &'life1 mut Ctx, ) -> Pin<Box<dyn Future<Output = Result<CompensationOutcome, Err>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Compensate a single step at the given index.

fn retry_policy_at(&self, index: usize) -> RetryPolicy

Get the retry policy for the step at the given index.

impl<H> Serialize for HSingle<H>

where H: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.