Struct BatchNodeExecutor 

pub struct BatchNodeExecutor<E> { /* private fields */ }

Node executor adapter for host-owned batch implementations such as WASM.

The adapter owns the host side of the batch boundary: it drains all currently connected input edges, invokes the topology-blind batch executor, and sends every returned packet through normal PortsOut validation before a packet can enter graph edges.

Implementations

impl<E> BatchNodeExecutor<E>

pub const fn new(executor: E) -> Self

Wrap one batch executor as a runtime node executor.

pub const fn executor(&self) -> &E

Borrow the wrapped batch executor.

Trait Implementations

impl<E: Debug> Debug for BatchNodeExecutor<E>

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

Formats the value using the given formatter.

impl<E> NodeExecutor for BatchNodeExecutor<E>

where E: BatchExecutor,

type RunFuture<'a> = Pin<Box<dyn Future<Output = Result<(), PureflowError>> + Send + 'a>> where Self: 'a

Future returned by one node execution attempt.

fn run( &self, ctx: NodeContext, inputs: PortsIn, outputs: PortsOut, ) -> Self::RunFuture<'_>

Execute one runtime-managed node boundary.