Struct JsonRpcLineEndpoint 

pub struct JsonRpcLineEndpoint { /* private fields */ }

Protocol json rpc line endpoint value used by toolkit JSON-RPC adapters. Constructing the value prepares protocol data; endpoint and transport methods own transcript or I/O effects.

Implementations

impl JsonRpcLineEndpoint

pub fn pair( left_name: impl Into<String>, right_name: impl Into<String>, ) -> (Self, Self)

Builds the pair value. This is data construction and performs no I/O, journal append, event publication, or process work.

pub fn name(&self) -> &str

Returns the name currently held by this value. This reads endpoint metadata or a queued response from the in-memory transport.

pub fn send_frame(&self, frame: JsonRpcFrame) -> Result<String, AgentError>

Queues a JSON-RPC frame on the paired in-memory endpoint and records transcript state for tests; it performs no OS-level I/O.

pub fn send_raw_line(&self, line: impl Into<String>) -> Result<(), AgentError>

Queues a JSON-RPC frame on the paired in-memory endpoint and records transcript state for tests; it performs no OS-level I/O.

pub fn try_receive_raw_line(&self) -> Result<Option<String>, AgentError>

Reads a JSON-RPC line or frame from the in-memory endpoint queue. It does not perform OS-level I/O.

pub fn try_receive_frame(&self) -> Result<Option<JsonRpcFrame>, AgentError>

Reads a JSON-RPC line or frame from the in-memory endpoint queue. It does not perform OS-level I/O.

pub fn receive_frame(&self) -> Result<JsonRpcFrame, AgentError>

Reads a JSON-RPC line or frame from the in-memory endpoint queue. It does not perform OS-level I/O.

pub fn send_request( &self, id: impl Into<JsonRpcId>, method: impl Into<String>, params: Value, ) -> Result<String, AgentError>

Queues a JSON-RPC frame on the paired in-memory endpoint and records transcript state for tests; it performs no OS-level I/O.

pub fn send_notification( &self, method: impl Into<String>, params: Value, ) -> Result<String, AgentError>

Queues a JSON-RPC frame on the paired in-memory endpoint and records transcript state for tests; it performs no OS-level I/O.

pub fn send_result( &self, id: JsonRpcId, result: Value, ) -> Result<String, AgentError>

Queues a JSON-RPC frame on the paired in-memory endpoint and records transcript state for tests; it performs no OS-level I/O.

pub fn send_error( &self, id: Option<JsonRpcId>, code: i64, message: impl Into<String>, ) -> Result<String, AgentError>

Queues a JSON-RPC frame on the paired in-memory endpoint and records transcript state for tests; it performs no OS-level I/O.

pub fn response(&self) -> Result<JsonRpcResponse, AgentError>

Returns the response currently held by this value. This reads endpoint metadata or a queued response from the in-memory transport.

pub fn notification(&self) -> Result<JsonRpcNotification, AgentError>

Returns notification for this protocol::line_transport value without performing external I/O.

pub fn sent_lines(&self) -> Vec<String>

Returns sent lines for this protocol::line_transport value without performing external I/O. Panics only if the in-memory test transcript lock is poisoned.

pub fn received_lines(&self) -> Vec<String>

Returns received lines for this protocol::line_transport value without performing external I/O. Panics only if the in-memory test transcript lock is poisoned.

Trait Implementations

impl Clone for JsonRpcLineEndpoint

fn clone(&self) -> JsonRpcLineEndpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JsonRpcLineEndpoint

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

Formats the value using the given formatter.