Struct StackConcat 

pub struct StackConcat<A, B>(pub A, pub B);

Concatenates two arm stacks into one, running both concurrently.

Arm indices from A are 0..A::SIZE; arm indices from B are offset by A::SIZE. Outputs are (A::Outputs, B::Outputs).

Tuple Fields

0: A

1: B

Trait Implementations

impl<'de, KP, A, B> MapArmStack<'de, KP> for StackConcat<A, B>

where KP: MapKeyProbe<'de>, A: MapArmStack<'de, KP>, B: MapArmStack<'de, KP>,

const SIZE: usize

type Outputs = (<A as MapArmStack<'de, KP>>::Outputs, <B as MapArmStack<'de, KP>>::Outputs)

Left-nested tuple of Option<(K, V)> for each arm.

type RaceState = ConcatRaceState<<A as MapArmStack<'de, KP>>::RaceState, <B as MapArmStack<'de, KP>>::RaceState>

type DispatchState = ConcatDispatchState<<A as MapArmStack<'de, KP>>::DispatchState, <B as MapArmStack<'de, KP>>::DispatchState>

fn unsatisfied_count(&self) -> usize

Number of arms that still require a value (required fields not yet matched). Virtual arms are excluded.

fn open_count(&self) -> usize

Number of arms still willing to run, including virtual arms.

fn init_race(&mut self, kp: KP) -> Self::RaceState

fn poll_race_one( &mut self, state: Pin<&mut Self::RaceState>, arm_index: usize, cx: &mut Context<'_>, ) -> Poll<Result<Probe<(usize, KP::KeyClaim)>, KP::Error>>

fn init_dispatch( &mut self, arm_index: usize, vp: VP<'de, KP>, ) -> Self::DispatchState

fn poll_dispatch( &mut self, state: Pin<&mut Self::DispatchState>, cx: &mut Context<'_>, ) -> Poll<Result<Probe<(VC<'de, KP>, ())>, KP::Error>>

fn take_outputs(&mut self) -> Self::Outputs

async fn race_keys( &mut self, kp: KP, ) -> Result<Probe<(usize, KP::KeyClaim)>, KP::Error>

Race all unsatisfied arms’ key callbacks against the given key probe.

async fn dispatch_value( &mut self, arm_index: usize, vp: VP<'de, KP>, ) -> Result<Probe<(VC<'de, KP>, ())>, KP::Error>

Dispatch the value probe to the arm at arm_index.

impl<KP, A, B> MapArmStackOwned<KP> for StackConcat<A, B>

where KP: MapKeyProbeOwned, A: MapArmStackOwned<KP>, B: MapArmStackOwned<KP>,

const SIZE: usize

type Outputs = (<A as MapArmStackOwned<KP>>::Outputs, <B as MapArmStackOwned<KP>>::Outputs)

Left-nested tuple of Option<(K, V)> for each arm.

type RaceState = ConcatRaceState<<A as MapArmStackOwned<KP>>::RaceState, <B as MapArmStackOwned<KP>>::RaceState>

Pinned state holding per-arm key futures for one round of racing.

type DispatchState = ConcatDispatchState<<A as MapArmStackOwned<KP>>::DispatchState, <B as MapArmStackOwned<KP>>::DispatchState>

Pinned state for dispatching the winning arm’s value callback. Only one arm is dispatched per call (the race winner).

fn unsatisfied_count(&self) -> usize

Number of arms that still require a value (required fields not yet matched). Virtual arms (skip-unknown, dup-detect, tag-inject) are excluded.

fn open_count(&self) -> usize

Number of arms still willing to run, including both unsatisfied required-field arms and always-active virtual arms.

fn init_race(&mut self, kp: KP) -> Self::RaceState

Fork kp for each unsatisfied arm, call each arm’s key callback to create its future, and return the combined pinned state.

fn poll_race_one( &mut self, state: Pin<&mut Self::RaceState>, arm_index: usize, cx: &mut Context<'_>, ) -> Poll<Result<Probe<(usize, KP::KeyClaim)>, KP::Error>>

Poll a single arm’s key future. Sync - recursion through (Rest, Slot) is ordinary function calls, not async nesting.

fn init_dispatch(&mut self, arm_index: usize, vp: VP<KP>) -> Self::DispatchState

Create the dispatch state for the winning arm at arm_index.

fn poll_dispatch( &mut self, state: Pin<&mut Self::DispatchState>, cx: &mut Context<'_>, ) -> Poll<Result<Probe<(VC<KP>, ())>, KP::Error>>

Poll the dispatch future.

fn take_outputs(&mut self) -> Self::Outputs

Extract all outputs.

async fn race_keys( &mut self, kp: KP, ) -> Result<Probe<(usize, KP::KeyClaim)>, KP::Error>

Race all unsatisfied arms’ key callbacks against the given key probe.

async fn dispatch_value( &mut self, arm_index: usize, vp: VP<KP>, ) -> Result<Probe<(VC<KP>, ())>, KP::Error>

Dispatch the value probe to the arm at arm_index.