Struct ScriptedPeer 

pub struct ScriptedPeer { /* private fields */ }

A hostile A2A peer on a loopback port. See the module docs.

Implementations

impl ScriptedPeer

pub const fn new() -> Self

A JSON-RPC peer that stalls after one event; the methods below change either half.

pub const fn on(self, binding: Binding) -> Self

The binding to speak.

pub const fn stall_after(self, events: usize) -> Self

Send events, then fall silent with the connection held open.

pub const fn cut_off_after(self, events: usize) -> Self

Send events, then drop the connection (or, on gRPC, reset the stream).

pub const fn misframe_after(self, events: usize) -> Self

Send events, then one that does not parse, then fall silent.

pub const fn unauthorized(self) -> Self

Refuse every call as unauthenticated.

pub async fn start(self) -> Result<RunningPeer>

Binds 127.0.0.1:0 and starts answering.

Errors

Returns the error from binding the listener.

Trait Implementations

impl Clone for ScriptedPeer

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ScriptedPeer

impl Debug for ScriptedPeer

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

Formats the value using the given formatter.

impl Default for ScriptedPeer

fn default() -> Self

Returns the “default value” for a type.