Struct ScriptedOutputSink 

pub struct ScriptedOutputSink { /* private fields */ }

In-memory scripted output sink fixture for SDK conformance tests. Use it to script deterministic behavior in memory; any transcript or endpoint mutation is documented on the method that performs it.

Implementations

impl ScriptedOutputSink

pub fn new( sink_ref: OutputSinkRef, capabilities: OutputSinkCapabilities, ) -> Self

Creates a new testing::output_delivery value with explicit caller-provided inputs. This constructor is data-only and performs no I/O or external side effects.

Panics

Panics if constructor invariants fail, such as invalid identifier text or constructor-specific bounds. Use a fallible constructor such as try_new when one is available for untrusted input.

pub fn push_receipt(&self, receipt: Result<OutputDeliveryReceipt, AgentError>)

Push receipt. This reads or mutates deterministic in-memory test state unless the method explicitly names a fixture file.

pub fn calls(&self) -> Vec<OutputDeliveryRequest>

Operates on in-memory or journal-derived testing::output_delivery state for diagnostics and repair evidence. It does not create a second run loop or product workflow owner.

Trait Implementations

impl Clone for ScriptedOutputSink

fn clone(&self) -> ScriptedOutputSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl OutputSink for ScriptedOutputSink

fn sink_ref(&self) -> OutputSinkRef

Returns sink ref for the current value. This is a read-only or data-construction helper unless the method body explicitly calls a port or store.

fn capabilities(&self) -> OutputSinkCapabilities

Computes or returns capabilities for the ports::output_delivery contract without external I/O or side effects.

fn send_chunk( &self, request: OutputDeliveryRequest, ) -> Result<OutputDeliveryReceipt, AgentError>

Sends one output chunk to the configured sink. Implementations may perform sink I/O, but the runtime owns delivery policy checks, dedupe proof, and intent/result journal records.

fn send_final( &self, request: OutputDeliveryRequest, ) -> Result<OutputDeliveryReceipt, AgentError>

Sends the final output payload to the configured sink. Implementations may perform sink I/O, but the runtime owns delivery policy checks, dedupe proof, and intent/result journal records.

fn reconcile( &self, request: OutputDeliveryRequest, ) -> Result<OutputDeliveryReceipt, AgentError>

Reconciles prior delivery state with the sink without resending completed payloads. Implementations reconcile prior delivery state with the sink without resending completed payloads.