Struct ScriptedRealtimeAdapter 

pub struct ScriptedRealtimeAdapter { /* private fields */ }

In-memory scripted realtime adapter 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 ScriptedRealtimeAdapter

pub fn new(adapter_ref: impl Into<String>) -> Self

Creates a new testing::realtime 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_output(&self, frame: RealtimeOutputFrame)

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

pub fn fail_next_restart(&self, message: impl Into<String>)

Fail next restart. This reads or mutates deterministic in-memory test state unless the method explicitly names a fixture file.

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

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

pub fn call_names(&self) -> Vec<&'static str>

Returns the call names currently held by this value. This configures deterministic in-memory test state only.

Trait Implementations

impl Clone for ScriptedRealtimeAdapter

fn clone(&self) -> ScriptedRealtimeAdapter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ScriptedRealtimeAdapter

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

Formats the value using the given formatter.

impl RealtimeProviderAdapter for ScriptedRealtimeAdapter

fn adapter_ref(&self) -> &str

Returns the adapter ref identifier for this adapter. This is a side-effect-free adapter identifier accessor.

fn connect( &self, request: RealtimeConnectRequest, ) -> Result<RealtimeConnectResponse, AgentError>

Opens or attaches to a realtime adapter session. Implementations open or attach to a realtime adapter session and return the session record without appending journal records themselves.

fn send( &self, session_id: &RealtimeSessionId, frame: RealtimeInputFrame, ) -> Result<(), AgentError>

Sends one input frame to the active realtime adapter session. Implementations send one realtime input frame to the active adapter session and return the adapter response record.

fn receive( &self, session_id: &RealtimeSessionId, ) -> Result<Option<RealtimeOutputFrame>, AgentError>

Reads from the in-memory endpoint queue used by protocol tests; it performs no OS-level I/O.

fn interrupt( &self, session_id: &RealtimeSessionId, response_id: &RealtimeResponseId, ) -> Result<RealtimeAdapterAck, AgentError>

Sends an interruption request to the active realtime adapter session. Implementations send an interruption request to the active realtime adapter session.

fn restart( &self, session_id: &RealtimeSessionId, current_connection_id: &RealtimeConnectionId, ) -> Result<RealtimeConnectResponse, AgentError>

Restarts or reconnects the active realtime adapter session. Implementations restart or reconnect the active realtime adapter session and return the new session record.

fn close( &self, session_id: &RealtimeSessionId, reason: RealtimeCloseReason, ) -> Result<RealtimeAdapterAck, AgentError>

Closes the active realtime adapter session. Implementations close or detach the realtime adapter session according to the requested close reason.