Struct Local 

pub struct Local<Op> { /* private fields */ }

A wire whose payload is the request and whose frames are the reply’s steps, for an operation whose events the runtime builds itself.

The transport is the runtime: it implements Transport<Local<Op>>, takes the request and delivers the reply’s Steps, ending with the operation’s end. A runtime that stops without it leaves the reply truncated. A failure that ends the reply is the transport’s own Err.

Implementations

impl<Op: Operation<Emit = Free>> Local<Op>

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

A wire named name (as records and telemetry name it), addressing no model id, with default capabilities.

pub fn with_capabilities(self, capabilities: Capabilities) -> Self

What a runtime accounts for, such as an embedding width.

pub fn with_id(self, id: impl Into<String>) -> Self

The model id this wire addresses.

Trait Implementations

impl<Op> Clone for Local<Op>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Op> Debug for Local<Op>

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

Formats the value using the given formatter.

impl Transport<Local<Embedding>> for MockEmbeddings

Available on crate feature test-utils only.

fn send( &self, texts: Vec<String>, _exchange: Exchange, ) -> Opening<Step<Embedding>>

Open the reply to one payload. Nothing is sent until the opening is first polled. A payload the transport cannot send in the exchange’s mode fails the opening; a failure after the reply opened is its last frame.

impl<Op: Operation<Emit = Free>> Wire for Local<Op>

type Op = Op

The operation this wire performs.

type Payload = <Op as Operation>::Request

What Self::encode produces for the transport to send.

type Frame = Step<Op>

One unit of a reply, as the transport delivers it.

type Decoder<'id> = Steps

The decoder for one of its replies, branded with that reply.

type Reassembler = Unreassembled

What rebuilds a reply’s provider document from its frames when the transport reports no whole document, as for a stream. The driver feeds it every frame and records what it finishes with as raw. A wire whose operation’s decoders record raw themselves names document::Unreassembled; a completion wire cannot, because it does not Serve completions.

fn describe(&self) -> Descriptor<'_>

What the wire says about itself.

fn encode( &self, request: Op::Request, _mode: Mode, ) -> Result<Op::Request, EncodeError>

The request to send. Pure: it may read self, request and mode, and nothing else. A request that cannot be built is an EncodeError, which always reports as a request failure.

fn decoder<'id>(&self) -> Self::Decoder<'id>

A fresh decoder for one reply.

fn reassembler(&self) -> Self::Reassembler

A fresh reassembler for one reply. A wire that picks its API per reply builds the matching one.